| /third_party/node/deps/v8/tools/ |
| H A D | adb-d8.py | 32 data = self.request.recv(1024);
34 data += self.request.recv(1024);
|
| /third_party/lwip/src/include/lwip/ |
| H A D | altcp.h | 76 altcp_recv_fn recv; member
97 void altcp_recv(struct altcp_pcb *conn, altcp_recv_fn recv);
|
| /third_party/node/deps/openssl/openssl/include/internal/ |
| H A D | sockets.h | 136 # define readsocket(s,b,n) recv((s),(b),(n),0)
145 # define readsocket(s,b,n) recv((s),(b),(n),0)
|
| /third_party/pulseaudio/src/pulsecore/ |
| H A D | poll-posix.c | 202 * 0-byte recv, and use ioctl(2) to detect POLLHUP. */ in pa_poll()
203 int r = recv(f->fd, NULL, 0, MSG_PEEK); in pa_poll()
210 if (recv (f->fd, data, 64, MSG_PEEK) == -1) { in pa_poll()
|
| /third_party/openssl/include/internal/ |
| H A D | sockets.h | 136 # define readsocket(s,b,n) recv((s),(b),(n),0)
145 # define readsocket(s,b,n) recv((s),(b),(n),0)
|
| /kernel/linux/linux-5.10/tools/testing/selftests/net/ |
| H A D | ipsec.c | 254 if (recv(sock, &answer, sizeof(answer), 0) < 0) { in netlink_check_answer()
255 pr_err("recv()"); in netlink_check_answer()
648 r_bytes = recv(sock[0], sock_buf, buf_len, 0); in udp_ping_send()
651 pr_err("recv()"); in udp_ping_send()
676 r_bytes = recv(sock[0], sock_buf, buf_len, 0); in udp_ping_reply()
679 pr_err("recv()"); in udp_ping_reply()
1058 if (recv(xfrm_sock, &answer, sizeof(answer), 0) < 0) { in xfrm_state_check()
1059 pr_err("recv()"); in xfrm_state_check()
1316 if (recv(xfrm_sock, &answer, sizeof(answer), 0) < 0) { in xfrm_state_allocspi()
1317 pr_err("recv()"); in xfrm_state_allocspi()
[all...] |
| /kernel/linux/linux-5.10/tools/testing/selftests/bpf/ |
| H A D | tcp_client.py | 15 try: s = sock.recv(rem)
|
| /third_party/FreeBSD/sys/dev/usb/net/ |
| H A D | usb_eth_drv.h | 91 eth_recv recv; member
|
| /third_party/ltp/testcases/kernel/containers/netns/ |
| H A D | netns_netlink.c | 69 len = recv(fd, nlh, sizeof(buffer), MSG_DONTWAIT); in child_func()
|
| /third_party/node/deps/v8/src/regexp/ |
| H A D | regexp-utils.h | 30 Isolate* isolate, Handle<JSReceiver> recv);
|
| /third_party/rust/crates/rustix/src/net/ |
| H A D | mod.rs | 25 recv, recvfrom, send, sendto, sendto_any, sendto_v4, sendto_v6, RecvFlags, SendFlags,
|
| /kernel/linux/linux-5.10/drivers/net/ethernet/ |
| H A D | ec_bhf.c | 78 __le32 recv; member
196 return le32_to_cpu(desc->header.recv) & RXHDR_NEXT_RECV_FLAG; in ec_bhf_pkt_received()
228 desc->header.recv = 0; in ec_bhf_process_rx()
387 desc->header.recv = 0; in ec_bhf_setup_rx_descs()
|
| /kernel/linux/linux-6.6/drivers/net/ethernet/ |
| H A D | ec_bhf.c | 78 __le32 recv; member
196 return le32_to_cpu(desc->header.recv) & RXHDR_NEXT_RECV_FLAG; in ec_bhf_pkt_received()
228 desc->header.recv = 0; in ec_bhf_process_rx()
387 desc->header.recv = 0; in ec_bhf_setup_rx_descs()
|
| /third_party/musl/libc-test/src/functionalext/supplement/network/network_gtest/ |
| H A D | socket_test.cpp | 283 ssize_t bytesReceived = recv(acceptFd, buf, len1, 0); in HWTEST_F()
373 * @tc.desc: This test case helps ensure that the recv function can successfully receive data from a connected
397 EXPECT_EQ(strlen(g_message) + 1, static_cast<size_t>(recv(acceptFd, buf, sizeof(buf), 0))); in HWTEST_F()
415 int err = recv(-1, nullptr, 0, 0); in HWTEST_F()
453 EXPECT_EQ(strlen(g_message) + 1, static_cast<size_t>(recv(acceptFd, buf, len1, 0))); in HWTEST_F()
|
| /kernel/linux/linux-6.6/drivers/bluetooth/ |
| H A D | btnxpuart.c | 1261 { H4_RECV_ACL, .recv = hci_recv_frame },
1262 { H4_RECV_SCO, .recv = hci_recv_frame },
1263 { H4_RECV_EVENT, .recv = hci_recv_frame },
1264 { NXP_RECV_CHIP_VER_V1, .recv = nxp_recv_chip_ver_v1 },
1265 { NXP_RECV_FW_REQ_V1, .recv = nxp_recv_fw_req_v1 },
1266 { NXP_RECV_CHIP_VER_V3, .recv = nxp_recv_chip_ver_v3 },
1267 { NXP_RECV_FW_REQ_V3, .recv = nxp_recv_fw_req_v3 },
|
| /third_party/python/Lib/multiprocessing/ |
| H A D | managers.py | 90 kind, result = c.recv()
201 request = c.recv()
245 recv = conn.recv
253 request = recv()
567 self._address = reader.recv()
822 kind, result = conn.recv()
|
| /kernel/linux/linux-5.10/drivers/infiniband/hw/cxgb4/ |
| H A D | qp.c | 766 &wqe->recv.isgl, wr->sg_list, wr->num_sge, NULL); in build_rdma_recv()
770 sizeof(wqe->recv) + wr->num_sge * sizeof(struct fw_ri_sge), 16); in build_rdma_recv()
780 &wqe->recv.isgl, wr->sg_list, wr->num_sge, NULL); in build_srq_recv()
783 *len16 = DIV_ROUND_UP(sizeof(wqe->recv) + in build_srq_recv()
1317 wqe->recv.opcode = FW_RI_RECV_WR; in c4iw_post_receive()
1318 wqe->recv.r1 = 0; in c4iw_post_receive()
1319 wqe->recv.wrid = qhp->wq.rq.pidx; in c4iw_post_receive()
1320 wqe->recv.r2[0] = 0; in c4iw_post_receive()
1321 wqe->recv.r2[1] = 0; in c4iw_post_receive()
1322 wqe->recv in c4iw_post_receive()
[all...] |
| /kernel/linux/linux-6.6/drivers/infiniband/hw/cxgb4/ |
| H A D | qp.c | 766 &wqe->recv.isgl, wr->sg_list, wr->num_sge, NULL); in build_rdma_recv()
770 sizeof(wqe->recv) + wr->num_sge * sizeof(struct fw_ri_sge), 16); in build_rdma_recv()
780 &wqe->recv.isgl, wr->sg_list, wr->num_sge, NULL); in build_srq_recv()
783 *len16 = DIV_ROUND_UP(sizeof(wqe->recv) + in build_srq_recv()
1317 wqe->recv.opcode = FW_RI_RECV_WR; in c4iw_post_receive()
1318 wqe->recv.r1 = 0; in c4iw_post_receive()
1319 wqe->recv.wrid = qhp->wq.rq.pidx; in c4iw_post_receive()
1320 wqe->recv.r2[0] = 0; in c4iw_post_receive()
1321 wqe->recv.r2[1] = 0; in c4iw_post_receive()
1322 wqe->recv in c4iw_post_receive()
[all...] |
| /third_party/curl/tests/server/ |
| H A D | socksd.c | 381 rc = recv(fd, (char *)buffer, sizeof(buffer), 0); in sockit()
383 logmsg("SOCKS identifier message missing, recv returned %zd", rc); in sockit()
428 rc = recv(fd, (char *)buffer, sizeof(buffer), 0); in sockit()
430 logmsg("SOCKS5 request or auth message missing, recv returned %zd", rc); in sockit()
487 rc = recv(fd, (char *)buffer, sizeof(buffer), 0); in sockit()
489 logmsg("SOCKS5 request message missing, recv returned %zd", rc); in sockit()
656 nread = recv(cp->clientfd, buffer, sizeof(buffer), 0); in tunnel()
669 nread = recv(cp->remotefd, buffer, sizeof(buffer), 0); in tunnel()
|
| /third_party/python/Lib/test/ |
| H A D | test_interpreters.py | 588 obj = r.recv()
600 obj = r.recv()
614 obj1 = r.recv()
624 obj2 = r2.recv()
635 obj = r.recv()
646 obj = r.recv()
706 ch.recv()
|
| /kernel/linux/linux-5.10/drivers/atm/ |
| H A D | eni.c | 190 ENI_VCC(eni_dev->rx_map[i])->recv, in dump()
326 (unsigned) readl(eni_vcc->recv+eni_vcc->descr*4)); in rx_ident_err()
515 descr = readl(eni_vcc->recv+eni_vcc->descr*4); in rx_aal0()
553 descr = readl(eni_vcc->recv+eni_vcc->descr*4); in rx_aal5()
584 length = readl(eni_vcc->recv+(((eni_vcc->descr+size-1) & in rx_aal5()
790 eni_vcc->recv = eni_alloc_mem(eni_dev,&size); in open_rx_first()
791 DPRINTK("rx at 0x%lx\n",eni_vcc->recv); in open_rx_first()
793 if (!eni_vcc->recv) return -ENOBUFS; in open_rx_first()
818 DPRINTK("loc 0x%x\n",(unsigned) (eni_vcc->recv-eni_dev->ram)/4); in open_rx_second()
829 (((eni_vcc->recv in open_rx_second()
[all...] |
| /kernel/linux/linux-6.6/drivers/atm/ |
| H A D | eni.c | 190 ENI_VCC(eni_dev->rx_map[i])->recv, in dump()
326 (unsigned) readl(eni_vcc->recv+eni_vcc->descr*4)); in rx_ident_err()
515 descr = readl(eni_vcc->recv+eni_vcc->descr*4); in rx_aal0()
553 descr = readl(eni_vcc->recv+eni_vcc->descr*4); in rx_aal5()
584 length = readl(eni_vcc->recv+(((eni_vcc->descr+size-1) & in rx_aal5()
790 eni_vcc->recv = eni_alloc_mem(eni_dev,&size); in open_rx_first()
791 DPRINTK("rx at 0x%lx\n",eni_vcc->recv); in open_rx_first()
793 if (!eni_vcc->recv) return -ENOBUFS; in open_rx_first()
818 DPRINTK("loc 0x%x\n",(unsigned) (eni_vcc->recv-eni_dev->ram)/4); in open_rx_second()
829 (((eni_vcc->recv in open_rx_second()
[all...] |
| /kernel/linux/linux-6.6/tools/testing/selftests/net/ |
| H A D | ipsec.c | 292 if (recv(sock, &answer, sizeof(answer), 0) < 0) { in netlink_check_answer()
293 pr_err("recv()"); in netlink_check_answer()
689 r_bytes = recv(sock[0], sock_buf, buf_len, 0); in udp_ping_send()
692 pr_err("recv()"); in udp_ping_send()
717 r_bytes = recv(sock[0], sock_buf, buf_len, 0); in udp_ping_reply()
720 pr_err("recv()"); in udp_ping_reply()
1046 if (recv(xfrm_sock, &answer, sizeof(answer), 0) < 0) { in xfrm_state_check()
1047 pr_err("recv()"); in xfrm_state_check()
1304 if (recv(xfrm_sock, &answer, sizeof(answer), 0) < 0) { in xfrm_state_allocspi()
1305 pr_err("recv()"); in xfrm_state_allocspi()
[all...] |
| /kernel/linux/linux-5.10/tools/testing/selftests/bpf/prog_tests/ |
| H A D | sock_fields.c | 320 err = recv(cli_fd, buf, DATA_LEN, 0); in test()
321 if (CHECK(err != DATA_LEN, "recv(cli_fd)", "err:%d errno:%d\n", in test()
327 err = recv(accept_fd, buf, 1, 0); in test()
328 if (CHECK(err, "recv(accept_fd) for fin", "err:%d errno:%d\n", in test()
332 err = recv(cli_fd, buf, 1, 0); in test()
333 if (CHECK(err, "recv(cli_fd) for fin", "err:%d errno:%d\n", in test()
|
| /kernel/linux/linux-5.10/drivers/isdn/mISDN/ |
| H A D | hwchannel.c | 23 err = dch->dev.D.recv(dch->dev.D.peer, skb); in dchannel_bh()
47 err = bch->ch.recv(bch->ch.peer, skb); in bchannel_bh()
395 if (!ch->recv(ch->peer, skb)) in queue_ch_frame()
|