提交 046db9be 编写于 作者: E Emil Condrea 提交者: Stefano Stabellini

xen: Move xenstore_update to xen_pvdev.c

 * xenstore_update -> xen_pvdev.c
Signed-off-by: NEmil Condrea <emilcondrea@gmail.com>
Signed-off-by: NStefano Stabellini <sstabellini@kernel.org>
Signed-off-by: NQuan Xu <xuquan8@huawei.com>
Acked-by: NAnthony PERARD <anthony.perard@citrix.com>
上级 f0021dba
...@@ -556,8 +556,8 @@ static int xenstore_scan(const char *type, int dom, struct XenDevOps *ops) ...@@ -556,8 +556,8 @@ static int xenstore_scan(const char *type, int dom, struct XenDevOps *ops)
return 0; return 0;
} }
static void xenstore_update_be(char *watch, char *type, int dom, void xenstore_update_be(char *watch, char *type, int dom,
struct XenDevOps *ops) struct XenDevOps *ops)
{ {
struct XenDevice *xendev; struct XenDevice *xendev;
char path[XEN_BUFSIZE], *bepath; char path[XEN_BUFSIZE], *bepath;
...@@ -590,7 +590,7 @@ static void xenstore_update_be(char *watch, char *type, int dom, ...@@ -590,7 +590,7 @@ static void xenstore_update_be(char *watch, char *type, int dom,
} }
} }
static void xenstore_update_fe(char *watch, struct XenDevice *xendev) void xenstore_update_fe(char *watch, struct XenDevice *xendev)
{ {
char *node; char *node;
unsigned int len; unsigned int len;
...@@ -607,30 +607,6 @@ static void xenstore_update_fe(char *watch, struct XenDevice *xendev) ...@@ -607,30 +607,6 @@ static void xenstore_update_fe(char *watch, struct XenDevice *xendev)
xen_be_frontend_changed(xendev, node); xen_be_frontend_changed(xendev, node);
xen_be_check_state(xendev); xen_be_check_state(xendev);
} }
static void xenstore_update(void *unused)
{
char **vec = NULL;
intptr_t type, ops, ptr;
unsigned int dom, count;
vec = xs_read_watch(xenstore, &count);
if (vec == NULL) {
goto cleanup;
}
if (sscanf(vec[XS_WATCH_TOKEN], "be:%" PRIxPTR ":%d:%" PRIxPTR,
&type, &dom, &ops) == 3) {
xenstore_update_be(vec[XS_WATCH_PATH], (void *)type, dom, (void*)ops);
}
if (sscanf(vec[XS_WATCH_TOKEN], "fe:%" PRIxPTR, &ptr) == 1) {
xenstore_update_fe(vec[XS_WATCH_PATH], (void *)ptr);
}
cleanup:
free(vec);
}
static void xen_be_evtchn_event(void *opaque) static void xen_be_evtchn_event(void *opaque)
{ {
struct XenDevice *xendev = opaque; struct XenDevice *xendev = opaque;
......
...@@ -95,6 +95,29 @@ int xenstore_read_uint64(const char *base, const char *node, uint64_t *uval) ...@@ -95,6 +95,29 @@ int xenstore_read_uint64(const char *base, const char *node, uint64_t *uval)
return rc; return rc;
} }
void xenstore_update(void *unused)
{
char **vec = NULL;
intptr_t type, ops, ptr;
unsigned int dom, count;
vec = xs_read_watch(xenstore, &count);
if (vec == NULL) {
goto cleanup;
}
if (sscanf(vec[XS_WATCH_TOKEN], "be:%" PRIxPTR ":%d:%" PRIxPTR,
&type, &dom, &ops) == 3) {
xenstore_update_be(vec[XS_WATCH_PATH], (void *)type, dom, (void*)ops);
}
if (sscanf(vec[XS_WATCH_TOKEN], "fe:%" PRIxPTR, &ptr) == 1) {
xenstore_update_fe(vec[XS_WATCH_PATH], (void *)ptr);
}
cleanup:
free(vec);
}
const char *xenbus_strstate(enum xenbus_state state) const char *xenbus_strstate(enum xenbus_state state)
{ {
static const char *const name[] = { static const char *const name[] = {
......
...@@ -19,6 +19,9 @@ int xenstore_write_be_int(struct XenDevice *xendev, const char *node, int ival); ...@@ -19,6 +19,9 @@ int xenstore_write_be_int(struct XenDevice *xendev, const char *node, int ival);
int xenstore_write_be_int64(struct XenDevice *xendev, const char *node, int64_t ival); int xenstore_write_be_int64(struct XenDevice *xendev, const char *node, int64_t ival);
char *xenstore_read_be_str(struct XenDevice *xendev, const char *node); char *xenstore_read_be_str(struct XenDevice *xendev, const char *node);
int xenstore_read_be_int(struct XenDevice *xendev, const char *node, int *ival); int xenstore_read_be_int(struct XenDevice *xendev, const char *node, int *ival);
void xenstore_update_fe(char *watch, struct XenDevice *xendev);
void xenstore_update_be(char *watch, char *type, int dom,
struct XenDevOps *ops);
char *xenstore_read_fe_str(struct XenDevice *xendev, const char *node); char *xenstore_read_fe_str(struct XenDevice *xendev, const char *node);
int xenstore_read_fe_int(struct XenDevice *xendev, const char *node, int *ival); int xenstore_read_fe_int(struct XenDevice *xendev, const char *node, int *ival);
int xenstore_read_fe_uint64(struct XenDevice *xendev, const char *node, int xenstore_read_fe_uint64(struct XenDevice *xendev, const char *node,
......
...@@ -60,6 +60,7 @@ int xenstore_write_int64(const char *base, const char *node, int64_t ival); ...@@ -60,6 +60,7 @@ int xenstore_write_int64(const char *base, const char *node, int64_t ival);
char *xenstore_read_str(const char *base, const char *node); char *xenstore_read_str(const char *base, const char *node);
int xenstore_read_int(const char *base, const char *node, int *ival); int xenstore_read_int(const char *base, const char *node, int *ival);
int xenstore_read_uint64(const char *base, const char *node, uint64_t *uval); int xenstore_read_uint64(const char *base, const char *node, uint64_t *uval);
void xenstore_update(void *unused);
const char *xenbus_strstate(enum xenbus_state state); const char *xenbus_strstate(enum xenbus_state state);
......
Markdown is supported
0% .
You are about to add 0 people to the discussion. Proceed with caution.
先完成此消息的编辑!
想要评论请 注册