| /kernel/linux/linux-6.6/tools/testing/selftests/net/ |
| H A D | udpgso_bench_rx.c | 171 ret = recv(fd, NULL, 1 << 21, MSG_TRUNC | MSG_DONTWAIT); in do_flush_tcp()
257 ret = recv(fd, rbuf, len, MSG_TRUNC | MSG_DONTWAIT); in do_flush_udp()
263 error(1, errno, "recv"); in do_flush_udp()
265 error(1, 0, "recv: bad packet len, got %d," in do_flush_udp()
269 error(1, errno, "recv: 0 byte datagram\n"); in do_flush_udp()
274 error(1, 0, "recv: bad gso size, got %d, expected %d " in do_flush_udp()
|
| H A D | reuseport_addr_any.c | 182 i = recv(fd, buf, sizeof(buf), 0); in receive_once()
185 i = recv(ev.data.fd, buf, sizeof(buf), 0); in receive_once()
189 error(1, errno, "failed to recv"); in receive_once()
|
| H A D | reuseport_bpf_numa.c | 175 i = recv(fd, buf, sizeof(buf), 0); in receive_on_node()
178 i = recv(ev.data.fd, buf, sizeof(buf), 0); in receive_on_node()
182 error(1, errno, "failed to recv"); in receive_on_node()
|
| H A D | reuseport_bpf_cpu.c | 165 i = recv(fd, buf, sizeof(buf), 0); in receive_on_cpu()
168 i = recv(ev.data.fd, buf, sizeof(buf), 0); in receive_on_cpu()
172 error(1, errno, "failed to recv"); in receive_on_cpu()
|
| /kernel/liteos_m/components/net/test/ |
| H A D | net_socket_test_003.c | 81 /* recv */
in SampleTcpServer()
83 ret = recv(sfd, g_buf, sizeof(g_buf), 0);
in SampleTcpServer()
84 LogPrintln("server recv on socket %d: %d", sfd, ret);
in SampleTcpServer()
180 /* recv */
in SampleTcpClient()
182 ret = recv(sfd, g_buf, sizeof(g_buf), 0);
in SampleTcpClient()
183 LogPrintln("client recv on socket %d: %d", sfd, ret);
in SampleTcpClient()
|
| /kernel/linux/linux-6.6/kernel/ |
| H A D | sys_ni.c | 323 COND_SYSCALL(recv); variable
324 COND_SYSCALL_COMPAT(recv); variable
|
| /kernel/linux/linux-6.6/tools/accounting/ |
| H A D | procacct.c | 188 rep_len = recv(sd, &ans, sizeof(ans), 0); in get_family_id()
351 rep_len = recv(nl_sd, &msg, sizeof(msg), 0); in main()
|
| /test/xts/acts/pcs/pcs_ndk/entry/src/main/cpp/ |
| H A D | pcsNetworkTest.cpp | 167 resultValue = recv(PARAM_0, buf, dataLen, PARAM_0);
in Recv()
173 resultValue = recv(sockets[PARAM_0], buf, sizeof buf, PARAM_0);
in Recv()
|
| /third_party/lwip/src/apps/tftp/ |
| H A D | tftp_server.c | 204 recv(void *arg, struct udp_pcb *upcb, struct pbuf *p, const ip_addr_t *addr, u16_t port) in recv() function
419 udp_recv(pcb, recv, NULL); in tftp_init()
|
| /third_party/lwip/src/include/lwip/ |
| H A D | tcp.h | 354 tcp_recv_fn recv; member
420 void tcp_recv (struct tcp_pcb *pcb, tcp_recv_fn recv);
|
| H A D | stats.h | 66 STAT_COUNTER recv; /* Received packets. */ member
82 STAT_COUNTER recv; /* Received packets. */ member
|
| /third_party/node/deps/v8/src/debug/wasm/gdb-server/ |
| H A D | transport.cc | 261 ::recv(handle_accept_, buf_.get() + size_, kBufSize - size_, 0); in ReadSomeData()
384 ::recv(handle_accept_, buf_.get() + size_, kBufSize - size_, 0);
|
| /third_party/python/Lib/multiprocessing/ |
| H A D | reduction.py | 102 return conn.recv().detach()
150 if ACKNOWLEDGE and sock.recv(1) != b'A':
|
| /third_party/python/Lib/test/ |
| H A D | test_asynchat.py | 47 data = conn.recv(1)
267 sock.recv.side_effect = BlockingIOError(errno.EAGAIN)
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/drivers/ |
| H A D | driver_wired.c | 125 len = recv(sock, buf, sizeof(buf), 0); in handle_read()
127 wpa_printf(MSG_ERROR, "recv: %s", strerror(errno)); in handle_read()
143 len = recv(sock, buf, sizeof(buf), 0); in handle_dhcp()
145 wpa_printf(MSG_ERROR, "recv: %s", strerror(errno)); in handle_dhcp()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/drivers/ |
| H A D | driver_wired.c | 125 len = recv(sock, buf, sizeof(buf), 0); in handle_read()
127 wpa_printf(MSG_ERROR, "recv: %s", strerror(errno)); in handle_read()
143 len = recv(sock, buf, sizeof(buf), 0); in handle_dhcp()
145 wpa_printf(MSG_ERROR, "recv: %s", strerror(errno)); in handle_dhcp()
|
| /third_party/curl/lib/ |
| H A D | openldap.c | 188 Curl_recv *recv; /* For stacking SSL handler */ member
475 return conn->proto.ldapc->recv != NULL; in ssl_installed()
495 li->recv = conn->recv[FIRSTSOCKET]; in oldap_ssl_connect()
839 conn->recv[FIRSTSOCKET] = oldap_recv; in oldap_connecting()
1180 ret = (li->recv)(data, FIRSTSOCKET, buf, len, &err); in ldapsb_tls_read()
|
| /third_party/lwip/src/apps/altcp_tls/ |
| H A D | altcp_tls_mbedtls.c | 237 if (conn->recv) { in altcp_mbedtls_lower_recv()
238 return conn->recv(conn->arg, conn, NULL, ERR_OK); in altcp_mbedtls_lower_recv()
276 /* handshake not done, wait for more recv calls */ in altcp_mbedtls_lower_recv_process()
323 if (conn->recv) { in altcp_mbedtls_pass_rx_data()
328 err = conn->recv(conn->arg, conn, buf, ERR_OK); in altcp_mbedtls_pass_rx_data()
349 if (conn->recv) { in altcp_mbedtls_pass_rx_data()
350 return conn->recv(conn->arg, conn, NULL, ERR_OK); in altcp_mbedtls_pass_rx_data()
376 /* We're short on pbufs, try again later from 'poll' or 'recv' callbacks. in altcp_mbedtls_handle_rx_appldata()
435 /* recv callback needs to return this as the pcb is deallocated */ in altcp_mbedtls_handle_rx_appldata()
|
| /kernel/linux/linux-5.10/drivers/bluetooth/ |
| H A D | btmtksdio.c | 378 { H4_RECV_ACL, .recv = hci_recv_frame },
379 { H4_RECV_SCO, .recv = hci_recv_frame },
380 { H4_RECV_EVENT, .recv = btmtksdio_recv_event },
468 (&pkts[i])->recv(bdev->hdev, skb); in btmtksdio_rx_packet()
|
| /kernel/linux/linux-6.6/drivers/mailbox/ |
| H A D | tegra-hsp.c | 79 void (*recv)(struct tegra_hsp_channel *channel); member
263 mb->ops->recv(&mb->channel); in tegra_hsp_shared_irq()
405 .recv = tegra_hsp_sm_recv32,
450 .recv = tegra_hsp_sm_recv128,
|
| /third_party/python/Lib/asyncio/ |
| H A D | proactor_events.py | 293 # the future will be replaced by next proactor.recv call
440 self._read_fut = self._loop._proactor.recv(self._sock, 16)
573 self._read_fut = self._loop._proactor.recv(self._sock,
705 return await self._proactor.recv(sock, n)
801 f = self._proactor.recv(self._ssock, 4096)
|
| /kernel/linux/linux-5.10/drivers/gpu/drm/amd/amdgpu/ |
| H A D | atombios_dp.c | 59 u8 *recv, int recv_size, in amdgpu_atombios_dp_process_aux_ch()
113 if (recv && recv_size) in amdgpu_atombios_dp_process_aux_ch()
114 amdgpu_atombios_copy_swap(recv, base + 16, recv_bytes, false); in amdgpu_atombios_dp_process_aux_ch()
57 amdgpu_atombios_dp_process_aux_ch(struct amdgpu_i2c_chan *chan, u8 *send, int send_bytes, u8 *recv, int recv_size, u8 delay, u8 *ack) amdgpu_atombios_dp_process_aux_ch() argument
|
| /kernel/linux/linux-5.10/drivers/gpu/drm/radeon/ |
| H A D | atombios_dp.c | 87 u8 *recv, int recv_size, in radeon_process_aux_ch()
144 if (recv && recv_size) in radeon_process_aux_ch()
145 radeon_atom_copy_swap(recv, base + 16, recv_bytes, false); in radeon_process_aux_ch()
85 radeon_process_aux_ch(struct radeon_i2c_chan *chan, u8 *send, int send_bytes, u8 *recv, int recv_size, u8 delay, u8 *ack) radeon_process_aux_ch() argument
|
| /kernel/linux/linux-5.10/drivers/misc/ti-st/ |
| H A D | st_core.c | 112 if (likely(st_gdata->list[chnl_id]->recv != NULL)) { in st_send_frame()
114 (st_gdata->list[chnl_id]->recv in st_send_frame()
117 pr_err(" proto stack %d's ->recv failed", chnl_id); in st_send_frame()
122 pr_err(" proto stack %d's ->recv null", chnl_id); in st_send_frame()
537 if (st_gdata == NULL || new_proto == NULL || new_proto->recv == NULL in st_register()
539 pr_err("gdata/new_proto/recv or reg_complete_cb not ready"); in st_register()
|
| /kernel/linux/linux-6.6/drivers/misc/ti-st/ |
| H A D | st_core.c | 109 if (likely(st_gdata->list[chnl_id]->recv != NULL)) { in st_send_frame()
111 (st_gdata->list[chnl_id]->recv in st_send_frame()
114 pr_err(" proto stack %d's ->recv failed", chnl_id); in st_send_frame()
119 pr_err(" proto stack %d's ->recv null", chnl_id); in st_send_frame()
530 if (st_gdata == NULL || new_proto == NULL || new_proto->recv == NULL in st_register()
532 pr_err("gdata/new_proto/recv or reg_complete_cb not ready"); in st_register()
|