Home
last modified time | relevance | path

Searched refs:recv (Results 51 - 75 of 671) sorted by relevance

12345678910>>...27

/third_party/python/Modules/
H A D_xxsubinterpretersmodule.c551 _channelend *recv; member
564 ends->recv = NULL; in _channelends_new()
575 _channelend_free_all(ends->recv); in _channelends_clear()
576 ends->recv = NULL; in _channelends_clear()
601 ends->recv = end; in _channelends_add()
620 _channelend *end = _channelend_find(send ? ends->send : ends->recv, in _channelends_associate()
642 if (ends->send == NULL && ends->recv == NULL) { in _channelends_is_open()
676 if (which <= 0) { // recv/both in _channelends_close_interpreter()
677 end = _channelend_find(ends->recv, interp, &prev); in _channelends_close_interpreter()
702 // Ensure all the "recv" in _channelends_close_all()
1367 _channel_drop(_channels *channels, int64_t id, int send, int recv) _channel_drop() argument
1486 int recv = -1; channelid_new() local
2463 int recv = 0; channel_close() local
2511 int recv = 0; channel_release() local
[all...]
/third_party/node/test/addons/make-callback-domain-warning/
H A Dbinding.cc19 Local<Object> recv = args[0].As<Object>(); in MakeCallback() local
22 node::MakeCallback(isolate, recv, method, 0, nullptr, in MakeCallback()
/third_party/node/test/addons/make-callback-recurse/
H A Dbinding.cc19 Local<Object> recv = args[0].As<Object>(); in MakeCallback() local
22 node::MakeCallback(isolate, recv, method, 0, nullptr, in MakeCallback()
/kernel/linux/linux-5.10/drivers/soc/ixp4xx/
H A Dixp4xx-npe.c446 u32 *recv = msg; in npe_recv_message() local
453 recv[cnt++] = __raw_readl(&npe->regs->in_out_fifo); in npe_recv_message()
464 debug_msg(npe, "Received [%08X]\n", recv[0]); in npe_recv_message()
467 debug_msg(npe, "Received [%08X:%08X]\n", recv[0], recv[1]); in npe_recv_message()
485 u32 *send = msg, recv[2]; in npe_send_recv_message() local
489 if ((result = npe_recv_message(npe, recv, what)) != 0) in npe_send_recv_message()
492 if ((recv[0] != send[0]) || (recv[1] != send[1])) { in npe_send_recv_message()
/kernel/linux/linux-6.6/drivers/soc/ixp4xx/
H A Dixp4xx-npe.c453 u32 *recv = msg; in npe_recv_message() local
460 recv[cnt++] = __raw_readl(&npe->regs->in_out_fifo); in npe_recv_message()
471 debug_msg(npe, "Received [%08X]\n", recv[0]); in npe_recv_message()
474 debug_msg(npe, "Received [%08X:%08X]\n", recv[0], recv[1]); in npe_recv_message()
492 u32 *send = msg, recv[2]; in npe_send_recv_message() local
496 if ((result = npe_recv_message(npe, recv, what)) != 0) in npe_send_recv_message()
499 if ((recv[0] != send[0]) || (recv[1] != send[1])) { in npe_send_recv_message()
/kernel/linux/linux-5.10/drivers/bluetooth/
H A Dh4_recv.h17 int (*recv)(struct hci_dev *hdev, struct sk_buff *skb); member
135 (&pkts[i])->recv(hdev, skb); in h4_recv_buf()
140 (&pkts[i])->recv(hdev, skb); in h4_recv_buf()
H A Dhci_ath.c185 { H4_RECV_ACL, .recv = hci_recv_frame },
186 { H4_RECV_SCO, .recv = hci_recv_frame },
187 { H4_RECV_EVENT, .recv = hci_recv_frame },
255 .recv = ath_recv,
H A Dhci_ll.c415 { H4_RECV_ACL, .recv = hci_recv_frame },
416 { H4_RECV_SCO, .recv = hci_recv_frame },
417 { H4_RECV_EVENT, .recv = hci_recv_frame },
418 { LL_RECV_SLEEP_IND, .recv = ll_recv_frame },
419 { LL_RECV_SLEEP_ACK, .recv = ll_recv_frame },
420 { LL_RECV_WAKE_IND, .recv = ll_recv_frame },
421 { LL_RECV_WAKE_ACK, .recv = ll_recv_frame },
803 .recv = ll_recv,
/kernel/linux/linux-6.6/drivers/bluetooth/
H A Dh4_recv.h17 int (*recv)(struct hci_dev *hdev, struct sk_buff *skb); member
135 (&pkts[i])->recv(hdev, skb); in h4_recv_buf()
140 (&pkts[i])->recv(hdev, skb); in h4_recv_buf()
H A Dhci_ath.c185 { H4_RECV_ACL, .recv = hci_recv_frame },
186 { H4_RECV_SCO, .recv = hci_recv_frame },
187 { H4_RECV_EVENT, .recv = hci_recv_frame },
255 .recv = ath_recv,
H A Dhci_mrvl.c245 { H4_RECV_ACL, .recv = hci_recv_frame },
246 { H4_RECV_SCO, .recv = hci_recv_frame },
247 { H4_RECV_EVENT, .recv = hci_recv_frame },
248 { HCI_RECV_FW_REQ, .recv = mrvl_recv_fw_req },
249 { HCI_RECV_CHIP_VER, .recv = mrvl_recv_chip_ver },
443 .recv = mrvl_recv,
457 .recv = mrvl_recv,
H A Dhci_ll.c415 { H4_RECV_ACL, .recv = hci_recv_frame },
416 { H4_RECV_SCO, .recv = hci_recv_frame },
417 { H4_RECV_EVENT, .recv = hci_recv_frame },
418 { LL_RECV_SLEEP_IND, .recv = ll_recv_frame },
419 { LL_RECV_SLEEP_ACK, .recv = ll_recv_frame },
420 { LL_RECV_WAKE_IND, .recv = ll_recv_frame },
421 { LL_RECV_WAKE_ACK, .recv = ll_recv_frame },
804 .recv = ll_recv,
/third_party/rust/crates/rustix/tests/net/
H A Dv6.rs8 accept, bind_v6, connect_v6, getsockname, listen, recv, send, socket, AddressFamily, Ipv6Addr,
43 let nread = recv(&data_socket, &mut buffer, RecvFlags::empty()).unwrap(); in server()
72 let nread = recv(&data_socket, &mut buffer, RecvFlags::empty()).unwrap(); in client()
H A Dv4.rs8 accept, bind_v4, connect_v4, getsockname, listen, recv, send, socket, AddressFamily, Ipv4Addr,
39 let nread = recv(&data_socket, &mut buffer, RecvFlags::empty()).unwrap(); in server()
63 let nread = recv(&data_socket, &mut buffer, RecvFlags::empty()).unwrap(); in client()
/kernel/linux/linux-6.6/tools/testing/selftests/bpf/prog_tests/
H A Dassign_reuse.c48 ret = recv(fd_sv, buff, sizeof(buff), 0); in echo_test_udp()
56 ASSERT_EQ(recv(fd_cl, buff, sizeof(buff), 0), 1, "recv_client"); in echo_test_udp()
74 ASSERT_EQ(recv(fd_sv_cl, buff, sizeof(buff), 0), 1, "recv_server"); in echo_test_tcp()
76 ASSERT_EQ(recv(fd_cl, buff, sizeof(buff), 0), 1, "recv_client"); in echo_test_tcp()
/kernel/linux/linux-5.10/drivers/char/tpm/st33zp24/
H A Dst33zp24.c72 tpm_dev->ops->recv(tpm_dev->phy_id, TPM_INT_STATUS, &interrupt, 1); in clear_interruption()
101 tpm_dev->ops->recv(tpm_dev->phy_id, TPM_STS, &data, 1); in st33zp24_status()
116 status = tpm_dev->ops->recv(tpm_dev->phy_id, TPM_ACCESS, &data, 1); in check_locality()
186 status = tpm_dev->ops->recv(tpm_dev->phy_id, TPM_STS + 1, in get_burstcount()
192 status = tpm_dev->ops->recv(tpm_dev->phy_id, TPM_STS + 2, in get_burstcount()
318 ret = tpm_dev->ops->recv(tpm_dev->phy_id, TPM_DATA_FIFO, in recv_data()
495 .recv = st33zp24_recv,
/kernel/linux/linux-6.6/drivers/char/tpm/st33zp24/
H A Dst33zp24.c71 tpm_dev->ops->recv(tpm_dev->phy_id, TPM_INT_STATUS, &interrupt, 1); in clear_interruption()
96 tpm_dev->ops->recv(tpm_dev->phy_id, TPM_STS, &data, 1); in st33zp24_status()
109 status = tpm_dev->ops->recv(tpm_dev->phy_id, TPM_ACCESS, &data, 1); in check_locality()
168 status = tpm_dev->ops->recv(tpm_dev->phy_id, TPM_STS + 1, in get_burstcount()
174 status = tpm_dev->ops->recv(tpm_dev->phy_id, TPM_STS + 2, in get_burstcount()
277 ret = tpm_dev->ops->recv(tpm_dev->phy_id, TPM_DATA_FIFO, in recv_data()
428 .recv = st33zp24_recv,
/kernel/linux/linux-6.6/tools/testing/selftests/net/af_unix/
H A Dtest_unix_oob.c87 if (recv(fd, c, sizeof(*c), MSG_OOB) < 0) { in read_oob()
244 len = recv(pfd, buf, 1024, MSG_PEEK); in main()
268 len = recv(pfd, buf, 1024, MSG_PEEK); in main()
369 len = recv(pfd, buf, 1024, MSG_PEEK); in main()
401 len = recv(pfd, buf, 1024, MSG_PEEK); in main()
/kernel/linux/linux-5.10/drivers/isdn/mISDN/
H A Dstack.c389 dev->teimgr->recv = mISDN_queue_message; in create_stack()
392 dev->D.recv = l1_receive; in create_stack()
397 newst->own.recv = mISDN_queue_message; in create_stack()
434 ch->recv = mISDN_queue_message; in connect_layer1()
475 ch->recv = rq.ch->send; in connect_Bstack()
477 rq.ch->recv = ch->send; in connect_Bstack()
490 ch->recv = rq2.ch->send; in connect_Bstack()
500 rq2.ch->recv = rq.ch->send; in connect_Bstack()
502 rq.ch->recv = rq2.ch->send; in connect_Bstack()
533 ch->recv in create_l2entity()
[all...]
/kernel/linux/linux-6.6/drivers/isdn/mISDN/
H A Dstack.c389 dev->teimgr->recv = mISDN_queue_message; in create_stack()
392 dev->D.recv = l1_receive; in create_stack()
397 newst->own.recv = mISDN_queue_message; in create_stack()
434 ch->recv = mISDN_queue_message; in connect_layer1()
475 ch->recv = rq.ch->send; in connect_Bstack()
477 rq.ch->recv = ch->send; in connect_Bstack()
490 ch->recv = rq2.ch->send; in connect_Bstack()
500 rq2.ch->recv = rq.ch->send; in connect_Bstack()
502 rq.ch->recv = rq2.ch->send; in connect_Bstack()
533 ch->recv in create_l2entity()
[all...]
/kernel/linux/linux-6.6/tools/testing/vsock/
H A Dvsock_test.c318 res = recv(fd, buf_peek, sizeof(buf_peek), MSG_PEEK | MSG_DONTWAIT); in test_msg_peek_server()
320 fprintf(stderr, "expected recv(2) failure, got %zi\n", res); in test_msg_peek_server()
332 res = recv(fd, buf_half, sizeof(buf_half), MSG_PEEK); in test_msg_peek_server()
334 fprintf(stderr, "recv(2) + MSG_PEEK, expected %zu, got %zi\n", in test_msg_peek_server()
340 res = recv(fd, buf_peek, sizeof(buf_peek), MSG_PEEK); in test_msg_peek_server()
342 fprintf(stderr, "recv(2) + MSG_PEEK, expected %zu, got %zi\n", in test_msg_peek_server()
358 res = recv(fd, buf_half, sizeof(buf_half), MSG_PEEK | in test_msg_peek_server()
362 "recv(2) + MSG_PEEK | MSG_TRUNC, exp %zu, got %zi\n", in test_msg_peek_server()
368 res = recv(fd, buf_normal, sizeof(buf_normal), 0); in test_msg_peek_server()
370 fprintf(stderr, "recv( in test_msg_peek_server()
[all...]
/third_party/node/test/parallel/
H A Dtest-child-process-fork-exec-path.js56 child.on('message', common.mustCall(function(recv) {
57 assert.deepStrictEqual(recv, msg);
/kernel/linux/linux-5.10/tools/testing/selftests/pidfd/
H A Dpidfd_getfd_test.c62 * This blocking recv enables the parent to message the child. in __child()
68 while ((ret = recv(sk, &buf, sizeof(buf), 0)) > 0) { in __child()
162 ret = recv(sk_pair[0], &self->remote_fd, sizeof(self->remote_fd), 0); in FIXTURE_SETUP()
190 ASSERT_EQ(1, recv(self->sk, &c, 1, 0)); in TEST_F()
/kernel/linux/linux-6.6/tools/testing/selftests/pidfd/
H A Dpidfd_getfd_test.c62 * This blocking recv enables the parent to message the child. in __child()
68 while ((ret = recv(sk, &buf, sizeof(buf), 0)) > 0) { in __child()
162 ret = recv(sk_pair[0], &self->remote_fd, sizeof(self->remote_fd), 0); in FIXTURE_SETUP()
190 ASSERT_EQ(1, recv(self->sk, &c, 1, 0)); in TEST_F()
/third_party/python/Lib/test/support/
H A Dinterpreters.py101 """Return (recv, send) for a new cross-interpreter channel.
106 recv, send = RecvChannel(cid), SendChannel(cid)
107 return recv, send
111 """Return a list of (recv, send) for all open channels."""
149 def recv(self, *, _sentinel=object(), _delay=10 / 1000): # 10 milliseconds member in RecvChannel
166 is the same as recv().

Completed in 15 milliseconds

12345678910>>...27