| /xen/xen/drivers/char/ |
| A D | consoled.c | 49 XENCONS_RING_IDX cons, prod; in consoled_guest_rx() local
57 prod = ACCESS_ONCE(cons_ring->out_prod); 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()
103 XENCONS_RING_IDX cons, prod; in consoled_guest_tx() local
109 prod = cons_ring->in_prod; in consoled_guest_tx()
117 ASSERT((prod - cons) <= sizeof(cons_ring->in)); in consoled_guest_tx()
120 if ( sizeof(cons_ring->in) - (prod - cons) == 0 ) in consoled_guest_tx()
123 cons_ring->in[MASK_XENCONS_IDX(prod++, cons_ring->in)] = c; in consoled_guest_tx()
[all …]
|
| A D | xen_pv_console.c | 100 XENCONS_RING_IDX cons, prod; in pv_console_rx() local
106 prod = ACCESS_ONCE(cons_ring->in_prod); in pv_console_rx()
115 ASSERT((prod - cons) <= sizeof(cons_ring->in)); in pv_console_rx()
117 while ( cons != prod ) in pv_console_rx()
135 XENCONS_RING_IDX cons, prod; in pv_ring_puts() local
142 prod = cons_ring->out_prod; 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()
164 cons_ring->out[MASK_XENCONS_IDX(prod++, cons_ring->out)] = '\r'; in pv_ring_puts()
169 cons_ring->out[MASK_XENCONS_IDX(prod++, cons_ring->out)] = in pv_ring_puts()
[all …]
|
| /xen/tools/ocaml/libs/xb/ |
| A D | xs_ring_stubs.c | 60 XENSTORE_RING_IDX cons, prod; /* offsets only */ in ml_interface_read() local
65 prod = *(volatile uint32_t*)&intf->req_prod; in ml_interface_read()
73 if ((prod - cons) > XENSTORE_RING_SIZE) in ml_interface_read()
77 total_data = prod - cons; in ml_interface_read()
119 XENSTORE_RING_IDX cons, prod; in ml_interface_write() local
124 prod = *(volatile uint32_t*)&intf->rsp_prod; in ml_interface_write()
132 if ((prod - cons) > XENSTORE_RING_SIZE) in ml_interface_write()
136 total_space = XENSTORE_RING_SIZE - (prod - cons); in ml_interface_write()
147 space = XENSTORE_RING_SIZE - MASK_XENSTORE_IDX(prod); in ml_interface_write()
150 memcpy(intf->rsp + MASK_XENSTORE_IDX(prod), buffer, len); in ml_interface_write()
[all …]
|
| /xen/tools/xentrace/ |
| A D | xentrace.c | 90 unsigned long prod, cons, size; member
143 membuf.prod = membuf.cons = 0; in membuf_alloc()
289 prod = membuf.prod % membuf.size; in membuf_dump()
291 if(prod > cons) in membuf_dump()
295 wsize = prod - cons; in membuf_dump()
316 wsize = prod; in membuf_dump()
327 membuf.cons = membuf.prod = 0; in membuf_dump()
726 prod = meta[i]->prod; in monitor_tbufs()
729 if ( cons == prod ) in monitor_tbufs()
737 if ( prod < cons ) in monitor_tbufs()
[all …]
|
| /xen/xen/common/ |
| A D | trace.c | 113 typeof(dummy_size.prod) max_size; in calculate_tbuf_size()
238 buf->cons = buf->prod = 0; in alloc_trace_bufs()
453 if ( unlikely(prod & 3) || unlikely(prod >= 2 * data_size) || 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()
492 x = data_size - prod; in calc_bytes_to_wrap()
511 u32 x = buf->prod, cons = buf->cons; in next_record()
[all …]
|
| /xen/xen/include/public/io/ |
| A D | ring.h | 436 static inline RING_IDX name##_queued(RING_IDX prod, \
442 if (prod == cons) \
445 prod = name##_mask(prod, ring_size); \
448 if (prod == cons) \
451 if (prod > cons) \
452 size = prod - cons; \
454 size = ring_size - (cons - prod); \
|
| A D | libxenvchan.h | 54 uint32_t cons, prod; member
|
| /xen/tools/xenstore/ |
| A D | xenstored_domain.c | 99 XENSTORE_RING_IDX prod, in get_output_chunk() argument
105 return buf + MASK_XENSTORE_IDX(prod); in get_output_chunk()
109 XENSTORE_RING_IDX prod, in get_input_chunk() argument
113 if ((prod - cons) < *len) in get_input_chunk()
114 *len = prod - cons; in get_input_chunk()
124 XENSTORE_RING_IDX cons, prod; in writechn() local
128 prod = intf->rsp_prod; in writechn()
131 if (!check_indexes(cons, prod)) { in writechn()
154 XENSTORE_RING_IDX cons, prod; in readchn() local
158 prod = intf->req_prod; in readchn()
[all …]
|
| /xen/tools/console/daemon/ |
| A D | io.c | 315 XENCONS_RING_IDX cons, prod, size; in buffer_append() local
319 prod = intf->out_prod; in buffer_append()
322 size = prod - cons; in buffer_append()
335 while (cons != prod) in buffer_append()
988 XENCONS_RING_IDX cons, prod, space; in ring_free_bytes() local
991 prod = intf->in_prod; in ring_free_bytes()
994 space = prod - cons; in ring_free_bytes()
1019 XENCONS_RING_IDX prod; in handle_tty_read() local
1040 prod = intf->in_prod; in handle_tty_read()
1042 intf->in[MASK_XENCONS_IDX(prod++, intf->in)] = in handle_tty_read()
[all …]
|
| /xen/docs/misc/ |
| A D | 9pfs.pandoc | 324 prod cons
331 cons prod
372 - read *cons*, *prod* from shared memory
374 - verify *prod* against local copy (consumer shouldn't change it)
375 - write to array at position *prod* up to *cons*, wrapping around the circular
378 - increase *prod*
384 - read *prod*, *cons* from shared memory
387 - read from array at position *cons* up to *prod*, wrapping around the circular
395 in the buffer up to *prod*.
|
| A D | pvcalls.pandoc | 1004 prod cons
1011 cons prod
1018 static inline PVCALLS_RING_IDX pvcalls_ring_unconsumed(PVCALLS_RING_IDX prod,
1024 if (prod == cons)
1027 prod = _MASK_PVCALLS_IDX(prod, ring_size);
1030 if (prod == cons)
1033 if (prod > cons)
1034 size = prod - cons;
1037 size += prod;
|
| /xen/tools/xenmon/ |
| A D | xenbaked.c | 503 unsigned long start_offset, end_offset, cons, prod; in monitor_tbufs() local
506 prod = meta[i]->prod; in monitor_tbufs()
509 if ( cons == prod ) in monitor_tbufs()
513 end_offset = prod % data_size; in monitor_tbufs()
532 meta[i]->cons = prod; in monitor_tbufs()
|
| /xen/tools/libvchan/ |
| A D | io.c | 54 return ctrl->read.shr->prod; in rd_prod()
65 return &ctrl->write.shr->prod; in _wr_prod()
|
| /xen/xen/include/public/ |
| A D | trace.h | 317 uint32_t prod; /* Offset of next item to be produced by Xen. */ member
|
| /xen/docs/process/ |
| A D | xen-release-management.pandoc | 135 4. Collect and track any issues reported, determine their severity, prod
|