在根（/）下有三个子目录，vm，local（实际上是/local/domain）和tool。vm存放虚拟机管理信息。tool暂时没有数据。而/local/domain存放了活动虚拟机配置和驱动信息。/local/domain中每一个目录项代表一个活动的虚拟机，例如/local/domain/0代表dom0。Dom0可以读写XenStore的全部数据，而Dom-x只能访问/local/domain/x的内容。需要在dom0和domx之间共享的内容，一般都写在这个目录下，所以/local/domain是最常用的目录。

Xen提供了多种接口用来操作XenStore：命令行的xenstore-*命令、用户空间的xs_系列函数、内核的XenBus接口，都可以用来方便地操作XenStore的数据。

例子

命令行

用户空间

内核空间

Note: example/Alice相当于/local/domain/{当前domain}/example/Alice

1. struct xsd_sockmsg
2. {
3. uint32_t type;  /* XS_??? */
4. uint32_treq_id;/* Request identifier, echoed in daemon's response.  */
5. uint32_ttx_id; /* Transaction id (0 if not related to a transaction). */
6. uint32_t len;   /* Length of data following this. */
7. /* Generally followed bynul-terminated string(s). */
8. };

1. #define XENSTORE_RING_SIZE 1024
2. typedef uint32_t XENSTORE_RING_IDX;
3. #define MASK_XENSTORE_IDX(idx) ((idx) & (XENSTORE_RING_SIZE-1))
4. struct xenstore_domain_interface {
5. char req[XENSTORE_RING_SIZE]; /* Requests to xenstore daemon. */
6. char rsp[XENSTORE_RING_SIZE]; /* Replies and async watch events. */
7. XENSTORE_RING_IDX req_cons, req_prod;
8. XENSTORE_RING_IDX rsp_cons, rsp_prod;
9. };

1. static struct xenbus_watch xb_watch = {
2. .node = "memory",
3. .callback = watch_target;
4. };
5. ret = register_xenbus_watch(&xb_watch);
6. if(IS_ERR(ret)) {
7. IPRINTK("Failed to initialize balloon watcher\n");
8. } else {
9. IPRINTK("Balloon xenbus watcher initialized\n");
10. }

1. xs_handle *xh=xs_open(0);

1. assert(xs_watch(xh, path, token));
2. char **result = 0;
3. result = xs_read_watch(xh, &num);             //会阻塞
4. free(result);
5. xs_unwatch(xh, path, token);

1. char **xs_read_watch(struct xs_handle *h, unsigned int *num)
2. {
3. struct xs_stored_msg *msg;
4. char **ret, *strings, c = 0;
5. unsigned int num_strings, i;
6. mutex_lock(&h->watch_mutex);                 //------------------>加锁
7. //此处应该加一个pthread_cleanup_push(pthread_mutex_unlock, &h->watch_mutex)
8. #ifdef USE_PTHREAD
9. /* Wait on the condition variable for a watch to fire.
10. * If the reader thread doesn't exist yet, then that's because
11. * we haven't called xs_watch.  Presumably the application
12. * will do so later; in the meantime we just block.
13. */
14. while (list_empty(&h->watch_list) && h->fd != -1)
15. condvar_wait(&h->watch_condvar, &h->watch_mutex);
16. #else /* !defined(USE_PTHREAD) */
17. /* Read from comms channel ourselves if there are no threads
18. * and therefore no reader thread. */
19. assert(!read_thread_exists(h)); /* not threadsafe but worth a check */
20. if ((read_message(h) == -1))                //----------------------->没有消息时阻塞在这里
21. return NULL;

1. //used to extract (>_<) xs_handle internal members.
2. typedef struct list_head {
3. struct list_head *next, *prev;
4. }list_head_struct;
5. typedef struct
6. {
7. int fd;
8. pthread_t read_thr;
9. int read_thr_exists;
10. struct list_head watch_list;
11. pthread_mutex_t watch_mutex;//监视信号量，可能死锁
12. pthread_cond_t watch_condvar;
13. int watch_pipe[2];
14. struct list_head reply_list;
15. pthread_mutex_t reply_mutex;//回复信号量
16. pthread_cond_t reply_condvar;
17. pthread_mutex_t request_mutex;//请求信号量
18. }my_xs_handle;
19. #if __GNUC__ > 3
20. #define offsetof(a,b) __builtin_offsetof(a,b)//提取偏移量的宏。
21. #else
22. #define offsetof(a,b) ((unsigned long)&(((a *)0)->b))
23. #endif

1. #define check_xh_lock(x) do {\
2. pthread_mutex_t *pm = (pthread_mutex_t *)(((void *)pthis->xh) + offsetof(my_xs_handle, x));  \
3. if (pthread_mutex_trylock(pm) == EBUSY){            \           //pthread_mutex_trylock 如果没上锁，则加锁；否则返回EBUSY
4. cout << "thread_cleanup -> " #x " is already locked!" << endl;   \
5. if (0 != pthread_mutex_unlock(pm))              \
6. cout << "thread_cleanup -> error unlocking!" << endl;            \
7. else cout << "thread_cleanup -> unlocking " #x << endl;          \
8. } else assert(pthread_mutex_unlock(pm)==0);             \
9. } while (0)

1. check_xh_lock(watch_mutex);
2. check_xh_lock(request_mutex);
3. check_xh_lock(reply_mutex);
4. cout << "----- unwatch -----" << endl;
5. xs_unwatch(pthis->xh, pthis->path.c_str(), map_path("watch", pthis->path).c_str());
6. check_xh_lock(watch_mutex);
7. check_xh_lock(request_mutex);
8. check_xh_lock(reply_mutex);
9. cout << "-----  close  -----" << endl;
10. xs_close(pthis->xh);
11. pthis->xh=0;

1. viktor@buxiang-OptiPlex-330:~/proj/xc_map$ sudo ./domu domu.cpp
2. watch -> add watch on path mmap/domu-cpp callback func 0x8049aad                       //主线程打开监视线程
3. thread_func -> begin watch thread path= mmap/domu-cpp                                  //监视线程注册watch
4. thread_func -> watch event path= mmap/domu-cpp token= watch/mmap/domu-cpp            //注册时会发生一次事件，忽略之
5. watch_callback -> entering
6. //（在这里等待，此时按下Ctrl+C）
7. ^Cmain received signal Interrupt
8. unwatch -> **stopping work thread. waiting here...work thread already stopped.          //主线程用pthread_cancel关闭监视线程
9. thread_cleanup -> path= mmap/domu-cpp thread=b6d6eb70                                    //监视线程退出，主线程开始清理
10. ----- unwatch -----
11. map_path -> watch/mmap/domu-cpp
12. thread_cleanup -> watch_mutex is already locked!                                   //此时watch_mutex上锁了，说明xs_read_watch没有释放资源
13. thread_cleanup -> unlocking watch_mutex                                          //强行解锁
14. -----  close  -----                 //调用xs_unwatch和xs_close关闭连接。