| /third_party/wpa_supplicant/wpa_supplicant-2.9/src/drivers/ |
| H A D | driver_macsec_qca.c | 179 len = recv(sock, buf, sizeof(buf), 0); in macsec_qca_handle_read()
181 wpa_printf(MSG_ERROR, "macsec_qca: recv: %s", strerror(errno)); in macsec_qca_handle_read()
|
| H A D | driver_privsep.c | 83 res = recv(drv->cmd_socket, reply, *reply_len, 0); in wpa_priv_cmd()
85 wpa_printf(MSG_ERROR, "recv: %s", in wpa_priv_cmd()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/drivers/ |
| H A D | driver_macsec_qca.c | 179 len = recv(sock, buf, sizeof(buf), 0); in macsec_qca_handle_read()
181 wpa_printf(MSG_ERROR, "macsec_qca: recv: %s", strerror(errno)); in macsec_qca_handle_read()
|
| H A D | driver_privsep.c | 83 res = recv(drv->cmd_socket, reply, *reply_len, 0); in wpa_priv_cmd()
85 wpa_printf(MSG_ERROR, "recv: %s", in wpa_priv_cmd()
|
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/kvdb/ |
| H A D | kvdb_service_impl.cpp | 979 auto recv = DeviceMatrix::GetInstance().GetRecvLevel(uuids[0], in DoSyncInOrder() local
983 std::to_string(info.syncId), DATA_TYPE, meta.dataType, WATER_VERSION, recv.second); in DoSyncInOrder()
|
| /kernel/linux/linux-5.10/drivers/scsi/libfc/ |
| H A D | fc_lport.c | 931 .recv = fc_lport_recv_els_req,
963 prov->recv(lport, fp); in fc_lport_recv()
|
| /kernel/linux/linux-5.10/drivers/nvme/target/ |
| H A D | tcp.c | 110 /* recv state */
263 pr_err("queue %d: header digest error: recv %#x expected %#x\n", in nvmet_tcp_verify_hdgst()
1078 recv: in nvmet_tcp_try_recv_pdu()
1106 goto recv; in nvmet_tcp_try_recv_pdu()
1183 pr_err("queue %d: cmd %d pdu (%d) data digest error: recv %#x expected %#x\n", in nvmet_tcp_try_recv_ddgst()
|
| /kernel/linux/linux-6.6/drivers/nvme/target/ |
| H A D | tcp.c | 146 /* recv state */
301 pr_err("queue %d: header digest error: recv %#x expected %#x\n", in nvmet_tcp_verify_hdgst()
1120 recv: in nvmet_tcp_try_recv_pdu()
1148 goto recv; in nvmet_tcp_try_recv_pdu()
1224 pr_err("queue %d: cmd %d pdu (%d) data digest error: recv %#x expected %#x\n", in nvmet_tcp_try_recv_ddgst()
|
| /kernel/linux/linux-6.6/drivers/scsi/libfc/ |
| H A D | fc_lport.c | 934 .recv = fc_lport_recv_els_req,
966 prov->recv(lport, fp); in fc_lport_recv()
|
| /third_party/node/src/crypto/ |
| H A D | crypto_keys.cc | 1382 Local<Value> recv = Undefined(env->isolate()); in CreateNativeKeyObjectClass()
1385 env->context(), recv, 1, &ctor).ToLocal(&ret_v)) { in CreateNativeKeyObjectClass()
|
| /third_party/node/deps/v8/src/debug/ |
| H A D | debug-interface.cc | 1012 Local<Function> function, Local<Value> recv, in CallFunctionOn()
1018 auto recv_obj = Utils::OpenHandle(*recv); in CallFunctionOn()
1011 CallFunctionOn(Local<Context> context, Local<Function> function, Local<Value> recv, int argc, Local<Value> argv[], bool throw_on_side_effect) CallFunctionOn() argument
|
| /third_party/rust/crates/nix/src/sys/socket/ |
| H A D | mod.rs | 290 /// Flags for send/recv and their relatives
298 /// [`recv()`](fn.recv.html)
1878 let recv = super::recvmmsg(rsock, &mut data, recv_iovs.iter(), flags, Some(t))?; in test_recvmm2()
1880 for rmsg in recv { in test_recvmm2()
2200 /// [Further reading](https://pubs.opengroup.org/onlinepubs/9699919799/functions/recv.html)
2201 pub fn recv(sockfd: RawFd, buf: &mut [u8], flags: MsgFlags) -> Result<usize> { in recv() functions
2203 let ret = libc::recv( in recv()
|
| /third_party/wpa_supplicant/wpa_supplicant-2.9_standard/src/common/ |
| H A D | dpp_tcp.c | 1404 res = recv(sd, &conn->msg_len[conn->msg_len_octets], in dpp_controller_rx()
1407 wpa_printf(MSG_DEBUG, "DPP: recv failed: %s", in dpp_controller_rx()
1452 res = recv(sd, wpabuf_put(conn->msg, 0), wpabuf_tailroom(conn->msg), 0); in dpp_controller_rx()
1454 wpa_printf(MSG_DEBUG, "DPP: recv failed: %s", strerror(errno)); in dpp_controller_rx()
|
| /third_party/python/Lib/test/test_asyncio/ |
| H A D | test_events.py | 403 data = r.recv(1024)
440 read = r.recv(len(data) * 2)
753 response = csock.recv(99)
862 # recv()/send() on the serving socket
925 # recv()/send() on the serving socket
989 # recv()/send() on the serving socket
1020 # recv()/send() on the serving socket
|
| /third_party/python/Lib/test/ |
| H A D | test_logging.py | 1778 chunk = conn.recv(4)
1782 chunk = conn.recv(slen)
1784 chunk = chunk + conn.recv(slen - len(chunk))
4619 results = parent_conn.recv()
|
| /kernel/linux/linux-5.10/net/bluetooth/ |
| H A D | l2cap_core.c | 615 /* Raw socket can send/recv signalling messages only */ in __l2cap_chan_add()
3007 BT_DBG("recv fbit tx_state 0x2.2%x", chan->tx_state); in l2cap_tx_state_wait_f()
3081 if (chan->ops->recv(chan, nskb)) in l2cap_raw_recv()
6634 err = chan->ops->recv(chan, skb); in l2cap_reassemble_sdu()
6687 err = chan->ops->recv(chan, chan->sdu); in l2cap_reassemble_sdu()
6977 * chan->ops->recv == l2cap_sock_recv_cb in l2cap_rx_state_recv()
7381 * chan->ops->recv == l2cap_sock_recv_cb in l2cap_stream_rx()
7548 /* Wait recv to confirm reception before updating the credits */ in l2cap_ecred_recv()
7549 err = chan->ops->recv(chan, skb); in l2cap_ecred_recv()
7706 /* If socket recv buffer in l2cap_data_channel()
[all...] |
| /kernel/linux/linux-6.6/net/bluetooth/ |
| H A D | l2cap_core.c | 592 /* Raw socket can send/recv signalling messages only */ in __l2cap_chan_add()
2831 BT_DBG("recv fbit tx_state 0x2.2%x", chan->tx_state); in l2cap_tx_state_wait_f()
2905 if (chan->ops->recv(chan, nskb)) in l2cap_raw_recv()
5636 err = chan->ops->recv(chan, skb); in l2cap_reassemble_sdu()
5689 err = chan->ops->recv(chan, chan->sdu); in l2cap_reassemble_sdu()
5979 * chan->ops->recv == l2cap_sock_recv_cb in l2cap_rx_state_recv()
6375 * chan->ops->recv == l2cap_sock_recv_cb in l2cap_stream_rx()
6542 /* Wait recv to confirm reception before updating the credits */ in l2cap_ecred_recv()
6543 err = chan->ops->recv(chan, skb); in l2cap_ecred_recv()
6689 /* If socket recv buffer in l2cap_data_channel()
[all...] |
| /kernel/linux/linux-5.10/drivers/atm/ |
| H A D | fore200e.c | 2357 c = (int) fore200e->bus->read(&monitor->soft_uart.recv); in fore200e_monitor_getc()
2361 fore200e->bus->write(FORE200E_CP_MONITOR_UART_FREE, &monitor->soft_uart.recv); in fore200e_monitor_getc()
|
| /kernel/linux/linux-5.10/drivers/isdn/mISDN/ |
| H A D | layer2.c | 183 ret = l2->ch.recv(l2->ch.peer, skb); in l2down_skb()
299 l2->ch.st->own.recv(&l2->ch.st->own, skb); in l2_timeout()
|
| /kernel/linux/linux-5.10/drivers/net/ethernet/aquantia/atlantic/macsec/ |
| H A D | macsec_api.c | 1553 packed_record[5] |= (rec->recv & 0x1) << 2; in set_egress_sc_record()
1604 rec->recv = (packed_record[5] >> 2) & 0x1; in get_egress_sc_record()
|
| /kernel/linux/linux-6.6/drivers/net/ethernet/aquantia/atlantic/macsec/ |
| H A D | macsec_api.c | 1553 packed_record[5] |= (rec->recv & 0x1) << 2; in set_egress_sc_record()
1604 rec->recv = (packed_record[5] >> 2) & 0x1; in get_egress_sc_record()
|
| /kernel/linux/linux-6.6/drivers/atm/ |
| H A D | fore200e.c | 2355 c = (int) fore200e->bus->read(&monitor->soft_uart.recv); in fore200e_monitor_getc()
2359 fore200e->bus->write(FORE200E_CP_MONITOR_UART_FREE, &monitor->soft_uart.recv); in fore200e_monitor_getc()
|
| /kernel/linux/linux-6.6/drivers/isdn/mISDN/ |
| H A D | layer2.c | 183 ret = l2->ch.recv(l2->ch.peer, skb); in l2down_skb()
299 l2->ch.st->own.recv(&l2->ch.st->own, skb); in l2_timeout()
|
| /kernel/linux/linux-6.6/tools/testing/selftests/net/mptcp/ |
| H A D | mptcp_join.sh | 1876 cnt1=$(ss -N $ns1 -ti state established state syn-sent state syn-recv |
1878 cnt2=$(ss -N $ns2 -ti state established state syn-sent state syn-recv |
|
| /third_party/curl/lib/vssh/ |
| H A D | libssh.c | 1732 out writableable as the underlying libssh recv function will deal in myssh_statemach_act()
1900 out writableable as the underlying libssh recv function will deal in myssh_statemach_act()
2178 conn->recv[FIRSTSOCKET] = scp_recv; in myssh_connect()
2182 conn->recv[FIRSTSOCKET] = sftp_recv; in myssh_connect()
|