/barrelfish-master/include/lwip/lwip/ |
H A D | sock_chan_support.h | 29 errval_t lwip_sock_waitset_register_read(int socket, struct waitset *ws); 31 errval_t lwip_sock_waitset_register_write(int socket, struct waitset *ws);
|
/barrelfish-master/include/barrelfish/ |
H A D | waitset.h | 108 void waitset_init(struct waitset *ws); 109 errval_t waitset_destroy(struct waitset *ws); 111 errval_t get_next_event(struct waitset *ws, struct event_closure *retclosure); 112 errval_t get_next_event_disabled(struct waitset *ws, struct waitset_chanstate **retchan, 115 errval_t check_for_event(struct waitset *ws); 116 errval_t event_dispatch(struct waitset *ws); 117 errval_t wait_for_channel(struct waitset *ws, struct waitset_chanstate *channel, errval_t *error_var); 118 errval_t event_dispatch_disabled(struct waitset *ws, dispatcher_handle_t handle); 119 errval_t event_dispatch_debug(struct waitset *ws); 120 errval_t event_dispatch_non_block(struct waitset *ws); [all...] |
H A D | monitor_client.h | 37 struct waitset *ws, size_t lmp_buflen_words); 40 struct waitset *ws, size_t lmp_buflen_words); 43 struct waitset *ws, size_t lmp_buflen_words); 45 struct waitset *ws, uintptr_t domid,
|
H A D | waitset_chan.h | 33 errval_t waitset_chan_trigger_closure(struct waitset *ws, 37 errval_t waitset_chan_register(struct waitset *ws, struct waitset_chanstate *chan, 39 errval_t waitset_chan_register_polled(struct waitset *ws,
|
/barrelfish-master/lib/barrelfish/ |
H A D | waitset.c | 104 void waitset_init(struct waitset *ws) argument 106 assert(ws != NULL); 107 ws->pending = ws->polled = ws->idle = ws->waiting = NULL; 108 ws->waiting_threads = NULL; 114 errval_t waitset_destroy(struct waitset *ws) argument 116 assert(ws != NULL); 119 if (ws 174 get_pending_event_disabled(struct waitset *ws, struct waitset_chanstate *waitfor, struct waitset_chanstate *waitfor2) argument 263 reregister_channel(struct waitset *ws, struct waitset_chanstate *chan, dispatcher_handle_t handle) argument 288 find_recipient(struct waitset *ws, struct waitset_chanstate *channel, struct thread *me) argument 304 wake_up_other_thread(dispatcher_handle_t handle, struct waitset *ws) argument 335 get_next_event_disabled(struct waitset *ws, struct waitset_chanstate **retchannel, struct event_closure *retclosure, struct waitset_chanstate *waitfor, struct waitset_chanstate *waitfor2, dispatcher_handle_t handle, bool debug) argument 404 get_next_event(struct waitset *ws, struct event_closure *retclosure) argument 426 check_for_event_disabled(struct waitset *ws, dispatcher_handle_t handle) argument 438 check_for_event(struct waitset *ws) argument 458 event_dispatch(struct waitset *ws) argument 471 event_dispatch_debug(struct waitset *ws) argument 499 wait_for_channel(struct waitset *ws, struct waitset_chanstate *waitfor, errval_t *error_var) argument 537 event_dispatch_non_block(struct waitset *ws) argument 614 waitset_chan_register_disabled(struct waitset *ws, struct waitset_chanstate *chan, struct event_closure closure) argument 655 waitset_chan_register_polled_disabled(struct waitset *ws, struct waitset_chanstate *chan, struct event_closure closure, dispatcher_handle_t handle) argument 694 waitset_chan_register(struct waitset *ws, struct waitset_chanstate *chan, struct event_closure closure) argument 716 waitset_chan_register_polled(struct waitset *ws, struct waitset_chanstate *chan, struct event_closure closure) argument 738 struct waitset *ws = chan->waitset; local 798 struct waitset *ws = chan->waitset; local 849 struct waitset *ws = chan->waitset; local 912 waitset_chan_trigger_closure_disabled(struct waitset *ws, struct waitset_chanstate *chan, struct event_closure closure, dispatcher_handle_t handle) argument 960 waitset_chan_trigger_closure(struct waitset *ws, struct waitset_chanstate *chan, struct event_closure closure) argument [all...] |
H A D | ump_endpoint.c | 57 * \param ws Waitset 60 errval_t ump_endpoint_register(struct ump_endpoint *ep, struct waitset *ws, argument 68 assert(ws != NULL); 71 err = waitset_chan_trigger_closure_disabled(ws, &ep->waitset_state, closure, handle); 73 err = waitset_chan_register_polled_disabled(ws, &ep->waitset_state, closure, handle); 96 * \param ws New waitset 98 void ump_endpoint_migrate(struct ump_endpoint *ep, struct waitset *ws) argument 101 waitset_chan_migrate(&ep->waitset_state, ws);
|
/barrelfish-master/lib/barrelfish/include/ |
H A D | waitset_chan_priv.h | 22 errval_t waitset_chan_trigger_closure_disabled(struct waitset *ws, 28 errval_t waitset_chan_register_disabled(struct waitset *ws, 31 errval_t waitset_chan_register_polled_disabled(struct waitset *ws,
|
/barrelfish-master/usr/kaluga/ |
H A D | queue.c | 18 struct waitset *ws = get_default_waitset(); local 19 b->register_send(b, ws, MKCONT(send_next, b)); 37 struct waitset *ws = get_default_waitset(); local 38 errval_t err = b->register_send(b, ws, MKCONT(send_next, b));
|
/barrelfish-master/lib/octopus/server/ |
H A D | queue.c | 34 struct waitset *ws = get_default_waitset(); local 35 b->register_send(b, ws, MKCONT(oct_rpc_send_next, b)); 53 struct waitset *ws = get_default_waitset(); local 54 errval_t err = b->register_send(b, ws, MKCONT(oct_rpc_send_next, b));
|
/barrelfish-master/lib/libc/sys/ |
H A D | pselect.c | 44 pselect(int n, fd_set *rs, fd_set *ws, fd_set *es, const struct timespec *t, argument 50 __libc_interposing[INTERPOS_pselect])(n, rs, ws, es, t, s));
|
H A D | select.c | 44 select(int n, fd_set *rs, fd_set *ws, fd_set *es, struct timeval *t) argument 48 __libc_interposing[INTERPOS_select])(n, rs, ws, es, t));
|
/barrelfish-master/usr/bench/net_latency/elb/ |
H A D | interface_raw.c | 35 struct waitset *ws = get_default_waitset(); local 38 event_dispatch_non_block(ws);
|
/barrelfish-master/usr/drivers/serial/ |
H A D | main.c | 42 struct waitset *ws = get_default_waitset(); local 44 err = event_dispatch(ws);
|
/barrelfish-master/lib/libc/stdio/ |
H A D | fgetws.c | 46 fgetws_l(wchar_t * __restrict ws, int n, FILE * __restrict fp, locale_t locale) argument 65 wsp = ws; 100 } while ((wsp == ws || wsp[-1] != L'\n') && n > 1 && (fp->_r > 0 || 111 if (wsp == ws) 117 return (ws); 125 fgetws(wchar_t * __restrict ws, int n, FILE * __restrict fp) argument 127 return fgetws_l(ws, n, fp, __get_locale());
|
H A D | fputws.c | 47 fputws_l(const wchar_t * __restrict ws, FILE * __restrict fp, locale_t locale) argument 64 wsp = ws; 83 fputws(const wchar_t * __restrict ws, FILE * __restrict fp) argument 85 return fputws_l(ws, fp, __get_locale());
|
/barrelfish-master/usr/drivers/xeon_phi/ |
H A D | domain.c | 42 struct wait_state *ws = state; local 44 oct_remove_trigger(ws->tid); 52 interphi_domain_wait_reply(ws->node, err, ws->usr_state, domid); 120 struct wait_state *ws = malloc(sizeof(*ws)); local 121 if (ws == NULL) { 125 ws->usr_state = state; 126 ws->node = node; 131 domain_wait_trigger_handler, ws); [all...] |
/barrelfish-master/usr/monitor/capops/ |
H A D | capqueue.c | 43 capqueue_init(struct capqueue_queue *q, struct waitset *ws) argument 46 event_queue_init(&q->queues[0], ws, EVENT_QUEUE_CONTINUOUS); 47 event_queue_init(&q->queues[1], ws, EVENT_QUEUE_CONTINUOUS);
|
/barrelfish-master/usr/monitor/ |
H A D | queue.c | 89 struct waitset *ws = get_default_waitset(); // XXX: store this on the q? local 90 errval_t err = b->register_send(b, ws, MKCONT(intermon_send_handler,b)); 99 struct waitset *ws, struct msg_queue_elem *ms) 105 return b->register_send(b, ws, MKCONT(intermon_send_handler,b)); 112 struct waitset *ws, struct msg_queue_elem *ms) 118 return b->register_send(b, ws, MKCONT(intermon_send_handler,b)); 136 struct waitset *ws = get_default_waitset(); // XXX: store this on the q? local 137 errval_t err = b->register_send(b, ws, MKCONT(monitor_send_handler,b)); 146 struct waitset *ws, struct msg_queue_elem *ms) 152 return b->register_send(b, ws, MKCON 98 intermon_enqueue_send(struct intermon_binding *b, struct msg_queue *q, struct waitset *ws, struct msg_queue_elem *ms) argument 111 intermon_enqueue_send_at_front(struct intermon_binding *b, struct msg_queue *q, struct waitset *ws, struct msg_queue_elem *ms) argument 145 monitor_enqueue_send(struct monitor_binding *b, struct msg_queue *q, struct waitset *ws, struct msg_queue_elem *ms) argument 158 monitor_enqueue_send_at_front(struct monitor_binding *b, struct msg_queue *q, struct waitset *ws, struct msg_queue_elem *ms) argument [all...] |
/barrelfish-master/lib/bulk_transfer/backends/sm/ |
H A D | ws_helpers.c | 19 if (item->ws) { 20 err = event_dispatch_non_block(item->ws);
|
/barrelfish-master/usr/bench/bulk_transfer/ |
H A D | common.c | 50 struct bulk_channel_callbacks *cb, struct waitset *ws, 63 .waitset = ws, 80 err = bulk_net_proxy_listen(proxy, &pdesc->generic, ws, bufsz, 90 struct bulk_channel_callbacks *cb, struct waitset *ws, 103 .waitset = ws, 121 err = bulk_net_proxy_connect(proxy, &pdesc->generic, ws, bufsz, 131 struct bulk_channel_callbacks *cb, struct waitset *ws, 161 .waitset = ws, 178 struct bulk_channel_callbacks *cb, struct waitset *ws, 206 .waitset = ws, 49 net_proxy_listen(char *str, struct bulk_channel *channel, struct bulk_channel_callbacks *cb, struct waitset *ws, enum bulk_channel_direction dir, size_t bufsz, size_t metasz, bool *done) argument 89 net_proxy_connect(char *str, struct bulk_channel *channel, struct bulk_channel_callbacks *cb, struct waitset *ws, enum bulk_channel_direction dir, size_t bufsz, size_t metasz, bool *done) argument 130 net_transparent_listen(char *str, struct bulk_channel *channel, struct bulk_channel_callbacks *cb, struct waitset *ws, enum bulk_channel_direction dir, size_t bufsz, size_t metasz, bool *done, bool nocopy) argument 177 net_transparent_connect(char *str, struct bulk_channel *channel, struct bulk_channel_callbacks *cb, struct waitset *ws, enum bulk_channel_direction dir, size_t bufsz, size_t metasz, bool *done, bool nocopy) argument 216 sm_listen(char *str, struct bulk_channel *channel, struct bulk_channel_callbacks *cb, struct waitset *ws, enum bulk_channel_direction dir, size_t bufsz, size_t metasz, bool *done) argument 239 sm_connect(char *str, struct bulk_channel *channel, struct bulk_channel_callbacks *cb, struct waitset *ws, enum bulk_channel_direction dir, size_t bufsz, size_t metasz, bool *done) argument 263 initialize_channel(const char *str, struct bulk_channel *channel, struct bulk_channel_callbacks *cb, struct waitset *ws, enum bulk_channel_direction dir, size_t bufsz, size_t metasz, bool *done) argument [all...] |
/barrelfish-master/usr/skb/ |
H A D | queue.c | 22 struct waitset *ws = get_default_waitset(); local 23 b->register_send(b, ws, MKCONT(skb_send_next, b)); 42 struct waitset *ws = get_default_waitset(); local 43 errval_t err = b->register_send(b, ws, MKCONT(skb_send_next, b));
|
/barrelfish-master/include/int_route/ |
H A D | int_route_client.h | 29 struct waitset *ws, interrupt_handler_fn handler, void *handler_arg);
|
/barrelfish-master/usr/monitor/include/ |
H A D | caplock.h | 24 void caplock_init(struct waitset *ws);
|
H A D | queue.h | 43 struct waitset *ws, struct msg_queue_elem *ms); 46 struct waitset *ws, struct msg_queue_elem *ms); 58 struct waitset *ws, struct msg_queue_elem *ms); 61 struct waitset *ws, struct msg_queue_elem *ms);
|
/barrelfish-master/lib/libc/tests/stdio/ |
H A D | printbasic_test.c | 73 wchar_t ws[BUF], wfmt[BUF], wresult[BUF]; local 88 mbstowcs(ws, s, BUF - 1); 91 vswprintf(ws, sizeof(ws) / sizeof(ws[0]), wfmt, ap2); 92 if (wcscmp(wresult, ws) != 0) { 95 wfmt, argstr, ws, wresult);
|