Searched refs:ws (Results 1 - 25 of 169) sorted by relevance

1234567

/barrelfish-master/include/lwip/lwip/
H A Dsock_chan_support.h29 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 Dwaitset.h108 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 Dmonitor_client.h37 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 Dwaitset_chan.h33 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 Dwaitset.c104 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 Dump_endpoint.c57 * \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 Dwaitset_chan_priv.h22 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 Dqueue.c18 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 Dqueue.c34 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 Dpselect.c44 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 Dselect.c44 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 Dinterface_raw.c35 struct waitset *ws = get_default_waitset(); local
38 event_dispatch_non_block(ws);
/barrelfish-master/usr/drivers/serial/
H A Dmain.c42 struct waitset *ws = get_default_waitset(); local
44 err = event_dispatch(ws);
/barrelfish-master/lib/libc/stdio/
H A Dfgetws.c46 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 Dfputws.c47 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 Ddomain.c42 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 Dcapqueue.c43 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 Dqueue.c89 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 Dws_helpers.c19 if (item->ws) {
20 err = event_dispatch_non_block(item->ws);
/barrelfish-master/usr/bench/bulk_transfer/
H A Dcommon.c50 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 Dqueue.c22 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 Dint_route_client.h29 struct waitset *ws, interrupt_handler_fn handler, void *handler_arg);
/barrelfish-master/usr/monitor/include/
H A Dcaplock.h24 void caplock_init(struct waitset *ws);
H A Dqueue.h43 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 Dprintbasic_test.c73 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);

Completed in 111 milliseconds

1234567