Lines Matching refs:conn
81 static void add_event(struct connection *conn, in add_event() argument
92 struct node *node = get_node(conn, ctx, name, XS_PERM_READ); in add_event()
118 send_reply(conn, XS_WATCH_EVENT, data, len); in add_event()
126 void fire_watches(struct connection *conn, void *ctx, const char *name, in fire_watches() argument
133 if (conn && conn->transaction) in fire_watches()
153 int do_watch(struct connection *conn, struct buffered_data *in) in do_watch() argument
169 vec[0] = canonicalize(conn, in, vec[0]); in do_watch()
177 list_for_each_entry(watch, &conn->watches, list) { in do_watch()
183 if (domain_watch(conn) > quota_nb_watch_per_domain) in do_watch()
186 watch = talloc(conn, struct watch); in do_watch()
196 watch->relative_path = get_implicit_path(conn); in do_watch()
202 domain_watch_inc(conn); in do_watch()
203 list_add_tail(&watch->list, &conn->watches); in do_watch()
206 send_ack(conn, XS_WATCH); in do_watch()
209 add_event(conn, in, watch, watch->node); in do_watch()
214 int do_unwatch(struct connection *conn, struct buffered_data *in) in do_unwatch() argument
222 node = canonicalize(conn, in, vec[0]); in do_unwatch()
225 list_for_each_entry(watch, &conn->watches, list) { in do_unwatch()
229 domain_watch_dec(conn); in do_unwatch()
230 send_ack(conn, XS_UNWATCH); in do_unwatch()
237 void conn_delete_all_watches(struct connection *conn) in conn_delete_all_watches() argument
241 while ((watch = list_top(&conn->watches, struct watch, list))) { in conn_delete_all_watches()
244 domain_watch_dec(conn); in conn_delete_all_watches()