| /xen-4.10.0-shim-comet/tools/blktap2/drivers/ |
| A D | tapdisk-queue.c | 65 queue->iocbs[queue->queued - 1]->data; in queue_tiocb()
69 queue->iocbs[queue->queued++] = iocb; in queue_tiocb()
237 tapdisk_filter_iocbs(queue->filter, queue->iocbs, queue->queued); in tapdisk_rwio_submit()
238 merged = io_merge(&queue->opioctx, queue->iocbs, queue->queued); in tapdisk_rwio_submit()
517 tapdisk_filter_iocbs(queue->filter, queue->iocbs, queue->queued); in tapdisk_lio_submit()
518 merged = io_merge(&queue->opioctx, queue->iocbs, queue->queued); in tapdisk_lio_submit()
532 queue->tiocbs_pending += queue->queued; in tapdisk_lio_submit()
555 queue->tio->tio_destroy(queue); in tapdisk_queue_free_io()
661 queue->size, queue->tio->name, queue->queued, queue->iocbs_pending, in tapdisk_debug_queue()
662 queue->tiocbs_pending, queue->tiocbs_deferred, queue->deferrals); in tapdisk_debug_queue()
[all …]
|
| A D | tapdisk-queue.h | 91 int (*tio_setup) (struct tqueue *queue, int qlen);
92 void (*tio_destroy) (struct tqueue *queue);
93 int (*tio_submit) (struct tqueue *queue);
|
| A D | io-optimize.c | 218 io_merge(struct opioctx *ctx, struct iocb **queue, int num) in io_merge() argument
229 memcpy(q, queue, num * sizeof(struct iocb *)); in io_merge()
233 if (merge(ctx, queue[on_queue], io) != 0) in io_merge()
234 queue[++on_queue] = io; in io_merge()
238 print_merged_iocbs(ctx, queue, on_queue + 1); in io_merge()
255 queue[idx++] = op->iocb; in expand_iocb()
274 memcpy(q, queue, num * sizeof(struct iocb *)); in io_expand_iocbs()
279 queue[on_queue++] = io; in io_expand_iocbs()
281 on_queue += expand_iocb(ctx, queue + on_queue, io); in io_expand_iocbs()
289 struct io_event *event, struct io_event *queue, int idx) in expand_event() argument
[all …]
|
| A D | io-optimize.h | 64 int io_merge(struct opioctx *ctx, struct iocb **queue, int num);
66 int io_expand_iocbs(struct opioctx *ctx, struct iocb **queue, int idx, int num);
|
| A D | block-vhd.c | 210 struct vhd_req_list queue; /* data writes waiting for next member
964 clear_req_list(&bm->queue); in init_vhd_bitmap()
1016 bm->waiting.head || bm->tx.requests.head || bm->queue.head); in bitmap_in_use()
1538 add_to_tail(&bm->queue, req); in schedule_data_write()
1867 if (!bm->queue.head) in start_new_bitmap_transaction()
1872 r = bm->queue.head; in start_new_bitmap_transaction()
1874 clear_req_list(&bm->queue); in start_new_bitmap_transaction()
2275 r = bm->queue.head; in vhd_debug()
2296 i, bm->blk, bm->status, bm->queue.head, qnum, bm->waiting.head, in vhd_debug()
|
| A D | Makefile | 59 TAP-OBJS-y += tapdisk-queue.o
|
| /xen-4.10.0-shim-comet/tools/ocaml/libs/xs/ |
| A D | queueop.ml | 21 Xb.queue con (Xb.Packet.create tid 0 ty data)
30 Xb.queue con (Xb.Packet.create 0 0 Xb.Op.Debug (data_concat commands))
34 Xb.queue con (Xb.Packet.create 0 0 Xb.Op.Watch data)
38 Xb.queue con (Xb.Packet.create 0 0 Xb.Op.Unwatch data)
45 Xb.queue con (Xb.Packet.create tid 0 Xb.Op.Transaction_end data)
51 Xb.queue con (Xb.Packet.create 0 0 Xb.Op.Introduce data)
55 Xb.queue con (Xb.Packet.create 0 0 Xb.Op.Release data)
59 Xb.queue con (Xb.Packet.create 0 0 Xb.Op.Resume data)
63 Xb.queue con (Xb.Packet.create 0 0 Xb.Op.Getdomainpath data)
67 Xb.queue con (Xb.Packet.create tid 0 Xb.Op.Write data)
[all …]
|
| A D | xs.ml | 89 (* Returns true if a watch event in the queue satisfied us *)
112 we must process the queue on every loop iteration *)
|
| A D | xsraw.ml | 137 (* send one packet in the queue, and wait for reply *)
154 (* queue a query using function f *)
|
| /xen-4.10.0-shim-comet/tools/include/xen-external/ |
| A D | README | 8 bsd-sys-queue.h
9 bsd-queue.3
22 bsd-sys-queue-h-seddery
|
| /xen-4.10.0-shim-comet/tools/ocaml/xenstored/ |
| A D | domains.ml | 26 (* Domains queue up to regain conflict-credit; we have a queue for
28 maximum credit, and another queue for domains that have run out of
70 * from max-credit to paused without getting into the penalty queue. *)
76 let push dom queue =
77 Queue.push (ref (Some dom)) queue
79 let rec pop queue =
80 match !(Queue.pop queue) with
81 | None -> pop queue
84 let remove_from_queue dom queue =
87 | Some x -> if x=dom then d := None) queue
[all …]
|
| A D | oxenstored.conf.in | 29 # one at the front of the queue. If false, then after each tick each
|
| A D | connection.ml | 134 Xenbus.Xb.queue con.xb (Xenbus.Xb.Packet.create tid rid Xenbus.Xb.Op.Error "E2BIG\000")
136 Xenbus.Xb.queue con.xb (Xenbus.Xb.Packet.create tid rid ty data)
|
| /xen-4.10.0-shim-comet/xen/common/ |
| A D | event_fifo.c | 69 old_q = &v->evtchn_fifo->queue[evtchn->last_priority]; in lock_old_queue()
74 q = &v->evtchn_fifo->queue[evtchn->last_priority]; in lock_old_queue()
202 q = &v->evtchn_fifo->queue[evtchn->priority]; in evtchn_fifo_set_pending()
415 init_queue(v, &efv->queue[i], i); in setup_control_block()
438 v->evtchn_fifo->queue[i].head = &v->evtchn_fifo->control_block->head[i]; in map_control_block()
|
| A D | sched_rt.c | 497 deadline_queue_remove(struct list_head *queue, struct list_head *elem) in deadline_queue_remove() argument
501 if ( queue->next != elem ) in deadline_queue_remove()
511 struct list_head *queue) in deadline_queue_insert() argument
516 list_for_each ( iter, queue ) in deadline_queue_insert()
|
| /xen-4.10.0-shim-comet/xen/include/xen/ |
| A D | event_fifo.h | 21 struct evtchn_fifo_queue queue[EVTCHN_FIFO_MAX_QUEUES]; member
|
| /xen-4.10.0-shim-comet/tools/libs/toolcore/ |
| A D | Makefile | 55 …ore_list.h: $(XEN_INCLUDE)/xen-external/bsd-sys-queue-h-seddery $(XEN_INCLUDE)/xen-external/bsd-sy…
|
| /xen-4.10.0-shim-comet/docs/misc/ |
| A D | netif-staging-grants.pandoc | 315 [*Linux-specific*: It means we take a packet and add to an internal queue
431 be kept mapped in the backend. It only receives the queue as argument, and
437 It receives the queue index, the grant containing the list (offset is
469 maps it can keep. It then grants N entries per queue on both TX and RX ring
532 1queue 17244/6000 38189/28108
533 2queue 24023/9416 54783/40624
534 3queue 29148/17196 85777/54118
535 4queue 39782/18502 99530/46859
543 1queue 0.684/0.439 2.49/2.96
544 2queue 0.953/0.755 4.74/5.07
[all …]
|
| A D | xenmon.txt | 32 amount of time the domain spent in the "runnable" state (or on the run queue)
|
| A D | pvcalls.markdown | 608 - **backlog**: the maximum length to which the queue of pending
638 queue of pending connections for the listening socket identified by
712 the queue of the passive socket, the backend generates a response and
|
| /xen-4.10.0-shim-comet/tools/ocaml/libs/xb/ |
| A D | xb.mli | 78 val queue : t -> Packet.t -> unit val
|
| A D | xb.ml | 70 let queue con pkt = Queue.push pkt con.pkt_out function
|
| /xen-4.10.0-shim-comet/tools/fuzz/ |
| A D | README.afl | 57 $ ls queue/id* | xargs $path/afl-harness-cov
|
| /xen-4.10.0-shim-comet/tools/blktap2/ |
| A D | README | 116 Pausing a guest will also plug the corresponding IO queue for blktap2
152 the request queue of a live running guest.
301 request to a wait queue.
|
| /xen-4.10.0-shim-comet/stubdom/ |
| A D | lwip.patch-cvs | 794 + * the packet on a queue.
795 + * In callback mode, the packet is put on an internal queue and is fed to
824 + /* check for overflow or too many pbuf on queue */
834 + /* Copy the whole pbuf queue p into the single pbuf r */
886 + /* adjust the number of pbufs on queue */
904 + /* De-queue the pbuf from its successors on the 'loop_' list. */
948 * @note Only one packet is copied, no packet queue!
1793 + * LWIP_LOOPBACK_MAX_PBUFS: Maximum number of pbufs on queue for loopback
2261 - /* De-queue the pbuf from its successors on the 'priv' list. */
2280 - * the packet on a queue.
[all …]
|