| /dports/lang/micropython/micropython-1.17/extmod/ |
| H A D | moduwebsocket.c | 47 byte to_recv; member
67 o->to_recv = 2; in websocket_make_new()
81 if (self->to_recv != 0) { in websocket_read()
87 self->to_recv -= out_sz; in websocket_read()
88 if (self->to_recv != 0) { in websocket_read()
117 int to_recv = 0; in websocket_read() local
121 to_recv += 2; in websocket_read()
128 to_recv += 4; in websocket_read()
132 self->to_recv = to_recv; in websocket_read()
134 if (to_recv != 0) { in websocket_read()
[all …]
|
| /dports/devel/urjtag/urjtag-2021.03/src/tap/cable/ |
| H A D | cmd_xfer.c | 203 uint32_t to_recv) in urj_tap_cable_cx_cmd_queue() argument
218 cmd->to_recv = to_recv; in urj_tap_cable_cx_cmd_queue()
315 bytes_to_recv += cmd->to_recv; in urj_tap_cable_cx_xfer()
318 cmd->to_recv); in urj_tap_cable_cx_xfer()
329 out_cmd->buf_pos, out_cmd->to_recv); in urj_tap_cable_cx_xfer()
330 bytes_to_recv += out_cmd->to_recv; in urj_tap_cable_cx_xfer()
|
| H A D | cmd_xfer.h | 42 uint32_t to_recv; member
61 uint32_t to_recv);
|
| /dports/devel/urjtag/urjtag-2021.03/src/tap/usbconn/ |
| H A D | libftdi.c | 58 uint32_t to_recv; member
101 if (p->to_recv) in usbconn_ftdi_flush()
103 if (p->recv_write_idx + p->to_recv > p->recv_buf_len) in usbconn_ftdi_flush()
141 if (p->to_recv) in usbconn_ftdi_flush()
148 p->to_recv)) < 0) in usbconn_ftdi_flush()
154 if (recvd < p->to_recv) in usbconn_ftdi_flush()
159 p->to_recv -= recvd; in usbconn_ftdi_flush()
232 if ((p->to_recv + recv > URJ_USBCONN_FTDI_MAXRECV) in usbconn_ftdi_write()
234 && (p->to_recv == 0))) in usbconn_ftdi_write()
253 p->to_recv += recv; in usbconn_ftdi_write()
[all …]
|
| H A D | libftd2xx.c | 69 uint32_t to_recv; member
125 p->recv_buf_len, p->to_recv); in usbconn_ftd2xx_flush()
150 if (p->to_recv) in usbconn_ftd2xx_flush()
152 if (p->recv_write_idx + p->to_recv > p->recv_buf_len) in usbconn_ftd2xx_flush()
155 p->recv_buf_len = p->recv_write_idx + p->to_recv; in usbconn_ftd2xx_flush()
173 if (recvd < p->to_recv) in usbconn_ftd2xx_flush()
178 p->to_recv -= recvd; in usbconn_ftd2xx_flush()
262 if ((p->to_recv + recv > URJ_USBCONN_FTD2XX_MAXRECV) in usbconn_ftd2xx_write()
264 && (p->to_recv == 0))) in usbconn_ftd2xx_write()
283 p->to_recv += recv; in usbconn_ftd2xx_write()
[all …]
|
| /dports/net/openmpi3/openmpi-3.1.6/orte/mca/oob/ud/ |
| H A D | oob_ud_recv.c | 266 int to_recv = min (iov_left, mtu - packet_size); in mca_oob_ud_recv_try() local
270 to_recv, recv_req->req_data.iov.mr[iov_index]->lkey); in mca_oob_ud_recv_try()
272 iov_offset += to_recv; in mca_oob_ud_recv_try()
273 iov_left -= to_recv; in mca_oob_ud_recv_try()
274 packet_size += to_recv; in mca_oob_ud_recv_try()
314 int to_recv = min (buffer_left, mtu - packet_size); in mca_oob_ud_recv_try() local
318 to_recv, recv_req->req_data.buf.mr->lkey); in mca_oob_ud_recv_try()
320 buffer_offset += to_recv; in mca_oob_ud_recv_try()
321 buffer_left -= to_recv; in mca_oob_ud_recv_try()
322 packet_size += to_recv; in mca_oob_ud_recv_try()
|
| /dports/net/turnserver/coturn-4.5.2/src/apps/stunclient/ |
| H A D | stunclient.c | 173 const int to_recv = sizeof(buf.buf); in run_stunclient() local
176 len = recv(udp_fd, ptr, to_recv - recvd, 0); in run_stunclient()
328 const int to_recv = sizeof(buf.buf); in run_stunclient() local
331 len = recv(udp_fd, ptr, to_recv - recvd, 0); in run_stunclient()
|
| /dports/databases/mariadb105-client/mariadb-10.5.15/storage/columnstore/columnstore/utils/cloudio/ |
| H A D | SocketPool.h | 40 int send_recv(messageqcpp::ByteStream &to_send, messageqcpp::ByteStream *to_recv);
|
| /dports/databases/mariadb105-server/mariadb-10.5.15/storage/columnstore/columnstore/utils/cloudio/ |
| H A D | SocketPool.h | 40 int send_recv(messageqcpp::ByteStream &to_send, messageqcpp::ByteStream *to_recv);
|
| /dports/science/qmcpack/qmcpack-3.11.0/src/AFQMC/Matrix/ |
| H A D | csr_matrix_construct.hpp | 520 long to_recv = std::min(deltaN, nsent + nplus[ni][ci] - nbefore);
521 if (to_recv * sizeof(Type) >= static_cast<long>(std::numeric_limits<int>::max()))
523 int to_recv_int = int(to_recv * sizeof(Type));
525 Q.resize(curr_sz + to_recv);
528 nbefore += to_recv;
529 deltaN -= to_recv;
|
| /dports/devel/libdill/libdill-2.14/ |
| H A D | fd.c | 254 size_t to_recv = len < 0 || len > sizeof(buf) ? sizeof(buf) : len; in dill_fd_skip() local
255 struct dill_iolist iol = {buf, to_recv, NULL, 0}; in dill_fd_skip()
258 if(len >= 0) len -= to_recv; in dill_fd_skip()
|
| /dports/net/turnserver/coturn-4.5.2/src/apps/natdiscovery/ |
| H A D | natdiscovery.c | 164 const int to_recv = sizeof(buf.buf); in stunclient_receive() local
173 len = recv(sockfd, ptr, to_recv - recvd, 0); in stunclient_receive()
398 const int to_recv = sizeof(buf->buf); in stunclient_receive() local
407 len = recv(sockfd, ptr, to_recv - recvd, 0); in stunclient_receive()
|
| /dports/dns/gdnsd2/gdnsd-2.4.3/plugins/ |
| H A D | http_status.c | 252 const unsigned to_recv = 13U - md->done; in mon_read_cb() local
253 const ssize_t recv_rv = recv(md->sock, md->res_buf + md->done, to_recv, 0); in mon_read_cb()
273 if(recvd < to_recv) { in mon_read_cb()
|
| /dports/www/firefox-legacy/firefox-52.8.0esr/testing/mozbase/mozdevice/mozdevice/ |
| H A D | devicemanagerSUT.py | 602 def uread(to_recv, error_msg): argument
607 data = self._sock.recv(to_recv)
626 to_recv = min(total_to_recv - len(buf), 1024)
627 data = uread(to_recv, error_msg)
|
| /dports/devel/libqb/libqb-2.0.3/lib/ |
| H A D | ipc_setup.c | 224 int32_t to_recv = len; in qb_ipc_us_recv() local
230 result = recv(one_way->u.us.sock, &data[processed], to_recv, in qb_ipc_us_recv()
255 to_recv -= result; in qb_ipc_us_recv()
|
| H A D | ipc_socket.c | 465 int32_t to_recv = 0; in qb_ipc_us_recv_at_most() local
511 to_recv = hdr->size; in qb_ipc_us_recv_at_most()
514 result = recv(one_way->u.us.sock, data, to_recv, in qb_ipc_us_recv_at_most()
|
| /dports/net-mgmt/lldpd/lldpd-1.0.8/src/lib/ |
| H A D | atom.h | 83 void **to_recv, struct marshal_info *mi_recv);
|
| H A D | atom.c | 313 void **to_recv, struct marshal_info *mi_recv) in _lldpctl_do_something() argument
346 type, to_recv, mi_recv)) > 0) { in _lldpctl_do_something()
|
| /dports/net/liblinphone/linphone-3.12.0/tester/ |
| H A D | call_single_tester.c | 4551 MSQueue to_recv; member
4585 ms_queue_put(&data->to_recv, dupmsg(msg)); in rtptm_on_receive()
4614 while ((msg = ms_queue_get(&data->to_recv)) != NULL) { in rtptm_on_schedule()
4648 ms_queue_init(&data->to_recv); in call_state_changed_4()
|
| /dports/devel/urjtag/urjtag-2021.03/ |
| H A D | ChangeLog | 3223 p->to_recv
|