/seL4-camkes-master/projects/musllibc/src/termios/ |
H A D | tcflush.c | 4 int tcflush(int fd, int queue) argument 6 return ioctl(fd, TCFLSH, queue);
|
/seL4-camkes-master/kernel/src/object/ |
H A D | endpoint.c | 19 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 D | notification.c | 130 /* 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 D | tcb.c | 81 /* 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 D | config.h | 29 #include <sys/queue.h>
|
/seL4-camkes-master/tools/rumprun/platform/xen/xen/include/mini-os/ |
H A D | waittypes.h | 5 #include <bmk-core/queue.h>
|
H A D | xenbus.h | 6 #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 D | queue.h | 4 #include <bmk-core/queue.h>
|
H A D | wait.h | 10 #include <bmk-core/queue.h>
|
/seL4-camkes-master/kernel/include/object/ |
H A D | endpoint.h | 14 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 D | tcb.h | 81 /* 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 D | virtio_emul.c | 53 *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 D | tqueue.c | 89 /* 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 D | xenbus.c | 69 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 D | echo.c | 42 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 D | stage2.py | 41 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 D | tqueue.h | 38 /* 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 D | NO_SYS_SampleCode.c | 13 /* 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 D | virtio_pci_emul.h | 30 uint16_t queue; member in struct:v_queue
|
/seL4-camkes-master/kernel/src/fastpath/ |
H A D | fastpath.c | 426 /* 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 D | intr.c | 31 #include <bmk-core/queue.h>
|
/seL4-camkes-master/tools/rumprun/platform/sel4/ |
H A D | intr.c | 44 #include <bmk-core/queue.h>
|
/seL4-camkes-master/projects/camkes/apps/cakeml_tipc/components/cakeml-filter/ |
H A D | componentScript.sml | 54 (* Server has finished handling the message, dequeue it from the used queue *)
|
/seL4-camkes-master/tools/rumprun/platform/xen/librumpxen_xendev/ |
H A D | busdev_user.c | 531 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 D | evtdev.c | 77 static void queue(struct xenevt_dev_data *d, u_int port) function 139 queue(d, port);
|