Home
last modified time | relevance | path

Searched refs:cons (Results 1 – 20 of 20) sorted by relevance

/xen/tools/ocaml/xenstored/
A Dconnections.ml56 let find cons =
73 cons.watches <- Trie.map (del_watches_of_con con) cons.watches;
100 iter_domains cons fct; iter_anonymous cons fct
106 cons.domains []
124 cons.watches <- Trie.set cons.watches key (watch :: watches);
132 cons.watches <- Trie.unset cons.watches key
134 cons.watches <- Trie.set cons.watches key watches;
139 cons.watches <- Trie.map (del_watches_of_con con) cons.watches
172 iter cons aux;
175 let stats cons =
[all …]
A Dxenstored.ml30 fct store cons domains c
33 Connections.del_anonymous cons c;
37 Connections.del_anonymous cons c;
42 Connections.del_anonymous cons c;
54 let process_domains store cons domains =
190 Connections.add_domain cons ndom;
202 let from_file store cons doms file =
207 let to_channel store cons chan =
226 let to_file store cons file =
287 let cons = Connections.create () in
[all …]
A Dprocess.ml59 let process_watch t cons =
63 let do_op_watch op cons =
88 let do_debug con t _domains cons data =
183 Connections.del_watches cons con;
207 fct con t doms cons data;
210 process_watch t cons
218 match fct con t doms cons data with
224 fct con t doms cons data
399 process_watch t cons;
445 Connections.del_domain cons domid;
[all …]
/xen/xen/drivers/char/
A Dconsoled.c49 XENCONS_RING_IDX cons, prod; in consoled_guest_rx() local
56 cons = cons_ring->out_cons; in consoled_guest_rx()
65 ASSERT((prod - cons) <= sizeof(cons_ring->out)); in consoled_guest_rx()
68 if ( cons == prod ) in consoled_guest_rx()
71 while ( cons != prod ) in consoled_guest_rx()
73 char c = cons_ring->out[MASK_XENCONS_IDX(cons++, cons_ring->out)]; in consoled_guest_rx()
90 ACCESS_ONCE(cons_ring->out_cons) = cons; in consoled_guest_rx()
103 XENCONS_RING_IDX cons, prod; in consoled_guest_tx() local
108 cons = ACCESS_ONCE(cons_ring->in_cons); in consoled_guest_tx()
117 ASSERT((prod - cons) <= sizeof(cons_ring->in)); in consoled_guest_tx()
[all …]
A Dxen_pv_console.c100 XENCONS_RING_IDX cons, prod; in pv_console_rx() local
107 cons = cons_ring->in_cons; in pv_console_rx()
115 ASSERT((prod - cons) <= sizeof(cons_ring->in)); in pv_console_rx()
117 while ( cons != prod ) in pv_console_rx()
119 c = cons_ring->in[MASK_XENCONS_IDX(cons++, cons_ring->in)]; in pv_console_rx()
127 ACCESS_ONCE(cons_ring->in_cons) = cons; in pv_console_rx()
135 XENCONS_RING_IDX cons, prod; in pv_ring_puts() local
141 cons = ACCESS_ONCE(cons_ring->out_cons); in pv_ring_puts()
150 ASSERT((prod - cons) <= sizeof(cons_ring->out)); in pv_ring_puts()
151 avail = sizeof(cons_ring->out) - (prod - cons); in pv_ring_puts()
/xen/tools/ocaml/libs/xb/
A Dxs_ring_stubs.c60 XENSTORE_RING_IDX cons, prod; /* offsets only */ in ml_interface_read() local
64 cons = *(volatile uint32_t*)&intf->req_cons; in ml_interface_read()
73 if ((prod - cons) > XENSTORE_RING_SIZE) in ml_interface_read()
77 total_data = prod - cons; in ml_interface_read()
88 data = XENSTORE_RING_SIZE - MASK_XENSTORE_IDX(cons); in ml_interface_read()
91 memcpy(buffer, intf->req + MASK_XENSTORE_IDX(cons), len); in ml_interface_read()
94 memcpy(buffer, intf->req + MASK_XENSTORE_IDX(cons), data); in ml_interface_read()
119 XENSTORE_RING_IDX cons, prod; in ml_interface_write() local
123 cons = *(volatile uint32_t*)&intf->rsp_cons; in ml_interface_write()
132 if ((prod - cons) > XENSTORE_RING_SIZE) in ml_interface_write()
[all …]
/xen/tools/xentrace/
A Dxentrace.c90 unsigned long prod, cons, size; member
143 membuf.prod = membuf.cons = 0; in membuf_alloc()
283 int cons, prod, wsize, written; in membuf_dump() local
288 cons = membuf.cons % membuf.size; in membuf_dump()
291 if(prod > cons) in membuf_dump()
295 wsize = prod - cons; in membuf_dump()
327 membuf.cons = membuf.prod = 0; in membuf_dump()
725 cons = meta[i]->cons; in monitor_tbufs()
729 if ( cons == prod ) in monitor_tbufs()
737 if ( prod < cons ) in monitor_tbufs()
[all …]
/xen/xen/common/
A Dtrace.c238 buf->cons = buf->prod = 0; in alloc_trace_bufs()
451 static inline bool_t bogus(u32 prod, u32 cons) in bogus() argument
454 unlikely(cons & 3) || unlikely(cons >= 2 * data_size) ) in bogus()
458 smp_processor_id(), prod, cons); in bogus()
466 u32 prod = buf->prod, cons = buf->cons; in calc_unconsumed_bytes() local
470 if ( bogus(prod, cons) ) in calc_unconsumed_bytes()
473 x = prod - cons; in calc_unconsumed_bytes()
485 u32 prod = buf->prod, cons = buf->cons; in calc_bytes_to_wrap() local
489 if ( bogus(prod, cons) ) in calc_bytes_to_wrap()
511 u32 x = buf->prod, cons = buf->cons; in next_record() local
[all …]
/xen/xen/include/public/io/
A Dring.h437 RING_IDX cons, \
442 if (prod == cons) \
446 cons = name##_mask(cons, ring_size); \
448 if (prod == cons) \
451 if (prod > cons) \
452 size = prod - cons; \
454 size = ring_size - (cons - prod); \
A Dlibxenvchan.h54 uint32_t cons, prod; member
/xen/tools/xenstore/
A Dxenstored_domain.c95 return ((prod - cons) <= XENSTORE_RING_SIZE); in check_indexes()
104 *len = XENSTORE_RING_SIZE - (prod - cons); in get_output_chunk()
113 if ((prod - cons) < *len) in get_input_chunk()
114 *len = prod - cons; in get_input_chunk()
115 return buf + MASK_XENSTORE_IDX(cons); in get_input_chunk()
124 XENSTORE_RING_IDX cons, prod; in writechn() local
127 cons = intf->rsp_cons; in writechn()
131 if (!check_indexes(cons, prod)) { in writechn()
154 XENSTORE_RING_IDX cons, prod; in readchn() local
157 cons = intf->req_cons; in readchn()
[all …]
/xen/docs/misc/
A D9pfs.pandoc324 prod cons
331 cons prod
372 - read *cons*, *prod* from shared memory
375 - write to array at position *prod* up to *cons*, wrapping around the circular
384 - read *prod*, *cons* from shared memory
386 - verify *cons* against local copy (producer shouldn't change it)
387 - read from array at position *cons* up to *prod*, wrapping around the circular
390 - increase *cons*
394 up to *cons*. The consumer takes care of reading only as many bytes as available
A Dpvcalls.pandoc1004 prod cons
1011 cons prod
1019 PVCALLS_RING_IDX cons,
1024 if (prod == cons)
1028 cons = _MASK_PVCALLS_IDX(cons, ring_size);
1030 if (prod == cons)
1033 if (prod > cons)
1034 size = prod - cons;
1036 size = ring_size - cons;
A Dxsm-flask.txt185 constraints file (for example, vm_rule.cons). The vm_role module defines one
/xen/tools/console/daemon/
A Dio.c315 XENCONS_RING_IDX cons, prod, size; in buffer_append() local
318 cons = intf->out_cons; in buffer_append()
322 size = prod - cons; in buffer_append()
335 while (cons != prod) in buffer_append()
337 MASK_XENCONS_IDX(cons++, intf->out)]; in buffer_append()
340 intf->out_cons = cons; in buffer_append()
988 XENCONS_RING_IDX cons, prod, space; in ring_free_bytes() local
990 cons = intf->in_cons; in ring_free_bytes()
994 space = prod - cons; in ring_free_bytes()
/xen/tools/ocaml/libs/xl/
A Dxenlight_stubs.c172 CAMLlocal5(list, cons, key, val, kv); in Val_key_value_list()
183 cons = caml_alloc(2, 0); in Val_key_value_list()
184 Store_field(cons, 0, kv); // head in Val_key_value_list()
185 Store_field(cons, 1, list); // tail in Val_key_value_list()
186 list = cons; in Val_key_value_list()
214 CAMLlocal3(list, cons, string); in Val_string_list()
220 cons = caml_alloc(2, 0); in Val_string_list()
221 Store_field(cons, 0, string); // head in Val_string_list()
222 Store_field(cons, 1, list); // tail in Val_string_list()
223 list = cons; in Val_string_list()
/xen/tools/xenmon/
A Dxenbaked.c503 unsigned long start_offset, end_offset, cons, prod; in monitor_tbufs() local
505 cons = meta[i]->cons; in monitor_tbufs()
509 if ( cons == prod ) in monitor_tbufs()
512 start_offset = cons % data_size; in monitor_tbufs()
532 meta[i]->cons = prod; in monitor_tbufs()
/xen/tools/libvchan/
A Dio.c59 return &ctrl->read.shr->cons; in _rd_cons()
71 return ctrl->write.shr->cons; in wr_cons()
/xen/tools/flask/policy/
A DMakefile.common103 ALL_CONSTRAINTS := $(wildcard $(ALL_MODULES:.te=.cons))
/xen/xen/include/public/
A Dtrace.h316 uint32_t cons; /* Offset of next item to be consumed by control tools. */ member

Completed in 30 milliseconds