225 	struct xenbus_watch watch;  member
230 static void free_watch_adapter(struct watch_adapter *watch)  in free_watch_adapter()  argument
232 	kfree(watch->watch.node);  in free_watch_adapter()
233 	kfree(watch->token);  in free_watch_adapter()
234 	kfree(watch);  in free_watch_adapter()
240 	struct watch_adapter *watch;  in alloc_watch_adapter()  local
242 	watch = kzalloc(sizeof(*watch), GFP_KERNEL);  in alloc_watch_adapter()
243 	if (watch == NULL)  in alloc_watch_adapter()
246 	watch->watch.node = kstrdup(path, GFP_KERNEL);  in alloc_watch_adapter()
247 	if (watch->watch.node == NULL)  in alloc_watch_adapter()
250 	watch->token = kstrdup(token, GFP_KERNEL);  in alloc_watch_adapter()
251 	if (watch->token == NULL)  in alloc_watch_adapter()
254 	return watch;  in alloc_watch_adapter()
257 	free_watch_adapter(watch);  in alloc_watch_adapter()
263 static void watch_fired(struct xenbus_watch *watch,  in watch_fired()  argument
274 	adap = container_of(watch, struct watch_adapter, watch);  in watch_fired()
307 	struct watch_adapter *watch, *tmp_watch;  in xenbus_worker()  local
323 	list_for_each_entry_safe(watch, tmp_watch, &u->watches, list) {  in xenbus_worker()
324 		unregister_xenbus_watch(&watch->watch);  in xenbus_worker()
325 		list_del(&watch->list);  in xenbus_worker()
326 		free_watch_adapter(watch);  in xenbus_worker()
472 	struct watch_adapter *watch;  in xenbus_write_watch()  local
490 		watch = alloc_watch_adapter(path, token);  in xenbus_write_watch()
491 		if (watch == NULL) {  in xenbus_write_watch()
496 		watch->watch.callback = watch_fired;  in xenbus_write_watch()
497 		watch->dev_data = u;  in xenbus_write_watch()
499 		err = register_xenbus_watch(&watch->watch);  in xenbus_write_watch()
501 			free_watch_adapter(watch);  in xenbus_write_watch()
505 		list_add(&watch->list, &u->watches);  in xenbus_write_watch()
507 		list_for_each_entry(watch, &u->watches, list) {  in xenbus_write_watch()
508 			if (!strcmp(watch->token, token) &&  in xenbus_write_watch()
509 			    !strcmp(watch->watch.node, path)) {  in xenbus_write_watch()
510 				unregister_xenbus_watch(&watch->watch);  in xenbus_write_watch()
511 				list_del(&watch->list);  in xenbus_write_watch()
512 				free_watch_adapter(watch);  in xenbus_write_watch()