/third_party/node/deps/v8/include/v8-include/ |
H A D | v8-function.h | 56 Local<Value> recv, int argc,
|
/third_party/python/Lib/multiprocessing/dummy/ |
H A D | connection.py | 57 self.recv = self.recv_bytes = _in.get
|
/third_party/skia/third_party/externals/swiftshader/src/Common/ |
H A D | Socket.cpp | 88 return recv(socket, buffer, length, 0); in receive()
|
/third_party/skia/third_party/externals/swiftshader/src/System/ |
H A D | Socket.cpp | 89 return recv(socket, buffer, length, 0); in receive()
|
/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/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...] |
/base/security/crypto_framework/frameworks/js/napi/crypto/src/ |
H A D | napi_key_agreement.cpp | 177 napi_value recv = nullptr; in ReturnCallbackResult() local 179 napi_get_undefined(env, &recv); in ReturnCallbackResult() 180 napi_call_function(env, recv, func, ARGS_SIZE_TWO, params, &callFuncRet); in ReturnCallbackResult()
|
H A D | napi_rand.cpp | 96 napi_value recv = nullptr; in ReturnCallbackResult() local 98 napi_get_undefined(env, &recv); in ReturnCallbackResult() 99 napi_call_function(env, recv, func, ARGS_SIZE_TWO, params, &callFuncRet); in ReturnCallbackResult()
|
/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()
|
/kernel/linux/linux-5.10/drivers/net/ethernet/mellanox/mlx5/core/en_accel/ |
H A D | tls_rxtx.c | 70 struct recv_metadata_content recv; member 350 memcpy(&seq, &mdata->content.recv.sync_seq, sizeof(seq)); in tls_update_resync_sn() 365 switch (mdata->content.recv.syndrome) { in mlx5e_tls_handle_rx_skb_metadata()
|
/kernel/linux/linux-6.6/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()
|
/kernel/linux/linux-6.6/tools/testing/selftests/net/ |
H A D | ioam6_parser.c | 637 recv: in main() 638 size = recv(fd, buffer, sizeof(buffer), 0); in main() 646 goto recv; in main()
|
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-6.6/tools/testing/selftests/bpf/prog_tests/ |
H A D | sockmap_basic.c | 405 n = recv(c1, &b, 1, SOCK_NONBLOCK); in test_sockmap_skb_verdict_shutdown() 509 recvd = recv(c1, rcv, sizeof(rcv), MSG_PEEK); in test_sockmap_skb_verdict_peek() 510 ASSERT_EQ(recvd, sizeof(rcv), "recv(c1)"); in test_sockmap_skb_verdict_peek() 514 recvd = recv(c1, rcv, sizeof(rcv), 0); in test_sockmap_skb_verdict_peek() 515 ASSERT_EQ(recvd, sizeof(rcv), "recv(p0)"); in test_sockmap_skb_verdict_peek()
|
H A D | sock_fields.c | 319 err = recv(cli_fd, buf, DATA_LEN, 0); in test() 320 if (CHECK(err != DATA_LEN, "recv(cli_fd)", "err:%d errno:%d\n", in test() 326 err = recv(accept_fd, buf, 1, 0); in test() 327 if (CHECK(err, "recv(accept_fd) for fin", "err:%d errno:%d\n", in test() 331 err = recv(cli_fd, buf, 1, 0); in test() 332 if (CHECK(err, "recv(cli_fd) for fin", "err:%d errno:%d\n", in test()
|
/third_party/ltp/testcases/network/lib6/ |
H A D | asapi_01.c | 176 total = cc = recv(sd, packet, sizeof(struct tprot), 0); in recvtprot() 184 cc = recv(sd, &packet[total], expected - total, 0); in recvtprot() 421 cc = recv(sd, packet, sizeof(packet), 0); in csum_test()
|
/third_party/lwip/src/core/ |
H A D | altcp.c | 237 altcp_recv(struct altcp_pcb *conn, altcp_recv_fn recv) in altcp_recv() argument 240 conn->recv = recv; in altcp_recv()
|
/third_party/node/deps/v8/src/debug/wasm/gdb-server/ |
H A D | target.cc | 164 Packet recv, reply; in ProcessCommands() local 166 if (!session_->GetPacket(&recv)) { in ProcessCommands() 171 ProcessPacketResult result = ProcessPacket(&recv, &reply); in ProcessCommands()
|
/third_party/pulseaudio/src/pulsecore/ |
H A D | poll-win32.c | 268 r = recv (h, data, sizeof (data), MSG_PEEK); in windows_compute_revents_socket() 309 0-byte recv, and use ioctl(2) to detect POLLHUP. */ in compute_revents() 310 r = recv (fd, NULL, 0, MSG_PEEK); in compute_revents() 316 r = recv (fd, data, sizeof (data), MSG_PEEK); in compute_revents() 332 /* some systems can't use recv() on non-socket, including HP NonStop */ in compute_revents() 612 to distinguish FD_READ and FD_ACCEPT; this saves a recv later. */ in pa_poll()
|
/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...] |
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/ |
H A D | spunge_core.c | 293 inst->rateControl.recv.maxRate = g_resource.flowControl.maxRecvRate; in SpungeInstSendInit() 1024 recv rate, then allow to grow */ in FillpServerRecvRateAdjustment() 1039 if (calcRecvTotalRate > inst->rateControl.recv.maxRate) { in FillpServerRecvRateAdjustment() 1040 calcRecvTotalRate = inst->rateControl.recv.maxRate; in FillpServerRecvRateAdjustment() 1048 *connRecvCalLimit = inst->rateControl.recv.maxRate; in FillpServerRecvRateAdjustment() 1076 recv rate, then allow to grow */ in FillpServerSendRateAdjustment() 1160 pcb->rateControl.recv.curMaxRateLimitation = connRecvCalLimit; in FillpCalculateFairness() 1161 pcb->fpcb.recv.oppositeSetRate = pcb->rateControl.recv.curMaxRateLimitation; in FillpCalculateFairness() 1195 nackList = &(pcb->fpcb.recv in FillpCheckPcbNackListToSend() [all...] |