Searched refs:recv (Results 1 - 25 of 87) sorted by relevance

1234

/barrelfish-2018-10-04/include/thc/
H A Dthcstubs.h149 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 Dthcstubs.c37 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 Dbfscope.py25 header = s.recv(6)
31 trace += s.recv(1000000)
/barrelfish-2018-10-04/kernel/arch/x86/
H A Dipi_notify.c44 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 Draw.h66 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 Dudp.h100 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 Drecv.c31 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 Ddispatch.c154 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 Dthroughput.c30 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 Dlatency.c30 struct ump_chan_state *recv = &chan->endpoint.chan; local
41 while (!(msg = ump_impl_recv(recv)));
H A Dreceive.c30 struct ump_chan_state *recv = &chan->endpoint.chan; local
43 if ((msg = ump_impl_recv(recv))) {
H A Dsend.c30 struct ump_chan_state *recv = &chan->endpoint.chan; local
43 while (!(msg = ump_impl_recv(recv)));
H A Dexchange.c56 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 Dlatency_cache.c40 struct ump_chan_state *recv = &chan->endpoint.chan; local
72 while (!(msg = ump_impl_recv(recv)));
H A Dmain.c60 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 Dirq.c40 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 Draw.h80 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 Draw.c102 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 Dscheduler.c48 ** 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 Dsch_macros.h108 #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 Dread.c34 ret = recv(fd, buf, len, 0);
/barrelfish-2018-10-04/lib/devif/backends/net/mlx4/drivers/infiniband/core/
H A Dmad.c1829 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 Draw.c162 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 Dbarriers.c80 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 Dapi.h79 route_recv_fn recv; member in struct:route_cb_vtbl

Completed in 317 milliseconds

1234