Home
last modified time | relevance | path

Searched refs:recv (Results 26 - 50 of 751) sorted by relevance

12345678910>>...31

/kernel/linux/linux-6.6/drivers/bluetooth/
H A Dhci_h4.c101 { H4_RECV_ACL, .recv = hci_recv_frame },
102 { H4_RECV_SCO, .recv = hci_recv_frame },
103 { H4_RECV_EVENT, .recv = hci_recv_frame },
104 { H4_RECV_ISO, .recv = hci_recv_frame },
138 .recv = h4_recv,
259 (&pkts[i])->recv(hdev, skb); in h4_recv_buf()
267 (&pkts[i])->recv(hdev, skb); in h4_recv_buf()
/third_party/node/test/parallel/
H A Dtest-event-emitter-get-max-listeners.js17 const recv = {};
18 EventEmitter.prototype.on.call(recv, 'event', () => {});
19 EventEmitter.prototype.on.call(recv, 'event', () => {});
H A Dtest-socket-writes-before-passed-to-tls-socket.js12 const recv = [];
14 recv.push(chunk);
19 const clientHelloFstByte = Buffer.concat(recv).subarray(HEAD.length, HEAD.length + 1);
H A Dtest-double-tls-server.js61 const recv = [];
65 recv.push(chunk);
68 const serverHelloFstByte = Buffer.concat(recv).subarray(serverReplaySize, serverReplaySize + 1);
H A Dtest-tls-socket-default-options.js46 let recv = '';
48 conn.on('data', (data) => recv += data);
52 assert.strictEqual(recv, 'hello');
/kernel/linux/linux-5.10/net/sunrpc/
H A Dxprtsock.c472 if (!transport->recv.copied) { in xs_read_header()
473 if (buf->head[0].iov_len >= transport->recv.offset) in xs_read_header()
475 &transport->recv.xid, in xs_read_header()
476 transport->recv.offset); in xs_read_header()
477 transport->recv.copied = transport->recv.offset; in xs_read_header()
484 return transport->recv.fraghdr & cpu_to_be32(RPC_LAST_STREAM_FRAGMENT); in xs_read_stream_request_done()
505 want = transport->recv.len - transport->recv.offset; in xs_read_stream_request()
508 transport->recv in xs_read_stream_request()
[all...]
/third_party/toybox/porting/liteos_a/toys/net/
H A Dping.c49 unsigned long sent, recv, fugit, min, max;
56 lostret = TT.sent > TT.recv ? ((TT.sent-TT.recv)*100)/(TT.sent?TT.sent:1) : 0; in summary()
60 TT.sent, TT.recv, lostret); in summary()
62 TT.min, TT.max, TT.fugit/(TT.recv?TT.recv:1)); in summary()
202 if (0>=(waitms = tW-tnow) || !(TT.sent-TT.recv)) break; in ping_main()
241 TT.recv++; in ping_main()
/test/testfwk/arkxtest/uitest/test/
H A Dextension_test.cpp180 // if recv arg is null, should fail in TEST_F()
201 auto recv = ReceiveBuffer {.data = buf, .capacity = bufSize, .size = &outSize}; in TEST_F() local
202 ASSERT_EQ(RETCODE_SUCCESS, portCapture.getUiTestVersion(recv)); in TEST_F()
219 auto recv = ReceiveBuffer {.data = buf, .capacity = bufSize, .size = &outSize}; in TEST_F() local
222 ASSERT_EQ(RETCODE_FAIL, portCapture.getAndClearLastError(nullptr, recv)); in TEST_F()
225 ASSERT_EQ(RETCODE_SUCCESS, portCapture.getAndClearLastError(&errCode, recv)); in TEST_F()
230 ASSERT_EQ(RETCODE_SUCCESS, portCapture.getAndClearLastError(&errCode, recv)); in TEST_F()
270 ReceiveBuffer recv; member
316 auto ret = llfs.callThroughMessage(callIn, suite.recv, suite.isFatalRecv); in TEST_F()
318 if (suite.recv in TEST_F()
[all...]
/third_party/node/test/node-api/test_worker_terminate/
H A Dtest_worker_terminate.c8 napi_value recv; in Test() local
12 NODE_API_CALL(env, napi_get_cb_info(env, info, &argc, argv, &recv, NULL)); in Test()
20 status = napi_call_function(env, recv, argv[0], 0, NULL, NULL); in Test()
/kernel/linux/linux-5.10/drivers/gpu/drm/nouveau/nvkm/subdev/pmu/
H A Dbase.c57 struct nvkm_pmu *pmu = container_of(work, typeof(*pmu), recv.work); in nvkm_pmu_recv()
58 return pmu->func->recv(pmu); in nvkm_pmu_recv()
87 flush_work(&pmu->recv.work); in nvkm_pmu_fini()
176 INIT_WORK(&pmu->recv.work, nvkm_pmu_recv); in nvkm_pmu_ctor()
177 init_waitqueue_head(&pmu->recv.wait); in nvkm_pmu_ctor()
/kernel/linux/linux-5.10/drivers/isdn/hardware/mISDN/
H A Dnetjet.c77 struct tiger_dma recv; member
259 card->recv.dmacur = inl(card->base + NJ_DMA_WRITE_ADR); in mode_tiger()
261 card->recv.idx = (card->recv.dmacur - card->recv.dmastart) >> 2; in mode_tiger()
268 card->recv.idx); in mode_tiger()
318 pr_info("%s: no B%d recv buffer\n", card->name, i + 1); in inittiger()
342 card->recv.start = card->dma_p + (NJ_DMA_SIZE / 2); in inittiger()
343 card->recv.dmastart = (u32)card->dma + (NJ_DMA_SIZE / 2); in inittiger()
344 card->recv in inittiger()
[all...]
/kernel/linux/linux-6.6/drivers/isdn/hardware/mISDN/
H A Dnetjet.c77 struct tiger_dma recv; member
259 card->recv.dmacur = inl(card->base + NJ_DMA_WRITE_ADR); in mode_tiger()
261 card->recv.idx = (card->recv.dmacur - card->recv.dmastart) >> 2; in mode_tiger()
268 card->recv.idx); in mode_tiger()
318 pr_info("%s: no B%d recv buffer\n", card->name, i + 1); in inittiger()
342 card->recv.start = card->dma_p + (NJ_DMA_SIZE / 2); in inittiger()
343 card->recv.dmastart = (u32)card->dma + (NJ_DMA_SIZE / 2); in inittiger()
344 card->recv in inittiger()
[all...]
/third_party/node/test/node-api/test_async_context/
H A Dtest.js42 const recv = {};
43 makeCallback(resourceWrap, recv, function callback() {
49 assert.strictEqual(this, recv);
/third_party/node/test/node-api/test_make_callback_recurse/
H A Dbinding.c10 napi_value recv = args[0]; in MakeCallback() local
14 recv, func, 0 /* argc */, NULL /* argv */, NULL /* result */); in MakeCallback()
29 return recv; in MakeCallback()
/third_party/node/test/addons/make-callback/
H A Dbinding.cc13 auto recv = args[0].As<v8::Object>(); in MakeCallback() local
22 node::MakeCallback(isolate, recv, method, argv.size(), argv.data(), in MakeCallback()
27 node::MakeCallback(isolate, recv, method, argv.size(), argv.data(), in MakeCallback()
/kernel/linux/linux-6.6/drivers/mailbox/
H A Darm_mhuv2.c164 * @recv: Base address of the register mapping region.
178 struct mhu2_recv_frame_reg __iomem *recv; member
266 &mhu->recv->ch_wn[priv->ch_wn_idx].mask_clear); in mhuv2_doorbell_rx_startup()
276 &mhu->recv->ch_wn[priv->ch_wn_idx].mask_set); in mhuv2_doorbell_rx_shutdown()
284 &mhu->recv->ch_wn[priv->ch_wn_idx].stat_clear); in mhuv2_doorbell_read_data()
335 writel_relaxed(0xFFFFFFFF, &mhu->recv->ch_wn[i].mask_clear); in mhuv2_data_transfer_rx_startup()
345 writel_relaxed(0xFFFFFFFF, &mhu->recv->ch_wn[i].mask_set); in mhuv2_data_transfer_rx_shutdown()
378 data[windows - 1 - i] = readl_relaxed(&mhu->recv->ch_wn[idx].stat); in mhuv2_data_transfer_read_data()
379 writel_relaxed(0xFFFFFFFF, &mhu->recv->ch_wn[idx].stat_clear); in mhuv2_data_transfer_read_data()
627 chan = get_irq_chan_comb(mhu, mhu->recv in get_irq_chan_comb_rx()
[all...]
/kernel/linux/linux-6.6/tools/testing/selftests/bpf/prog_tests/
H A Dtcpbpf_user.c74 rv = recv(accept_fd, buf, 1000, 0); in run_test()
75 if (!ASSERT_EQ(rv, 1000, "recv(accept_fd)")) in run_test()
86 rv = recv(cli_fd, buf, 500, 0); in run_test()
87 if (!ASSERT_EQ(rv, 500, "recv(cli_fd)")) in run_test()
95 err = recv(cli_fd, buf, 1, 0); in run_test()
96 if (!ASSERT_OK(err, "recv(cli_fd) for fin")) in run_test()
100 err = recv(accept_fd, buf, 1, 0); in run_test()
101 ASSERT_OK(err, "recv(accept_fd) for fin"); in run_test()
/third_party/node/deps/v8/src/builtins/
H A Dbuiltins-regexp.cc21 CHECK_RECEIVER(JSReceiver, recv, "RegExp.prototype.toString"); in BUILTIN()
23 if (*recv == isolate->regexp_function()->prototype()) { in BUILTIN()
34 JSReceiver::GetProperty(isolate, recv, in BUILTIN()
47 JSReceiver::GetProperty(isolate, recv, in BUILTIN()
/third_party/toybox/toys/net/
H A Dping.c55 unsigned long sent, recv, fugit, min, max;
64 TT.sent, TT.recv, ((TT.sent-TT.recv)*100)/(TT.sent?TT.sent:1)); in summary()
65 if (TT.recv) in summary()
67 TT.min, TT.fugit/TT.recv, TT.max); in summary()
236 if (0>=(waitms = tW-tnow) || !(TT.sent-TT.recv)) break; in ping_main()
275 TT.recv++; in ping_main()
/kernel/linux/linux-6.6/drivers/gpu/drm/i915/gt/uc/
H A Dintel_guc_ct.c66 * | 0x0800 | G2H `CTB Descriptor`_ (recv) | |
71 * | 0x1000 | G2H `CT Buffer`_ (recv) | m*4K |
116 spin_lock_init(&ct->ctbs.recv.lock); in intel_guc_ct_init_early()
268 /* store pointers to desc and cmds for recv ctb */ in intel_guc_ct_init()
273 CT_DEBUG(ct, "%s desc %#tx cmds %#tx size %u/%u\n", "recv", in intel_guc_ct_init()
277 guc_ct_buffer_init(&ct->ctbs.recv, desc, cmds, cmds_size, resv_space); in intel_guc_ct_init()
323 guc_ct_buffer_reset(&ct->ctbs.recv); in intel_guc_ct_enable()
329 desc = base + ptrdiff(ct->ctbs.recv.desc, blob); in intel_guc_ct_enable()
330 cmds = base + ptrdiff(ct->ctbs.recv.cmds, blob); in intel_guc_ct_enable()
331 size = ct->ctbs.recv in intel_guc_ct_enable()
549 struct guc_ct_buffer_desc *recv = ct->ctbs.send.desc; ct_deadlocked() local
[all...]
/third_party/node/test/js-native-api/test_reference/
H A Dtest_finalizer.c19 napi_value recv; in FinalizeExternalCallJs() local
22 NODE_API_CALL_RETURN_VOID(env, napi_get_global(env, &recv)); in FinalizeExternalCallJs()
24 env, napi_call_function(env, recv, js_finalizer, 0, NULL, NULL)); in FinalizeExternalCallJs()
/third_party/node/test/node-api/test_buffer/
H A Dtest_finalizer.c14 napi_value recv; in malignDeleter() local
17 NODE_API_CALL_RETURN_VOID(env, napi_get_global(env, &recv)); in malignDeleter()
19 env, napi_call_function(env, recv, js_finalizer, 0, NULL, NULL)); in malignDeleter()
/third_party/node/test/node-api/test_threadsafe_function/
H A Dtest_uncaught_exception.c10 napi_value recv; in ThreadSafeFunctionFinalize() local
13 NODE_API_CALL_RETURN_VOID(env, napi_get_global(env, &recv)); in ThreadSafeFunctionFinalize()
15 env, napi_call_function(env, recv, js_func, 0, NULL, NULL)); in ThreadSafeFunctionFinalize()
/base/request/request/services/src/manage/
H A Dnotifier.rs152 let info = client_rx.recv().await.unwrap(); in ut_notify_progress()
162 let info = client_rx.recv().await.unwrap(); in ut_notify_progress()
209 let info = client_rx.recv().await.unwrap(); in ut_notify_pause_resume()
222 let info = client_rx.recv().await.unwrap(); in ut_notify_pause_resume()
259 let info = client_rx.recv().await.unwrap(); in ut_notify_remove()
297 let info = client_rx.recv().await.unwrap(); in ut_notify_completed()
335 let info = client_rx.recv().await.unwrap(); in ut_notify_failed()
375 let info = client_rx.recv().await.unwrap(); in ut_notify_pause_resume_completed()
380 let info = client_rx.recv().await.unwrap(); in ut_notify_pause_resume_completed()
413 let info = client_rx.recv() in ut_notify_pause_resume_failed()
[all...]
/kernel/linux/linux-5.10/drivers/infiniband/core/
H A Dmad.c1871 struct ib_mad_private *recv, in handle_ib_smi()
1875 struct ib_smp *smp = (struct ib_smp *)recv->mad; in handle_ib_smi()
1900 memcpy(response, recv, mad_priv_size(response)); in handle_ib_smi()
1918 static bool generate_unmatched_resp(const struct ib_mad_private *recv, in generate_unmatched_resp() argument
1922 const struct ib_mad_hdr *recv_hdr = (const struct ib_mad_hdr *)recv->mad; in generate_unmatched_resp()
1927 memcpy(response, recv, mad_priv_size(response)); in generate_unmatched_resp()
1942 (struct opa_smp *)recv->mad); in generate_unmatched_resp()
1958 struct ib_mad_private *recv, in handle_opa_smi()
1962 struct opa_smp *smp = (struct opa_smp *)recv->mad; in handle_opa_smi()
1989 memcpy(response, recv, mad_priv_siz in handle_opa_smi()
1867 handle_ib_smi(const struct ib_mad_port_private *port_priv, const struct ib_mad_qp_info *qp_info, const struct ib_wc *wc, int port_num, struct ib_mad_private *recv, struct ib_mad_private *response) handle_ib_smi() argument
1954 handle_opa_smi(struct ib_mad_port_private *port_priv, struct ib_mad_qp_info *qp_info, struct ib_wc *wc, int port_num, struct ib_mad_private *recv, struct ib_mad_private *response) handle_opa_smi() argument
2010 handle_smi(struct ib_mad_port_private *port_priv, struct ib_mad_qp_info *qp_info, struct ib_wc *wc, int port_num, struct ib_mad_private *recv, struct ib_mad_private *response, bool opa) handle_smi() argument
2035 struct ib_mad_private *recv, *response = NULL; ib_mad_recv_done() local
2761 struct ib_mad_private *recv; cleanup_recv_queue() local
[all...]

Completed in 15 milliseconds

12345678910>>...31