| /dports/net/nanomsg/nanomsg-1.1.5/src/utils/ |
| H A D | msg.c | 29 nn_chunkref_init (&self->sphdr, 0); in nn_msg_init()
36 nn_chunkref_init (&self->sphdr, 0); in nn_msg_init_chunk()
43 nn_chunkref_term (&self->sphdr); in nn_msg_term()
50 nn_chunkref_mv (&dst->sphdr, &src->sphdr); in nn_msg_mv()
57 nn_chunkref_cp (&dst->sphdr, &src->sphdr); in nn_msg_cp()
64 nn_chunkref_bulkcopy_start (&self->sphdr, copies); in nn_msg_bulkcopy_start()
71 nn_chunkref_bulkcopy_cp (&dst->sphdr, &src->sphdr); in nn_msg_bulkcopy_cp()
|
| H A D | msg.h | 35 struct nn_chunkref sphdr; member
|
| /dports/net/nanomsg/nanomsg-1.1.5/src/protocols/survey/ |
| H A D | xrespondent.c | 163 if (nn_slow (nn_chunkref_size (&msg->sphdr) < sizeof (uint32_t))) { in nn_xrespondent_send()
169 key = nn_getl (nn_chunkref_data (&msg->sphdr)); in nn_xrespondent_send()
170 nn_chunkref_trim (&msg->sphdr, 4); in nn_xrespondent_send()
241 nn_assert (nn_chunkref_size (&msg->sphdr) == 0); in nn_xrespondent_recv()
242 nn_chunkref_term (&msg->sphdr); in nn_xrespondent_recv()
243 nn_chunkref_init (&msg->sphdr, i * sizeof (uint32_t)); in nn_xrespondent_recv()
244 memcpy (nn_chunkref_data (&msg->sphdr), data, i * sizeof (uint32_t)); in nn_xrespondent_recv()
250 nn_chunkref_init (&ref, nn_chunkref_size (&msg->sphdr) + sizeof (uint32_t)); in nn_xrespondent_recv()
253 nn_chunkref_data (&msg->sphdr), nn_chunkref_size (&msg->sphdr)); in nn_xrespondent_recv()
254 nn_chunkref_term (&msg->sphdr); in nn_xrespondent_recv()
[all …]
|
| H A D | respondent.c | 118 nn_assert (nn_chunkref_size (&msg->sphdr) == 0); in nn_respondent_send()
119 nn_chunkref_term (&msg->sphdr); in nn_respondent_send()
120 nn_chunkref_mv (&msg->sphdr, &respondent->backtrace); in nn_respondent_send()
153 nn_chunkref_mv (&respondent->backtrace, &msg->sphdr); in nn_respondent_recv()
154 nn_chunkref_init (&msg->sphdr, 0); in nn_respondent_recv()
|
| H A D | surveyor.c | 203 nn_assert (nn_chunkref_size (&msg->sphdr) == 0); in nn_surveyor_send()
204 nn_chunkref_term (&msg->sphdr); in nn_surveyor_send()
205 nn_chunkref_init (&msg->sphdr, 4); in nn_surveyor_send()
206 nn_putl (nn_chunkref_data (&msg->sphdr), surveyor->surveyid); in nn_surveyor_send()
260 if (nn_slow (nn_chunkref_size (&msg->sphdr) != sizeof (uint32_t))) in nn_surveyor_recv()
262 surveyid = nn_getl (nn_chunkref_data (&msg->sphdr)); in nn_surveyor_recv()
267 nn_chunkref_term (&msg->sphdr); in nn_surveyor_recv()
268 nn_chunkref_init (&msg->sphdr, 0); in nn_surveyor_recv()
|
| H A D | xsurveyor.c | 177 nn_assert (nn_chunkref_size (&msg->sphdr) == 0); in nn_xsurveyor_recv()
178 nn_chunkref_term (&msg->sphdr); in nn_xsurveyor_recv()
179 nn_chunkref_init (&msg->sphdr, sizeof (uint32_t)); in nn_xsurveyor_recv()
180 memcpy (nn_chunkref_data (&msg->sphdr), nn_chunkref_data (&msg->body), in nn_xsurveyor_recv()
|
| /dports/net/nanomsg/nanomsg-1.1.5/src/protocols/reqrep/ |
| H A D | xrep.c | 164 if (nn_slow (nn_chunkref_size (&msg->sphdr) < sizeof (uint32_t))) { in nn_xrep_send()
170 key = nn_getl (nn_chunkref_data (&msg->sphdr)); in nn_xrep_send()
171 nn_chunkref_trim (&msg->sphdr, 4); in nn_xrep_send()
242 nn_assert (nn_chunkref_size (&msg->sphdr) == 0); in nn_xrep_recv()
243 nn_chunkref_term (&msg->sphdr); in nn_xrep_recv()
244 nn_chunkref_init (&msg->sphdr, i * sizeof (uint32_t)); in nn_xrep_recv()
245 memcpy (nn_chunkref_data (&msg->sphdr), data, i * sizeof (uint32_t)); in nn_xrep_recv()
252 nn_chunkref_size (&msg->sphdr) + sizeof (uint32_t)); in nn_xrep_recv()
255 nn_chunkref_data (&msg->sphdr), nn_chunkref_size (&msg->sphdr)); in nn_xrep_recv()
256 nn_chunkref_term (&msg->sphdr); in nn_xrep_recv()
[all …]
|
| H A D | rep.c | 102 nn_assert (nn_chunkref_size (&msg->sphdr) == 0); in nn_rep_send()
103 nn_chunkref_term (&msg->sphdr); in nn_rep_send()
104 nn_chunkref_mv (&msg->sphdr, &rep->backtrace); in nn_rep_send()
135 nn_chunkref_mv (&rep->backtrace, &msg->sphdr); in nn_rep_recv()
136 nn_chunkref_init (&msg->sphdr, 0); in nn_rep_recv()
|
| H A D | req.c | 167 if (nn_slow (nn_chunkref_size (&req->task.reply.sphdr) != in nn_req_in()
174 reqid = nn_getl (nn_chunkref_data (&req->task.reply.sphdr)); in nn_req_in()
185 nn_chunkref_term (&req->task.reply.sphdr); in nn_req_in()
186 nn_chunkref_init (&req->task.reply.sphdr, 0); in nn_req_in()
240 nn_assert (nn_chunkref_size (&msg->sphdr) == 0); in nn_req_csend()
241 nn_chunkref_term (&msg->sphdr); in nn_req_csend()
242 nn_chunkref_init (&msg->sphdr, 4); in nn_req_csend()
243 nn_putl (nn_chunkref_data (&msg->sphdr), req->task.id | 0x80000000); in nn_req_csend()
|
| H A D | xreq.c | 196 nn_assert (nn_chunkref_size (&msg->sphdr) == 0); in nn_xreq_recv()
197 nn_chunkref_term (&msg->sphdr); in nn_xreq_recv()
198 nn_chunkref_init (&msg->sphdr, sizeof (uint32_t)); in nn_xreq_recv()
199 memcpy (nn_chunkref_data (&msg->sphdr), nn_chunkref_data (&msg->body), in nn_xreq_recv()
|
| /dports/net/nanomsg/nanomsg-1.1.5/src/protocols/bus/ |
| H A D | xbus.c | 154 hdrsz = nn_chunkref_size (&msg->sphdr); in nn_xbus_send()
158 memcpy (&exclude, nn_chunkref_data (&msg->sphdr), sizeof (exclude)); in nn_xbus_send()
159 nn_chunkref_term (&msg->sphdr); in nn_xbus_send()
160 nn_chunkref_init (&msg->sphdr, 0); in nn_xbus_send()
185 if (nn_chunkref_size (&msg->sphdr) == 0) in nn_xbus_recv()
191 nn_chunkref_term (&msg->sphdr); in nn_xbus_recv()
192 nn_chunkref_init (&msg->sphdr, sizeof (uint64_t)); in nn_xbus_recv()
193 memset (nn_chunkref_data (&msg->sphdr), 0, sizeof (uint64_t)); in nn_xbus_recv()
194 memcpy (nn_chunkref_data (&msg->sphdr), &pipe, sizeof (pipe)); in nn_xbus_recv()
|
| H A D | bus.c | 89 if (nn_chunkref_size (&msg->sphdr)) in nn_bus_send()
111 nn_assert (nn_chunkref_size (&msg->sphdr) == sizeof (uint64_t)); in nn_bus_recv()
114 nn_chunkref_term (&msg->sphdr); in nn_bus_recv()
115 nn_chunkref_init (&msg->sphdr, 0); in nn_bus_recv()
|
| /dports/net/nanomsg/nanomsg-1.1.5/src/transports/inproc/ |
| H A D | msgqueue.c | 87 msgsz = nn_chunkref_size (&msg->sphdr) + nn_chunkref_size (&msg->body); in nn_msgqueue_send()
142 self->mem -= (nn_chunkref_size (&msg->sphdr) + in nn_msgqueue_recv()
|
| H A D | sinproc.c | 154 nn_chunkref_size (&msg->sphdr) + in nn_sinproc_send()
157 nn_chunkref_data (&msg->sphdr), in nn_sinproc_send()
158 nn_chunkref_size (&msg->sphdr)); in nn_sinproc_send()
160 nn_chunkref_size (&msg->sphdr), in nn_sinproc_send()
|
| /dports/devel/zpu-binutils/zpu-toolchain-1.0/toolchain/gcc/newlib/libc/sys/linux/include/netns/ |
| H A D | spp_var.h | 60 struct sphdr s_shdr; /* prototype header to transmit */
69 struct sphdr s_rhdr; /* last received header (in effect!)*/
|
| H A D | sp.h | 44 struct sphdr { struct
|
| H A D | spidp.h | 46 struct sphdr si_s;
|
| /dports/devel/zpu-gcc/zpu-toolchain-1.0/toolchain/gcc/newlib/libc/sys/linux/include/netns/ |
| H A D | spp_var.h | 60 struct sphdr s_shdr; /* prototype header to transmit */
69 struct sphdr s_rhdr; /* last received header (in effect!)*/
|
| H A D | sp.h | 44 struct sphdr { struct
|
| H A D | spidp.h | 46 struct sphdr si_s;
|
| /dports/devel/arm-none-eabi-newlib/newlib-2.4.0/newlib/libc/sys/linux/include/netns/ |
| H A D | spp_var.h | 60 struct sphdr s_shdr; /* prototype header to transmit */
69 struct sphdr s_rhdr; /* last received header (in effect!)*/
|
| H A D | sp.h | 44 struct sphdr { struct
|
| H A D | spidp.h | 46 struct sphdr si_s;
|
| /dports/net/nanomsg/nanomsg-1.1.5/src/transports/tcp/ |
| H A D | stcp.c | 136 nn_putll (stcp->outhdr, nn_chunkref_size (&stcp->outmsg.sphdr) + in nn_stcp_send()
142 iov [1].iov_base = nn_chunkref_data (&stcp->outmsg.sphdr); in nn_stcp_send()
143 iov [1].iov_len = nn_chunkref_size (&stcp->outmsg.sphdr); in nn_stcp_send()
|
| /dports/net/nanomsg/nanomsg-1.1.5/src/transports/ipc/ |
| H A D | sipc.c | 141 nn_putll (sipc->outhdr + 1, nn_chunkref_size (&sipc->outmsg.sphdr) + in nn_sipc_send()
147 iov [1].iov_base = nn_chunkref_data (&sipc->outmsg.sphdr); in nn_sipc_send()
148 iov [1].iov_len = nn_chunkref_size (&sipc->outmsg.sphdr); in nn_sipc_send()
|