136 		} watch;  member
648 		msg->u.watch.vec = split(body, msg->hdr.len,  in xs_process_msg()
649 		    &msg->u.watch.vec_size);  in xs_process_msg()
652 		msg->u.watch.handle = find_watch(  in xs_process_msg()
653 		    msg->u.watch.vec[XS_WATCH_TOKEN]);  in xs_process_msg()
655 		if (msg->u.watch.handle != NULL &&  in xs_process_msg()
656 		    (!msg->u.watch.handle->max_pending ||  in xs_process_msg()
657 		    msg->u.watch.handle->pending <  in xs_process_msg()
658 		    msg->u.watch.handle->max_pending)) {  in xs_process_msg()
659 			msg->u.watch.handle->pending++;  in xs_process_msg()
665 			free(msg->u.watch.vec, M_XENSTORE);  in xs_process_msg()
984 			msg->u.watch.handle->pending--;  in xenwatch_thread()
995 			if (msg->u.watch.handle->callback != NULL)  in xenwatch_thread()
996 				msg->u.watch.handle->callback(  in xenwatch_thread()
997 					msg->u.watch.handle,  in xenwatch_thread()
998 					(const char **)msg->u.watch.vec,  in xenwatch_thread()
999 					msg->u.watch.vec_size);  in xenwatch_thread()
1000 			free(msg->u.watch.vec, M_XENSTORE);  in xenwatch_thread()
1190 	struct xs_watch *watch;  in xs_resume()  local
1191 	char token[sizeof(watch) * 2 + 1];  in xs_resume()
1203 	LIST_FOREACH(watch, &xs.registered_watches, list) {  in xs_resume()
1204 		sprintf(token, "%lX", (long)watch);  in xs_resume()
1205 		xs_watch(watch->node, token);  in xs_resume()
1573 xs_register_watch(struct xs_watch *watch)  in xs_register_watch()  argument
1576 	char token[sizeof(watch) * 2 + 1];  in xs_register_watch()
1579 	watch->pending = 0;  in xs_register_watch()
1580 	sprintf(token, "%lX", (long)watch);  in xs_register_watch()
1584 	LIST_INSERT_HEAD(&xs.registered_watches, watch, list);  in xs_register_watch()
1587 	error = xs_watch(watch->node, token);  in xs_register_watch()
1595 		LIST_REMOVE(watch, list);  in xs_register_watch()
1603 xs_unregister_watch(struct xs_watch *watch)  in xs_unregister_watch()  argument
1606 	char token[sizeof(watch) * 2 + 1];  in xs_unregister_watch()
1609 	sprintf(token, "%lX", (long)watch);  in xs_unregister_watch()
1616 	LIST_REMOVE(watch, list);  in xs_unregister_watch()
1619 	error = xs_unwatch(watch->node, token);  in xs_unregister_watch()
1622 		    watch->node, error);  in xs_unregister_watch()
1627 		if (msg->u.watch.handle != watch)  in xs_unregister_watch()
1630 		free(msg->u.watch.vec, M_XENSTORE);  in xs_unregister_watch()