| /xen-4.10.0-shim-comet/tools/xenstore/ |
| A D | xenstored_domain.c | 283 return conn && conn->domain && in domain_is_unprivileged()
354 struct connection *conn = domain->conn; in domain_conn_reset() local
385 if (domain_is_unprivileged(conn) || !conn->can_write) in do_introduce()
453 if (domain_is_unprivileged(conn) || !conn->can_write) in do_set_target()
468 domain->conn->target = tdomain->conn; in do_set_target()
665 if (!conn) in domain_entry_inc()
691 if (!conn) in domain_entry_dec()
703 } else if (conn->domain && conn->domain->nbentry) { in domain_entry_dec()
741 if (!conn || !conn->domain) in domain_watch_inc()
748 if (!conn || !conn->domain) in domain_watch_dec()
[all …]
|
| A D | xenstored_domain.h | 48 const char *get_implicit_path(const struct connection *conn);
54 bool domain_can_read(struct connection *conn);
55 bool domain_can_write(struct connection *conn);
57 bool domain_is_unprivileged(struct connection *conn);
60 void domain_entry_inc(struct connection *conn, struct node *);
63 int domain_entry(struct connection *conn);
64 void domain_watch_inc(struct connection *conn);
65 void domain_watch_dec(struct connection *conn);
66 int domain_watch(struct connection *conn);
92 void wrl_apply_debit_direct(struct connection *conn);
[all …]
|
| A D | xenstored_core.c | 222 ret = conn->write(conn, out->hdr.raw + out->used, in write_messages()
239 ret = conn->write(conn, out->buffer + out->used, in write_messages()
273 talloc_unlink(conn, conn->target); in destroy_conn()
352 conn->pollfd_idx = set_fd(conn->fd, events); in initialize_fds()
479 if (!domain_is_unprivileged(conn) || perms[0].id == conn->id in perm_for_conn()
1338 conn->in->hdr.msg.len, conn); in consider_message()
1340 process_message(conn, conn->in); in consider_message()
1353 conn->in = new_buffer(conn); in handle_input()
1363 bytes = conn->read(conn, in->hdr.raw + in->used, in handle_input()
1389 bytes = conn->read(conn, in->buffer + in->used, in handle_input()
[all …]
|
| A D | xenstored_solaris.c | 80 if (conn->domain) in cred()
83 if (getpeerucred(conn->fd, &ucred) == -1) in cred()
104 return (talloc_strdup(conn, "")); in mangle()
130 char *mangled = mangle(conn, in); in dtrace_io()
131 XENSTORE_MSG(in->hdr.msg.tx_id, conn->id, cred(conn), in dtrace_io()
141 char *mangled = mangle(conn, in); in dtrace_io()
143 cred(conn), mangled); in dtrace_io()
149 char *mangled = mangle(conn, in); in dtrace_io()
150 XENSTORE_WATCH_EVENT(conn->id, cred(conn), mangled); in dtrace_io()
156 char *mangled = mangle(conn, in); in dtrace_io()
[all …]
|
| A D | xenstored_transaction.c | 196 if (!conn || !conn->transaction || in transaction_prepend()
238 if (conn && !conn->transaction) in access_node()
242 if (!conn || !conn->transaction) { in access_node()
249 trans = conn->transaction; in access_node()
434 if (conn->transaction) in do_transaction_start()
437 if (conn->id && conn->transaction_started > quota_max_transaction) in do_transaction_start()
453 exists = transaction_lookup(conn, conn->next_transaction_id++); in do_transaction_start()
458 talloc_steal(conn, trans); in do_transaction_start()
460 conn->transaction_started++; in do_transaction_start()
495 conn->transaction = NULL; in do_transaction_end()
[all …]
|
| A D | xenstored_watch.c | 81 static void add_event(struct connection *conn, in add_event() argument
133 if (conn && conn->transaction) in fire_watches()
169 vec[0] = canonicalize(conn, in, vec[0]); in do_watch()
186 watch = talloc(conn, struct watch); in do_watch()
202 domain_watch_inc(conn); in do_watch()
206 send_ack(conn, XS_WATCH); in do_watch()
209 add_event(conn, in, watch, watch->node); in do_watch()
222 node = canonicalize(conn, in, vec[0]); in do_unwatch()
229 domain_watch_dec(conn); in do_unwatch()
230 send_ack(conn, XS_UNWATCH); in do_unwatch()
[all …]
|
| A D | xenstored_control.c | 35 static int do_control_check(void *ctx, struct connection *conn, in do_control_check() argument
43 send_ack(conn, XS_CONTROL); in do_control_check()
47 static int do_control_log(void *ctx, struct connection *conn, in do_control_log() argument
60 send_ack(conn, XS_CONTROL); in do_control_log()
75 send_ack(conn, XS_CONTROL); in do_control_logfile()
114 send_ack(conn, XS_CONTROL); in do_control_memreport()
126 send_ack(conn, XS_CONTROL); in do_control_print()
141 static int do_control_help(void *ctx, struct connection *conn, in do_control_help() argument
173 send_reply(conn, XS_CONTROL, resp, len); in do_control_help()
183 if (conn->id != 0) in do_control()
[all …]
|
| A D | xenstored_transaction.h | 30 int do_transaction_start(struct connection *conn, struct buffered_data *node);
31 int do_transaction_end(struct connection *conn, struct buffered_data *in);
33 struct transaction *transaction_lookup(struct connection *conn, uint32_t id);
40 int access_node(struct connection *conn, struct node *node,
44 int transaction_prepend(struct connection *conn, const char *name,
47 void conn_delete_all_transactions(struct connection *conn);
|
| A D | xenstored_watch.h | 24 int do_watch(struct connection *conn, struct buffered_data *in);
25 int do_unwatch(struct connection *conn, struct buffered_data *in);
28 void fire_watches(struct connection *conn, void *tmp, const char *name,
31 void conn_delete_all_watches(struct connection *conn);
|
| A D | xenstored_core.h | 144 void send_reply(struct connection *conn, enum xsd_sockmsg_type type,
148 void send_ack(struct connection *conn, enum xsd_sockmsg_type type);
151 char *canonicalize(struct connection *conn, const void *ctx, const char *node);
154 int write_node_raw(struct connection *conn, TDB_DATA *key, struct node *node);
157 struct node *get_node(struct connection *conn,
164 void corrupt(struct connection *conn, const char *fmt, ...);
173 void dtrace_io(const struct connection *conn, const struct buffered_data *data, int out);
|
| A D | xenstored_control.h | 19 int do_control(struct connection *conn, struct buffered_data *in);
|
| /xen-4.10.0-shim-comet/stubdom/ |
| A D | lwip.patch-cvs | 101 + tcp_arg(conn->pcb.tcp, NULL);
103 - tcp_arg(conn->pcb.tcp, NULL);
106 tcp_recv(conn->pcb.tcp, NULL);
111 + tcp_err(conn->pcb.tcp, NULL);
114 err = tcp_close(conn->pcb.tcp);
117 conn->state = NETCONN_NONE;
119 - tcp_err(conn->pcb.tcp, NULL);
123 - tcp_arg(conn->pcb.tcp, NULL);
124 conn->pcb.tcp = NULL;
125 conn->err = ERR_OK;
[all …]
|