Home
last modified time | relevance | path

Searched refs:conn (Results 1 – 15 of 15) sorted by relevance

/tools/xenstored/
A Ddomain.h70 int do_resume(const void *ctx, struct connection *conn,
117 unsigned int domain_nbentry(struct connection *conn);
129 return domain_memory_add(conn, domid, mem, false); in domain_memory_add_chk()
140 domain_memory_add(conn, domid, mem, true); in domain_memory_add_nochk()
142 void domain_watch_inc(struct connection *conn);
143 void domain_watch_dec(struct connection *conn);
144 int domain_watch(struct connection *conn);
145 void domain_outstanding_inc(struct connection *conn);
147 void domain_transaction_inc(struct connection *conn);
158 void acc_drop(struct connection *conn);
[all …]
A Dcore.c214 domain_memory_add_nochk(conn, conn->id, in free_buffered_data()
239 domain_outstanding_dec(conn, conn->id); in free_buffered_data()
440 if (!conn->funcs->can_read(conn)) in conn_can_read()
455 return !conn->is_ignored && conn->funcs->can_write(conn); in conn_can_write()
874 if (ret && conn && conn->transaction) { in write_node()
1092 domain_memory_add_nochk(conn, conn->id, in send_reply()
1097 domain_memory_add_chk(conn, conn->id, in send_reply()
1526 if (conn && conn->transaction) in create_node()
2133 conn, conn->in->hdr.msg.req_id); in consider_message()
2143 process_message(conn, conn->in); in consider_message()
[all …]
A Dwatch.c129 if (conn && conn->transaction) { in fire_watches()
134 req = domain_is_unprivileged(conn) ? conn->in : NULL; in fire_watches()
185 if (domain_memory_add(conn, conn->id, strlen(path) + strlen(token), in add_watch()
191 domain_watch_inc(conn); in add_watch()
231 send_ack(conn, XS_WATCH); in do_watch()
259 domain_memory_add_nochk(conn, conn->id, in do_unwatch()
263 domain_watch_dec(conn); in do_unwatch()
277 domain_memory_add_nochk(conn, conn->id, -strlen(watch->node) - in conn_delete_all_watches()
280 domain_watch_dec(conn); in conn_delete_all_watches()
325 struct connection *conn; in read_state_watch() local
[all …]
A Dtransaction.c146 struct connection *conn; member
203 if (conn && conn->transaction) { in transaction_prepend()
236 if (conn && !conn->transaction) in access_node()
240 if (!conn || !conn->transaction) { in access_node()
247 trans = conn->transaction; in access_node()
470 if (conn->transaction) in do_transaction_start()
484 trans->conn = conn; in do_transaction_start()
491 exists = transaction_lookup(conn, conn->next_transaction_id++); in do_transaction_start()
525 conn->transaction = NULL; in do_transaction_end()
582 conn->ta_start_time = 0; in conn_delete_all_transactions()
[all …]
A Ddomain.c368 if (!conn) in wrl_apply_debit_direct()
653 conn = domain->conn; in do_check_domain()
977 struct connection *conn = domain->conn; in domain_conn_reset() local
1001 if (conn->domain && conn->domain->interface && in ignore_connection()
1139 domain->conn->target = tdomain->conn; in do_set_target()
1609 if (conn && domid == conn->id && conn->domain) in domain_acc_add()
1627 if (conn && conn->in && what < ACC_REQ_N) { in domain_acc_add()
1720 if (!conn || !conn->domain) in domain_max_chk()
1765 if (!conn || !conn->domain || !domid_is_unprivileged(conn->id) || in domain_chk_quota()
1957 conn = domain->conn; in read_state_connection()
[all …]
A Dcontrol.c57 send_ack(conn, XS_CONTROL); in do_control_check()
99 send_ack(conn, XS_CONTROL); in do_control_log()
144 send_ack(conn, XS_CONTROL); in quota_set()
158 return domain_get_quota(ctx, conn, atoi(vec[0])); in quota_get()
174 return domain_max_global_acc(ctx, conn); in quota_max()
187 return quota_max(ctx, conn, vec + 1, num - 1); in do_control_quota()
189 return quota_get(ctx, conn, vec, num); in do_control_quota()
215 send_ack(conn, XS_CONTROL); in do_control_logfile()
259 send_ack(conn, XS_CONTROL); in do_control_memreport()
271 send_ack(conn, XS_CONTROL); in do_control_print()
[all …]
A Dlu.c52 lu_status->conn = conn; in lu_begin()
232 if (!lu_status || lu_status->conn != conn) in lu_cmdline()
244 struct connection *conn; in lu_check_lu_allowed() local
269 struct connection *conn; in lu_reject_reason() local
411 assert(lu_status->conn == conn); in do_lu_start()
436 saved_in = conn->in; in do_lu_start()
437 conn->in = req->in; in do_lu_start()
439 conn->in = saved_in; in do_lu_start()
450 if (!lu_status || lu_status->conn != conn) in lu_start()
465 lu_status->in = conn->in; in lu_start()
[all …]
A Dposix.c243 if (conn->pollfd_idx == -1) in socket_can_process()
247 talloc_free(conn); in socket_can_process()
274 struct connection *conn; in accept_connection() local
280 conn = new_connection(&socket_funcs); in accept_connection()
281 if (conn) { in accept_connection()
282 conn->fd = fd; in accept_connection()
283 conn->id = store_domid; in accept_connection()
329 struct connection *conn; in add_socket_connection() local
332 if (!conn) in add_socket_connection()
334 conn->fd = fd; in add_socket_connection()
[all …]
A Dcore.h255 unsigned int perm_for_conn(struct connection *conn,
279 return perm_for_conn(conn, &perms); in perm_for_conn_from_node()
296 int write_node_raw(struct connection *conn, const char *db_name,
301 struct node *read_node(struct connection *conn, const void *ctx,
314 void corrupt(struct connection *conn, const char *fmt, ...);
392 return conn && domid_is_unprivileged(conn->id); in domain_is_unprivileged()
431 void db_delete(struct connection *conn, const char *name,
434 void conn_free_buffered_data(struct connection *conn);
476 int (*enter)(const void *ctx, struct connection *conn,
478 int (*exit)(const void *ctx, struct connection *conn,
[all …]
A Dtransaction.h32 int do_transaction_start(const void *ctx, struct connection *conn,
34 int do_transaction_end(const void *ctx, struct connection *conn,
37 struct transaction *transaction_lookup(struct connection *conn, uint32_t id);
43 int __must_check access_node(struct connection *conn, struct node *node,
47 void queue_watches(struct connection *conn, const char *name, bool watch_exact);
50 const char *transaction_prepend(struct connection *conn, const char *name);
58 void conn_delete_all_transactions(struct connection *conn);
A Dlu_minios.c51 static const char *lu_binary_alloc(const void *ctx, struct connection *conn, in lu_binary_alloc() argument
58 ret = lu_begin(conn); in lu_binary_alloc()
73 static const char *lu_binary_save(const void *ctx, struct connection *conn, in lu_binary_save() argument
76 if (!lu_status || lu_status->conn != conn) in lu_binary_save()
89 const char *lu_arch(const void *ctx, struct connection *conn, const char **vec, in lu_arch() argument
93 return lu_binary_alloc(ctx, conn, atol(vec[1])); in lu_arch()
95 return lu_binary_save(ctx, conn, atoi(vec[1]), vec[2]); in lu_arch()
A Dwatch.h24 int do_watch(const void *ctx, struct connection *conn,
26 int do_unwatch(const void *ctx, struct connection *conn,
30 void fire_watches(struct connection *conn, const void *tmp, const char *name,
34 void conn_delete_all_watches(struct connection *conn);
36 const char *dump_state_watches(FILE *fp, struct connection *conn,
A Dlu.h10 struct connection *conn; member
42 int do_control_lu(const void *ctx, struct connection *conn, const char **vec,
47 const char *lu_arch(const void *ctx, struct connection *conn, const char **vec,
49 const char *lu_begin(struct connection *conn);
A Dlu_daemon.c25 static const char *lu_binary(const void *ctx, struct connection *conn, in lu_binary() argument
38 ret = lu_begin(conn); in lu_binary()
50 const char *lu_arch(const void *ctx, struct connection *conn, const char **vec, in lu_arch() argument
54 return lu_binary(ctx, conn, vec[1]); in lu_arch()
A Dcontrol.h19 int do_control(const void *ctx, struct connection *conn,

Completed in 37 milliseconds