Searched refs:queue (Results 1 - 25 of 37) sorted by relevance

12

/seL4-camkes-master/projects/musllibc/src/termios/
H A Dtcflush.c4 int tcflush(int fd, int queue) argument
6 return ioctl(fd, TCFLSH, queue);
/seL4-camkes-master/kernel/src/object/
H A Dendpoint.c19 static inline void ep_ptr_set_queue(endpoint_t *epptr, tcb_queue_t queue) argument
21 endpoint_ptr_set_epQueue_head(epptr, (word_t)queue.head);
22 endpoint_ptr_set_epQueue_tail(epptr, (word_t)queue.end);
37 tcb_queue_t queue; local
55 /* Place calling thread in endpoint queue */
56 queue = ep_ptr_get_queue(epptr);
57 queue = tcbEPAppend(thread, queue);
59 ep_ptr_set_queue(epptr, queue);
64 tcb_queue_t queue; local
169 tcb_queue_t queue; local
200 tcb_queue_t queue; local
310 tcb_queue_t queue; local
413 tcb_queue_t queue = ep_ptr_get_queue(epptr); local
466 tcb_queue_t queue = ep_ptr_get_queue(epptr); local
[all...]
H A Dnotification.c130 /* Haskell error "WaitingNtfn Notification must have non-empty queue" */
137 /* set the thread state to idle if the queue is empty */
303 tcb_queue_t queue = ntfn_ptr_get_queue(ntfnPtr); local
304 queue = tcbEPDequeue(thread, queue);
305 queue = tcbEPAppend(thread, queue);
306 ntfn_ptr_set_queue(ntfnPtr, queue);
H A Dtcb.c81 /* Add TCB to the head of a scheduler queue */
90 tcb_queue_t queue; local
98 queue = NODE_STATE_ON_CORE(ksReadyQueues[idx], tcb->tcbAffinity);
100 if (!queue.end) { /* Empty list */
101 queue.end = tcb;
104 queue.head->tcbSchedPrev = tcb;
107 tcb->tcbSchedNext = queue.head;
108 queue.head = tcb;
110 NODE_STATE_ON_CORE(ksReadyQueues[idx], tcb->tcbAffinity) = queue;
116 /* Add TCB to the end of a scheduler queue */
125 tcb_queue_t queue; local
155 tcb_queue_t queue; local
226 tcbEPAppend(tcb_t *tcb, tcb_queue_t queue) argument
242 tcbEPDequeue(tcb_t *tcb, tcb_queue_t queue) argument
[all...]
/seL4-camkes-master/tools/rumprun/include/rumprun-base/
H A Dconfig.h29 #include <sys/queue.h>
/seL4-camkes-master/tools/rumprun/platform/xen/xen/include/mini-os/
H A Dwaittypes.h5 #include <bmk-core/queue.h>
H A Dxenbus.h6 #include <mini-os/queue.h>
22 * your own accesses to the queue (including the contained waitq)
46 void xenbus_event_queue_init(struct xenbus_event_queue *queue);
50 void xenbus_wait_for_watch(struct xenbus_event_queue *queue);
51 char **xenbus_wait_for_watch_return(struct xenbus_event_queue *queue);
52 char* xenbus_wait_for_value(const char *path, const char *value, struct xenbus_event_queue *queue);
53 char *xenbus_wait_for_state_change(const char* path, XenbusState *state, struct xenbus_event_queue *queue);
56 /* When no token is provided, use a global queue. */
127 * Use of queue->wakeup:
129 * If queue
[all...]
H A Dqueue.h4 #include <bmk-core/queue.h>
H A Dwait.h10 #include <bmk-core/queue.h>
/seL4-camkes-master/kernel/include/object/
H A Dendpoint.h14 tcb_queue_t queue; local
16 queue.head = (tcb_t *)endpoint_ptr_get_epQueue_head(epptr);
17 queue.end = (tcb_t *)endpoint_ptr_get_epQueue_tail(epptr);
19 return queue;
H A Dtcb.h81 /* Add TCB into the priority ordered endpoint queue */
82 static inline tcb_queue_t tcbEPAppend(tcb_t *tcb, tcb_queue_t queue) argument
84 /* start at the back of the queue as FIFO is the common case */
85 tcb_t *before = queue.end;
96 queue.head = tcb;
103 queue.end = tcb;
111 return queue;
114 tcb_queue_t tcbEPDequeue(tcb_t *tcb, tcb_queue_t queue);
117 tcb_queue_t tcbEPAppend(tcb_t *tcb, tcb_queue_t queue);
118 tcb_queue_t tcbEPDequeue(tcb_t *tcb, tcb_queue_t queue);
[all...]
/seL4-camkes-master/projects/seL4_projects_libs/libsel4vmmplatsupport/src/drivers/
H A Dvirtio_emul.c53 *result = emul->virtq.queue_size[emul->virtq.queue];
57 *result = emul->virtq.queue_pfn[emul->virtq.queue];
82 emul->virtq.queue = (value & 0xffff);
83 assert(emul->virtq.queue == 0 || emul->virtq.queue == 1);
87 int queue = emul->virtq.queue; local
88 emul->virtq.queue_pfn[queue] = value;
89 vring_init(&emul->virtq.vring[queue], emul->virtq.queue_size[queue], (voi
[all...]
/seL4-camkes-master/projects/util_libs/libplatsupport/src/
H A Dtqueue.c89 /* remove from queue */
91 sglib_tqueue_node_t_delete(&tq->queue, &tq->array[id]);
110 /* delete the callback from the queue if its present */
112 sglib_tqueue_node_t_delete(&tq->queue, &tq->array[id]);
120 sglib_tqueue_node_t_add(&tq->queue, &tq->array[id]);
136 /* delete the callback from the queue if its present */
138 sglib_tqueue_node_t_delete(&tq->queue, &tq->array[id]);
150 /* keep checking the head of this queue */
151 tqueue_node_t *t = head(tq->queue);
159 sglib_tqueue_node_t_delete(&tq->queue,
[all...]
/seL4-camkes-master/tools/rumprun/platform/xen/xen/xenbus/
H A Dxenbus.c69 static void queue_wakeup(struct xenbus_event_queue *queue) argument
71 minios_wake_up(&queue->waitq);
74 void xenbus_event_queue_init(struct xenbus_event_queue *queue) argument
76 MINIOS_STAILQ_INIT(&queue->events);
77 queue->wakeup = queue_wakeup;
78 minios_init_waitqueue_head(&queue->waitq);
81 static struct xenbus_event *remove_event(struct xenbus_event_queue *queue) argument
86 event = MINIOS_STAILQ_FIRST(&queue->events);
89 MINIOS_STAILQ_REMOVE_HEAD(&queue->events, entry);
95 static void queue_event(struct xenbus_event_queue *queue, argument
103 await_event(struct xenbus_event_queue *queue) argument
137 xenbus_wait_for_watch_return(struct xenbus_event_queue *queue) argument
146 xenbus_wait_for_watch(struct xenbus_event_queue *queue) argument
158 xenbus_wait_for_value(const char* path, const char* value, struct xenbus_event_queue *queue) argument
221 xenbus_wait_for_state_change(const char* path, XenbusState *state, struct xenbus_event_queue *queue) argument
534 struct xenbus_event_queue queue; local
[all...]
/seL4-camkes-master/projects/camkes/apps/picotcp_tcp_echo/components/Echo/src/
H A Decho.c42 static tx_msg_t *get_msg_from_queue(virtqueue_driver_t *queue) argument
46 if (virtqueue_get_used_buf(queue, &handle, &len) == 0) {
52 int more = virtqueue_gather_used(queue, &handle, &buf, &len, &flag);
54 ZF_LOGF("Failed to dequeue message from the queue");
/seL4-camkes-master/projects/camkes-tool/camkes/parser/
H A Dstage2.py41 queue = collections.deque(ast_augmented)
44 while len(queue) > 0:
45 source, filename, item = queue.popleft()
100 queue.extendleft(reversed(more_ast_augmented))
/seL4-camkes-master/projects/util_libs/libplatsupport/include/platsupport/
H A Dtqueue.h38 /* is this timeout in the callback queue? */
40 /* next ptr for queue */
47 tqueue_node_t *queue; member in struct:__anon688
/seL4-camkes-master/projects/lwip/doc/
H A DNO_SYS_SampleCode.c13 /* Put in a queue which is processed in main loop */
14 if(!queue_try_put(&queue, p)) {
15 /* queue is full -> packet loss */
97 struct pbuf* p = queue_try_get(&queue);
/seL4-camkes-master/projects/seL4_projects_libs/libsel4vmmplatsupport/include/sel4vmmplatsupport/drivers/
H A Dvirtio_pci_emul.h30 uint16_t queue; member in struct:v_queue
/seL4-camkes-master/kernel/src/fastpath/
H A Dfastpath.c426 /* Place the thread in the endpoint queue */
432 /* Set head/tail of queue and endpoint state. */
438 /* Update queue. */
439 tcb_queue_t queue = tcbEPAppend(NODE_STATE(ksCurThread), ep_ptr_get_queue(ep_ptr)); local
440 endpoint_ptr_set_epQueue_head_np(ep_ptr, TCB_REF(queue.head));
441 endpoint_ptr_mset_epQueue_tail_state(ep_ptr, TCB_REF(queue.end), EPState_Recv);
443 /* Append current thread onto the queue. */
448 /* Update tail of queue. */
/seL4-camkes-master/tools/rumprun/platform/hw/
H A Dintr.c31 #include <bmk-core/queue.h>
/seL4-camkes-master/tools/rumprun/platform/sel4/
H A Dintr.c44 #include <bmk-core/queue.h>
/seL4-camkes-master/projects/camkes/apps/cakeml_tipc/components/cakeml-filter/
H A DcomponentScript.sml54 (* Server has finished handling the message, dequeue it from the used queue *)
/seL4-camkes-master/tools/rumprun/platform/xen/librumpxen_xendev/
H A Dbusdev_user.c531 xenbus_dev_xb_wakeup(struct xenbus_event_queue *queue) argument
535 container_of(queue, struct rumpxenbus_data_user, replies);
536 DPRINTF(("/dev/xen/xenbus[queue=%p,du=%p]: wakeup...\n",queue,du));
H A Devtdev.c77 static void queue(struct xenevt_dev_data *d, u_int port) function
139 queue(d, port);

Completed in 270 milliseconds

12