| /xen/tools/xenstore/ |
| 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);
63 void domain_entry_inc(struct connection *conn, struct node *);
66 int domain_entry(struct connection *conn);
67 void domain_watch_inc(struct connection *conn);
68 void domain_watch_dec(struct connection *conn);
69 int domain_watch(struct connection *conn);
100 void wrl_apply_debit_direct(struct connection *conn);
[all …]
|
| A D | xenstored_core.h | 64 struct connection;
65 typedef int connwritefn_t(struct connection *, const void *, unsigned int);
66 typedef int connreadfn_t(struct connection *, void *, unsigned int);
68 struct connection struct
104 struct connection *target; argument
149 void send_reply(struct connection *conn, enum xsd_sockmsg_type type,
153 void send_ack(struct connection *conn, enum xsd_sockmsg_type type);
159 enum xs_perm_type perm_for_conn(struct connection *conn,
167 struct node *read_node(struct connection *conn, const void *ctx,
172 void corrupt(struct connection *conn, const char *fmt, ...);
[all …]
|
| A D | xenstored_transaction.h | 32 int do_transaction_start(struct connection *conn, struct buffered_data *node);
33 int do_transaction_end(struct connection *conn, struct buffered_data *in);
35 struct transaction *transaction_lookup(struct connection *conn, uint32_t id);
42 int access_node(struct connection *conn, struct node *node,
46 int transaction_prepend(struct connection *conn, const char *name,
49 void conn_delete_all_transactions(struct connection *conn);
|
| A D | xenstored_control.c | 31 int (*func)(void *, struct connection *, char **, int);
35 static int do_control_check(void *ctx, struct connection *conn, in do_control_check()
47 static int do_control_log(void *ctx, struct connection *conn, in do_control_log()
65 static int do_control_memreport(void *ctx, struct connection *conn, in do_control_memreport()
77 static int do_control_logfile(void *ctx, struct connection *conn, in do_control_logfile()
92 static int do_control_memreport(void *ctx, struct connection *conn, in do_control_memreport()
132 static int do_control_print(void *ctx, struct connection *conn, in do_control_print()
144 static int do_control_help(void *, struct connection *, char **, int);
159 static int do_control_help(void *ctx, struct connection *conn, in do_control_help()
195 int do_control(struct connection *conn, struct buffered_data *in) in do_control()
|
| 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, const void *tmp, const char *name,
31 void conn_delete_all_watches(struct connection *conn);
|
| A D | xenstored_domain.c | 68 struct connection *conn;
118 static int writechn(struct connection *conn, in writechn()
231 struct connection *conn; in domain_cleanup()
283 bool domain_can_read(struct connection *conn) in domain_can_read()
301 bool domain_is_unprivileged(struct connection *conn) in domain_is_unprivileged()
307 bool domain_can_write(struct connection *conn) in domain_can_write()
404 struct connection *conn = domain->conn; in domain_conn_reset()
901 int domain_entry(struct connection *conn) in domain_entry()
908 void domain_watch_inc(struct connection *conn) in domain_watch_inc()
915 void domain_watch_dec(struct connection *conn) in domain_watch_dec()
[all …]
|
| A D | xenstored_core.c | 139 static void trace_io(const struct connection *conn, in trace_io()
211 static bool write_messages(struct connection *conn) in write_messages()
262 struct connection *conn = _conn; in destroy_conn()
320 struct connection *conn; in initialize_fds()
1120 static void delete_child(struct connection *conn, in delete_child()
1437 static void handle_input(struct connection *conn) in handle_input()
1496 static void handle_output(struct connection *conn) in handle_output()
1505 struct connection *new; in new_connection()
1574 struct connection *conn; in accept_connection()
1981 extern void dump_conn(struct connection *conn);
[all …]
|
| A D | xenstored_watch.c | 79 static void add_event(struct connection *conn, in add_event()
114 static bool watch_permitted(struct connection *conn, const void *ctx, in watch_permitted()
160 void fire_watches(struct connection *conn, const void *ctx, const char *name, in fire_watches()
163 struct connection *i; in fire_watches()
199 int do_watch(struct connection *conn, struct buffered_data *in) in do_watch()
260 int do_unwatch(struct connection *conn, struct buffered_data *in) in do_unwatch()
283 void conn_delete_all_watches(struct connection *conn) in conn_delete_all_watches()
|
| A D | xenstored_transaction.c | 199 int transaction_prepend(struct connection *conn, const char *name, in transaction_prepend()
234 int access_node(struct connection *conn, struct node *node, in access_node()
339 static int finalize_transaction(struct connection *conn, in finalize_transaction()
436 struct transaction *transaction_lookup(struct connection *conn, uint32_t id) in transaction_lookup()
450 int do_transaction_start(struct connection *conn, struct buffered_data *in) in do_transaction_start()
505 int do_transaction_end(struct connection *conn, struct buffered_data *in) in do_transaction_end()
585 void conn_delete_all_transactions(struct connection *conn) in conn_delete_all_transactions()
602 struct connection *conn; in check_transactions()
|
| A D | xenstored_solaris.c | 75 static pid_t cred(const struct connection *conn) in cred()
98 mangle(const struct connection *conn, const struct buffered_data *in) in mangle()
125 dtrace_io(const struct connection *conn, const struct buffered_data *in, in dtrace_io()
|
| A D | xenstored_control.h | 19 int do_control(struct connection *conn, struct buffered_data *in);
|
| /xen/tools/ocaml/xenstored/ |
| A D | perms.ml | 119 let get_owners (connection:t) =
120 match connection.main, connection.target with
124 let is_owner (connection:t) id =
125 match connection.target with
129 let is_dom0 (connection:t) =
130 is_owner connection 0
135 let to_string connection =
136 …Printf.sprintf "%s%s" (elt_to_string connection.main) (default "" (may elt_to_string connection.ta…
174 let check connection request node =
175 if lacks connection request node
[all …]
|
| A D | store.ml | 78 (* check if the current node can be accessed by the current connection with rperm permissions *)
79 let check_perm node connection request =
80 Perms.check connection request node.perms
82 (* check if the current node is owned by the current connection *)
83 let check_owner node connection =
84 if not (Perms.check_owner connection node.perms)
|
| /xen/tools/ocaml/libs/xb/ |
| A D | xs_ring_stubs.c | 62 uint32_t connection; in ml_interface_read() local
66 connection = *(volatile uint32_t*)&intf->connection; in ml_interface_read()
68 if (connection != XENSTORE_CONNECTED) in ml_interface_read()
121 uint32_t connection; in ml_interface_write() local
125 connection = *(volatile uint32_t*)&intf->connection; in ml_interface_write()
127 if (connection != XENSTORE_CONNECTED) in ml_interface_write()
196 intf->connection = XENSTORE_CONNECTED; in ml_interface_close()
|
| A D | partial.ml | 36 This will leave the guest connection is a bad state and will
37 be hard to recover from without restarting the connection
|
| /xen/tools/ocaml/libs/xs/ |
| A D | xs.mli | 54 connection *)
61 (** watch manipulation on a connection *)
66 (** get_fd return the fd of the connection to be able to select on it.
67 NOTE: it works only for socket-based connection *)
72 NOTE: it works only when use with a socket-based connection *)
83 (** open a socket-based xenstored connection *)
86 (** open a mmap-based xenstored connection *)
89 (** close any xenstored connection *)
|
| /xen/docs/designs/ |
| A D | xenstore-migration.md | 143 each connection to xenstore. For migration it will only contain a record for
165 | | connection in subsequent connection-specific |
178 | | from the connection not yet processed |
181 | | not yet written to the connection |
184 | | not yet written to the connection, including |
191 In case of live update the connection record for the connection via which
239 This type of connection is only relevant for live update, where the xenstored
241 the file descriptor of the socket connection.
267 | `conn-id` | The connection that issued the `WATCH` |
287 that is pending on a connection for which there is `CONNECTION_DATA` record
[all …]
|
| /xen/docs/misc/ |
| A D | console.txt | 42 * 'connection' information describing to what they should be
58 The toolstack writes 'connection' information in the xenstore backend in
60 * connection: either 'pty' or 'socket'
61 * path: only present if connection = 'socket', the path of the socket to
71 connection = pty
86 <path>, a connection accepted and data proxied to the console, it will write:
88 connection = socket
140 console connection between the stubdom and dom0 to export the serial
147 need another pv console connection for each console backend to export
|
| A D | xenstore-ring.txt | 107 - discard any watches associated with the connection
108 - discard any transactions associated with the connection
112 From the point of view of the guest, the connection has been reset on a
|
| A D | crashdb.txt | 18 if you have a simple null modem connection between the test box and
34 (XEN) GDB connection activated.
|
| /xen/tools/libxl/ |
| A D | libxl_console.c | 302 if (console->connection) { in libxl__device_console_add()
304 flexarray_append(back, console->connection); in libxl__device_console_add()
426 switch (channel->connection) { in libxl__init_console_from_channel()
432 console->connection = libxl__strdup(NOGC, "pty"); in libxl__init_console_from_channel()
440 console->connection = libxl__strdup(NOGC, "socket"); in libxl__init_console_from_channel()
448 __func__, channel->connection); in libxl__init_console_from_channel()
477 channel->connection = LIBXL_CHANNEL_CONNECTION_PTY; in libxl__device_channel_from_xenstore()
479 channel->connection = LIBXL_CHANNEL_CONNECTION_SOCKET; in libxl__device_channel_from_xenstore()
605 channelinfo->connection = channel->connection; in libxl_device_channel_getinfo()
606 switch (channel->connection) { in libxl_device_channel_getinfo()
|
| A D | libxl_types_internal.idl | 50 ("connection", string),
|
| /xen/tools/xl/ |
| A D | xl_console.c | 109 channels[i].connection)); in main_channellist()
110 switch (channels[i].connection) { in main_channellist()
|
| /xen/tools/firmware/hvmloader/ |
| A D | xenbus.c | 81 rings->connection = XENSTORE_RECONNECT; in xenbus_shutdown()
84 while (*(volatile uint32_t*)&rings->connection == XENSTORE_RECONNECT) in xenbus_shutdown()
|
| /xen/xen/include/public/io/ |
| A D | xs_wire.h | 126 uint32_t connection; member
|