/barrelfish-2018-10-04/include/thc/ |
H A D | thcstubs.h | 149 extern void thc_init_per_recv_state(struct thc_per_recv_t *recv); 155 struct thc_per_recv_t *recv) { 159 while (recv->num_discard == 0 && 160 (recv->r == NULL || recv->r->waiter == NULL)) { 161 recv->num_bh++; 162 thc_condvar_wait(&recv->cv_bh, &thc->thc_binding_lock); 163 recv->num_bh--; 166 if (recv->num_discard > 0) { 168 recv 153 thc_start_bh(struct thc_per_binding_state_t *thc, void *f, struct thc_per_recv_t *recv) argument 183 thc_end_bh(struct thc_per_binding_state_t *thc, void *f, struct thc_per_recv_t *recv, struct thc_receiver_info *rxi) argument [all...] |
/barrelfish-2018-10-04/lib/thc/ |
H A D | thcstubs.c | 37 void thc_init_per_recv_state(struct thc_per_recv_t *recv) { argument 38 recv->r = NULL; 39 thc_condvar_init(&recv->cv_bh); 40 recv->num_bh = 0; 41 recv->num_discard = 0; 42 thc_queue_init(&recv->fifo_rpc_q); 43 thc_lock_init(&recv->fifo_rpc_lock); 44 recv->fifo_rpc_next_recv = 0; 70 struct thc_per_recv_t *recv, 80 rxi = recv 68 thc_start_demuxable_bh(struct thc_per_binding_state_t *thc, void *common_binding, struct thc_per_recv_t *recv, uint64_t demux) argument 123 thc_receive(struct thc_per_binding_state_t *thc, struct thc_per_recv_t *recv, struct thc_receiver_info *rxi) argument 185 thc_receive_x(struct thc_per_binding_state_t *thc, struct thc_per_recv_t *recv, struct thc_receiver_info *rxi) argument 246 thc_discard(struct thc_per_binding_state_t *thc, struct thc_per_recv_t *recv, uint64_t n) argument 263 thc_start_receive_demux(struct thc_per_binding_state_t *thc, struct thc_per_recv_t *recv, struct thc_receiver_info *rxi) argument 279 thc_receive_demux(struct thc_per_binding_state_t *thc, struct thc_per_recv_t *recv, struct thc_receiver_info *rxi) argument 316 thc_receive_demux_x(struct thc_per_binding_state_t *thc, struct thc_per_recv_t *recv, struct thc_receiver_info *rxi) argument 375 thc_cancel_receive_demux(struct thc_per_binding_state_t *thc, struct thc_per_recv_t *recv, struct thc_receiver_info *rxi) argument 424 thc_start_receiving(struct thc_per_binding_state_t *thc, struct thc_per_recv_t *recv, struct thc_receiver_info *rxi) argument 486 thc_stop_receiving(struct thc_per_binding_state_t *thc, struct thc_per_recv_t *recv, struct thc_receiver_info *rxi) argument [all...] |
/barrelfish-2018-10-04/tools/tracing/ |
H A D | bfscope.py | 25 header = s.recv(6) 31 trace += s.recv(1000000)
|
/barrelfish-2018-10-04/kernel/arch/x86/ |
H A D | ipi_notify.c | 44 struct cte *recv; local 48 2, &recv, CAPRIGHTS_WRITE); 53 assert(recv != NULL); 56 if(recv->cap.type != ObjType_EndPoint) { 61 if(recv->cap.u.endpoint.listener == NULL) { 70 return caps_copy_to_cte(&endpoints[chanid], recv, false, 0, 0);
|
/barrelfish-2018-10-04/include/lwip/lwip/ |
H A D | raw.h | 66 u8_t(*recv) (void *arg, struct raw_pcb * pcb, struct pbuf * p, member in struct:raw_pcb 68 /* user-supplied argument for the recv callback */ 80 u8_t(*recv) (void *arg, struct raw_pcb * pcb,
|
H A D | udp.h | 100 void (*recv) (void *arg, struct udp_pcb * pcb, struct pbuf * p, member in struct:udp_pcb 102 /* user-supplied argument for the recv callback */ 116 void (*recv) (void *arg, struct udp_pcb * upcb,
|
/barrelfish-2018-10-04/lib/libc/net/ |
H A D | recv.c | 31 static char sccsid[] = "@(#)recv.c 8.2 (Berkeley) 2/21/94"; 43 recv(int s, void *buf, size_t len, int flags) function 46 * POSIX says recv() shall be a cancellation point, so call the
|
/barrelfish-2018-10-04/kernel/ |
H A D | dispatch.c | 154 struct dcb *recv = ep->u.endpoint.listener; local 155 assert(recv != NULL); 161 = (void *)((uint8_t *)recv->disp + ep->u.endpoint.epoffset); 167 err = caps_lookup_cap(&recv->cspace.cap, recv_ep->recv_cspc, 2, 207 /* Insert send cap into recv cap */ 216 assert(err_is_ok(err)); // A copy now exists in the recv slot, so this 234 struct dcb *recv = ep->u.endpoint.listener; local 235 assert(recv != NULL); 238 if (recv->disp == 0 || ep->u.endpoint.epoffset == 0) { 244 = (void *)((uint8_t *)recv 290 struct dcb *recv = ep->u.endpoint.listener; local 370 struct dcb *recv = ep->u.endpoint.listener; local [all...] |
/barrelfish-2018-10-04/usr/bench/ump_bench/ |
H A D | throughput.c | 30 struct ump_chan_state *recv = &chan->endpoint.chan; local 45 while (!(msg = ump_impl_recv(recv))); 53 while (!(msg = ump_impl_recv(recv)));
|
H A D | latency.c | 30 struct ump_chan_state *recv = &chan->endpoint.chan; local 41 while (!(msg = ump_impl_recv(recv)));
|
H A D | receive.c | 30 struct ump_chan_state *recv = &chan->endpoint.chan; local 43 if ((msg = ump_impl_recv(recv))) {
|
H A D | send.c | 30 struct ump_chan_state *recv = &chan->endpoint.chan; local 43 while (!(msg = ump_impl_recv(recv)));
|
H A D | exchange.c | 56 struct ump_chan_state *recv = &chan->endpoint.chan; local 72 msg = ump_impl_recv(recv); 124 struct ump_chan_state *recv = &chan->endpoint.chan; local 132 while (!(msg = ump_impl_recv(recv)));
|
H A D | latency_cache.c | 40 struct ump_chan_state *recv = &chan->endpoint.chan; local 72 while (!(msg = ump_impl_recv(recv)));
|
H A D | main.c | 60 struct ump_chan_state *recv = &chan->endpoint.chan; local 66 while (!(msg = ump_impl_recv(recv)));
|
/barrelfish-2018-10-04/kernel/arch/arm/ |
H A D | irq.c | 40 struct cte *recv; local 43 2, &recv, CAPRIGHTS_WRITE); 48 assert(recv != NULL); 51 if (recv->cap.type != ObjType_EndPoint) { 56 if (recv->cap.u.endpoint.listener == NULL) { 65 err = caps_copy_to_cte(&irq_dispatch[nidt], recv, false, 0, 0);
|
/barrelfish-2018-10-04/include/lwip2/lwip/ |
H A D | raw.h | 80 raw_recv_fn recv; member in struct:raw_pcb 81 /* user-supplied argument for the recv callback */ 101 void raw_recv (struct raw_pcb *pcb, raw_recv_fn recv, void *recv_arg);
|
/barrelfish-2018-10-04/lib/lwip/src/core/ |
H A D | raw.c | 102 if (pcb->recv != NULL) { 104 if (pcb->recv(pcb->recv_arg, pcb, p, &(iphdr->src)) != 0) { 182 u8_t(*recv) (void *arg, struct raw_pcb * upcb, struct pbuf * p, 185 /* remember recv() callback and user data */ 186 pcb->recv = recv;
|
/barrelfish-2018-10-04/usr/eclipseclp/Kernel/src/ |
H A D | scheduler.c | 48 ** recv-id, msg-type, send-id 257 struct st_id_ds recv; member in struct:__anon1638 263 struct st_id_ds recv; member in struct:__anon1639 270 struct st_id_ds recv; member in struct:__anon1640 278 struct st_id_ds recv; member in struct:__anon1641 285 struct st_id_ds recv; member in struct:__anon1642 294 struct st_id_ds recv; member in struct:__anon1643 302 struct st_id_ds recv; member in struct:__anon1644 311 struct st_id_ds recv; member in struct:__anon1645 459 static void smsg_snd00(recv, typ 815 st_id_t *recv; local [all...] |
H A D | sch_macros.h | 108 #define Smsg_Hdl_Notify(smsg, recv, send) { \ 109 if (ComnSite((recv),(send))) \ 110 Scheduler(Site(recv))->smsg_count_intra++; \ 111 Scheduler(Site(recv))->smsg_count_hdl++; \ 112 Scheduler(Site(recv))->smsg_subcount[smsg]++; \ 113 Sch_Event_Notify2("RECV_SMSG",smsg_name[(smsg)], (send), (recv)); \ 115 #define Smsg_Snd_Notify(smsg, recv, send) { \ 117 Sch_Event_Notify2("SEND_SMSG",smsg_name[(smsg)], (send), (recv)); \ 568 #define IntraSiteCheckIn(recv,send) { \ 569 if ((recv) [all...] |
/barrelfish-2018-10-04/lib/posixcompat/ |
H A D | read.c | 34 ret = recv(fd, buf, len, 0);
|
/barrelfish-2018-10-04/lib/devif/backends/net/mlx4/drivers/infiniband/core/ |
H A D | mad.c | 1829 struct ib_mad_private *recv, *response = NULL; local 1840 recv = container_of(mad_priv_hdr, struct ib_mad_private, header); 1841 //ib_dma_unmap_single(port_priv->device, recv->header.mapping, 1846 recv->header.wc = *wc; 1847 recv->header.recv_wc.wc = &recv->header.wc; 1848 recv->header.recv_wc.mad_len = sizeof(struct ib_mad); 1849 recv->header.recv_wc.recv_buf.mad = &recv->mad.mad; 1850 recv [all...] |
/barrelfish-2018-10-04/lib/lwip2/src/core/ |
H A D | raw.c | 162 if (pcb->recv != NULL) { 167 eaten = pcb->recv(pcb->recv_arg, pcb, p, ip_current_src_addr()); 181 LWIP_ASSERT("raw pcb recv callback altered pbuf payload pointer without eating packet", 255 raw_recv(struct raw_pcb *pcb, raw_recv_fn recv, void *recv_arg) argument 257 /* remember recv() callback and user data */ 258 pcb->recv = recv;
|
/barrelfish-2018-10-04/lib/octopus/client/ |
H A D | barriers.c | 80 err = cl->recv.trigger(cl, NULL, NULL, &mode, NULL, NULL); 147 err = cl->recv.trigger(cl, NULL, NULL, &mode, NULL, NULL);
|
/barrelfish-2018-10-04/doc/006-routing/ |
H A D | api.h | 79 route_recv_fn recv; member in struct:route_cb_vtbl
|