| /kernel/linux/linux-5.10/net/rds/ |
| H A D | ib_recv.c | 49 struct rds_ib_recv_work *recv; in rds_ib_recv_init_ring() local
52 for (i = 0, recv = ic->i_recvs; i < ic->i_recv_ring.w_nr; i++, recv++) { in rds_ib_recv_init_ring()
55 recv->r_ibinc = NULL; in rds_ib_recv_init_ring()
56 recv->r_frag = NULL; in rds_ib_recv_init_ring()
58 recv->r_wr.next = NULL; in rds_ib_recv_init_ring()
59 recv->r_wr.wr_id = i; in rds_ib_recv_init_ring()
60 recv->r_wr.sg_list = recv->r_sge; in rds_ib_recv_init_ring()
61 recv in rds_ib_recv_init_ring()
223 rds_ib_recv_clear_one(struct rds_ib_connection *ic, struct rds_ib_recv_work *recv) rds_ib_recv_clear_one() argument
307 rds_ib_recv_refill_one(struct rds_connection *conn, struct rds_ib_recv_work *recv, gfp_t gfp) rds_ib_recv_refill_one() argument
385 struct rds_ib_recv_work *recv; rds_ib_recv_refill() local
848 rds_ib_process_recv(struct rds_connection *conn, struct rds_ib_recv_work *recv, u32 data_len, struct rds_ib_ack_state *state) rds_ib_process_recv() argument
988 struct rds_ib_recv_work *recv; rds_ib_recv_cqe_handler() local
[all...] |
| /kernel/linux/linux-6.6/net/rds/ |
| H A D | ib_recv.c | 50 struct rds_ib_recv_work *recv; in rds_ib_recv_init_ring() local
53 for (i = 0, recv = ic->i_recvs; i < ic->i_recv_ring.w_nr; i++, recv++) { in rds_ib_recv_init_ring()
56 recv->r_ibinc = NULL; in rds_ib_recv_init_ring()
57 recv->r_frag = NULL; in rds_ib_recv_init_ring()
59 recv->r_wr.next = NULL; in rds_ib_recv_init_ring()
60 recv->r_wr.wr_id = i; in rds_ib_recv_init_ring()
61 recv->r_wr.sg_list = recv->r_sge; in rds_ib_recv_init_ring()
62 recv in rds_ib_recv_init_ring()
224 rds_ib_recv_clear_one(struct rds_ib_connection *ic, struct rds_ib_recv_work *recv) rds_ib_recv_clear_one() argument
308 rds_ib_recv_refill_one(struct rds_connection *conn, struct rds_ib_recv_work *recv, gfp_t gfp) rds_ib_recv_refill_one() argument
386 struct rds_ib_recv_work *recv; rds_ib_recv_refill() local
849 rds_ib_process_recv(struct rds_connection *conn, struct rds_ib_recv_work *recv, u32 data_len, struct rds_ib_ack_state *state) rds_ib_process_recv() argument
989 struct rds_ib_recv_work *recv; rds_ib_recv_cqe_handler() local
[all...] |
| /third_party/node/deps/v8/src/regexp/ |
| H A D | regexp-utils.cc | 40 V8_INLINE bool HasInitialRegExpMap(Isolate* isolate, JSReceiver recv) { in HasInitialRegExpMap() argument
41 return recv.map() == isolate->regexp_function()->initial_map(); in HasInitialRegExpMap()
47 Handle<JSReceiver> recv, in SetLastIndex()
51 if (HasInitialRegExpMap(isolate, *recv)) { in SetLastIndex()
52 JSRegExp::cast(*recv).set_last_index(*value_as_object, in SetLastIndex()
54 return recv; in SetLastIndex()
57 isolate, recv, isolate->factory()->lastIndex_string(), value_as_object, in SetLastIndex()
63 Handle<JSReceiver> recv) { in GetLastIndex()
64 if (HasInitialRegExpMap(isolate, *recv)) { in GetLastIndex()
65 return handle(JSRegExp::cast(*recv) in GetLastIndex()
46 SetLastIndex(Isolate* isolate, Handle<JSReceiver> recv, uint64_t value) SetLastIndex() argument
62 GetLastIndex(Isolate* isolate, Handle<JSReceiver> recv) GetLastIndex() argument
[all...] |
| /kernel/linux/linux-6.6/drivers/gpu/drm/nouveau/nvkm/subdev/pmu/ |
| H A D | gt215.c | 54 pmu->recv.message = message; in gt215_pmu_send()
55 pmu->recv.process = process; in gt215_pmu_send()
77 wait_event(pmu->recv.wait, (pmu->recv.process == 0)); in gt215_pmu_send()
78 reply[0] = pmu->recv.data[0]; in gt215_pmu_send()
79 reply[1] = pmu->recv.data[1]; in gt215_pmu_send()
105 pmu->recv.base)); in gt215_pmu_recv()
116 if (pmu->recv.process) { in gt215_pmu_recv()
117 if (process == pmu->recv.process && in gt215_pmu_recv()
118 message == pmu->recv in gt215_pmu_recv()
[all...] |
| /kernel/linux/linux-5.10/drivers/gpu/drm/nouveau/nvkm/subdev/pmu/ |
| H A D | gt215.c | 54 pmu->recv.message = message; in gt215_pmu_send()
55 pmu->recv.process = process; in gt215_pmu_send()
77 wait_event(pmu->recv.wait, (pmu->recv.process == 0)); in gt215_pmu_send()
78 reply[0] = pmu->recv.data[0]; in gt215_pmu_send()
79 reply[1] = pmu->recv.data[1]; in gt215_pmu_send()
105 pmu->recv.base)); in gt215_pmu_recv()
116 if (pmu->recv.process) { in gt215_pmu_recv()
117 if (process == pmu->recv.process && in gt215_pmu_recv()
118 message == pmu->recv in gt215_pmu_recv()
[all...] |
| /third_party/libuv/test/ |
| H A D | test-ipc-send-recv.c | 51 union handles recv; member
61 union handles recv; member
94 union handles* recv; in recv_cb() local
103 recv = &ctx.recv; in recv_cb()
105 recv = &ctx.recv2; in recv_cb()
124 r = uv_pipe_init(ctx.channel.loop, &recv->pipe, 0); in recv_cb()
126 r = uv_tcp_init(ctx.channel.loop, &recv->tcp); in recv_cb()
131 r = uv_accept(handle, &recv->stream); in recv_cb()
294 uv_close(&ctx2.recv in write2_cb()
308 union handles* recv; read_cb() local
[all...] |
| /kernel/linux/linux-5.10/fs/hmdfs/ |
| H A D | hmdfs_server.c | 540 struct open_request *recv = data; in hmdfs_server_open() local
546 trace_hmdfs_server_open_enter(con, recv); in hmdfs_server_open()
555 if (path_contain_dotdot(recv->buf, recv->path_len)) { in hmdfs_server_open()
560 info->file = hmdfs_open_file(con, recv->buf, recv->file_type, in hmdfs_server_open()
567 ret = hmdfs_get_open_info(con, recv->file_type, recv->buf, info); in hmdfs_server_open()
623 struct atomic_open_request *recv, in hmdfs_lookup_create()
629 uint32_t open_flags = le32_to_cpu(recv in hmdfs_lookup_create()
622 hmdfs_lookup_create(struct hmdfs_peer *con, struct atomic_open_request *recv, struct path *child_path, bool *truncate) hmdfs_lookup_create() argument
700 hmdfs_server_do_atomic_open(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd, struct atomic_open_request *recv, struct hmdfs_open_info *info, struct atomic_open_response *resp) hmdfs_server_do_atomic_open() argument
747 struct atomic_open_request *recv = data; hmdfs_server_atomic_open() local
1325 struct rename_request *recv = data; hmdfs_server_rename() local
1651 struct setattr_request *recv = data; hmdfs_server_setattr() local
1740 struct getattr_request *recv = data; hmdfs_server_getattr() local
1839 struct statfs_request *recv = data; hmdfs_server_statfs() local
1912 struct getxattr_request *recv = data; hmdfs_server_getxattr() local
1979 struct setxattr_request *recv = data; hmdfs_server_setxattr() local
2028 struct listxattr_request *recv = data; hmdfs_server_listxattr() local
[all...] |
| /kernel/linux/linux-6.6/fs/hmdfs/ |
| H A D | hmdfs_server.c | 540 struct open_request *recv = data; in hmdfs_server_open() local
546 trace_hmdfs_server_open_enter(con, recv); in hmdfs_server_open()
555 if (path_contain_dotdot(recv->buf, recv->path_len)) { in hmdfs_server_open()
560 info->file = hmdfs_open_file(con, recv->buf, recv->file_type, in hmdfs_server_open()
567 ret = hmdfs_get_open_info(con, recv->file_type, recv->buf, info); in hmdfs_server_open()
623 struct atomic_open_request *recv, in hmdfs_lookup_create()
629 uint32_t open_flags = le32_to_cpu(recv in hmdfs_lookup_create()
622 hmdfs_lookup_create(struct hmdfs_peer *con, struct atomic_open_request *recv, struct path *child_path, bool *truncate) hmdfs_lookup_create() argument
700 hmdfs_server_do_atomic_open(struct hmdfs_peer *con, struct hmdfs_head_cmd *cmd, struct atomic_open_request *recv, struct hmdfs_open_info *info, struct atomic_open_response *resp) hmdfs_server_do_atomic_open() argument
747 struct atomic_open_request *recv = data; hmdfs_server_atomic_open() local
1325 struct rename_request *recv = data; hmdfs_server_rename() local
1651 struct setattr_request *recv = data; hmdfs_server_setattr() local
1740 struct getattr_request *recv = data; hmdfs_server_getattr() local
1839 struct statfs_request *recv = data; hmdfs_server_statfs() local
1912 struct getxattr_request *recv = data; hmdfs_server_getxattr() local
1979 struct setxattr_request *recv = data; hmdfs_server_setxattr() local
2028 struct listxattr_request *recv = data; hmdfs_server_listxattr() local
[all...] |
| /third_party/node/src/api/ |
| H A D | callback.cc | 172 Local<Object> recv, in InternalMakeCallback()
177 CHECK(!recv.IsEmpty()); in InternalMakeCallback()
213 ret = hook_cb->Call(context, recv, args.length(), &args[0]); in InternalMakeCallback()
215 ret = callback->Call(context, recv, argc, argv); in InternalMakeCallback()
234 Local<Object> recv, in MakeCallback()
241 return MakeCallback(isolate, recv, method_string, argc, argv, asyncContext); in MakeCallback()
245 Local<Object> recv, in MakeCallback()
252 Environment::GetCurrent(recv->GetCreationContext().ToLocalChecked()); in MakeCallback()
257 if (!recv->Get(isolate->GetCurrentContext(), symbol).ToLocal(&callback_v)) in MakeCallback()
265 return MakeCallback(isolate, recv, callbac in MakeCallback()
170 InternalMakeCallback(Environment* env, Local<Object> resource, Local<Object> recv, const Local<Function> callback, int argc, Local<Value> argv[], async_context asyncContext) InternalMakeCallback() argument
233 MakeCallback(Isolate* isolate, Local<Object> recv, const char* method, int argc, Local<Value> argv[], async_context asyncContext) MakeCallback() argument
244 MakeCallback(Isolate* isolate, Local<Object> recv, Local<String> symbol, int argc, Local<Value> argv[], async_context asyncContext) MakeCallback() argument
268 MakeCallback(Isolate* isolate, Local<Object> recv, Local<Function> callback, int argc, Local<Value> argv[], async_context asyncContext) MakeCallback() argument
299 MakeSyncCallback(Isolate* isolate, Local<Object> recv, Local<Function> callback, int argc, Local<Value> argv[]) MakeSyncCallback() argument
327 MakeCallback(Isolate* isolate, Local<Object> recv, const char* method, int argc, Local<Value>* argv) MakeCallback() argument
338 MakeCallback(Isolate* isolate, Local<Object> recv, Local<String> symbol, int argc, Local<Value>* argv) MakeCallback() argument
349 MakeCallback(Isolate* isolate, Local<Object> recv, Local<Function> callback, int argc, Local<Value>* argv) MakeCallback() argument
[all...] |
| /kernel/linux/linux-5.10/sound/soc/sh/ |
| H A D | dma-sh7760.c | 123 int recv = substream->stream == SNDRV_PCM_STREAM_PLAYBACK ? 0:1; in camelot_pcm_open() local
129 dmairq = (recv) ? cam->txid + 2 : cam->txid; in camelot_pcm_open()
130 if (recv) { in camelot_pcm_open()
157 int recv = substream->stream == SNDRV_PCM_STREAM_PLAYBACK ? 0:1; in camelot_pcm_close() local
160 dmairq = (recv) ? cam->txid + 2 : cam->txid; in camelot_pcm_close()
162 if (recv) in camelot_pcm_close()
179 int recv = substream->stream == SNDRV_PCM_STREAM_PLAYBACK ? 0:1; in camelot_hw_params() local
182 if (recv) { in camelot_hw_params()
230 /* start DMABRG engine: recv start, auto-reload */ in dmabrg_rec_dma_start()
246 int recv in camelot_trigger() local
274 int recv = substream->stream == SNDRV_PCM_STREAM_PLAYBACK ? 0:1; camelot_pos() local
[all...] |
| /kernel/linux/linux-6.6/sound/soc/sh/ |
| H A D | dma-sh7760.c | 123 int recv = substream->stream == SNDRV_PCM_STREAM_PLAYBACK ? 0:1; in camelot_pcm_open() local
129 dmairq = (recv) ? cam->txid + 2 : cam->txid; in camelot_pcm_open()
130 if (recv) { in camelot_pcm_open()
157 int recv = substream->stream == SNDRV_PCM_STREAM_PLAYBACK ? 0:1; in camelot_pcm_close() local
160 dmairq = (recv) ? cam->txid + 2 : cam->txid; in camelot_pcm_close()
162 if (recv) in camelot_pcm_close()
179 int recv = substream->stream == SNDRV_PCM_STREAM_PLAYBACK ? 0:1; in camelot_hw_params() local
181 if (recv) { in camelot_hw_params()
229 /* start DMABRG engine: recv start, auto-reload */ in dmabrg_rec_dma_start()
245 int recv in camelot_trigger() local
273 int recv = substream->stream == SNDRV_PCM_STREAM_PLAYBACK ? 0:1; camelot_pos() local
[all...] |
| /kernel/linux/linux-6.6/tools/testing/selftests/net/ |
| H A D | tls.c | 240 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
425 EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send); in TEST_F()
429 EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size); in TEST_F()
461 EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL), in chunked_sendfile()
499 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
511 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
522 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
524 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL), in TEST_F()
536 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
546 EXPECT_EQ(recv(sel in TEST_F()
[all...] |
| /third_party/protobuf/ruby/src/main/java/com/google/protobuf/jruby/ |
| H A D | RubyEnum.java | 51 public static IRubyObject lookup(ThreadContext context, IRubyObject recv, IRubyObject number) { in lookup() argument
52 RubyEnumDescriptor rubyEnumDescriptorescriptor = (RubyEnumDescriptor) getDescriptor(context, recv); in lookup()
67 public static IRubyObject resolve(ThreadContext context, IRubyObject recv, IRubyObject name) { in resolve() argument
68 RubyEnumDescriptor rubyEnumDescriptorescriptor = (RubyEnumDescriptor) getDescriptor(context, recv); in resolve()
83 public static IRubyObject getDescriptor(ThreadContext context, IRubyObject recv) { in getDescriptor() argument
84 return ((RubyModule) recv).getInstanceVariable(Utils.DESCRIPTOR_INSTANCE_VAR); in getDescriptor()
|
| /third_party/node/test/addons/make-callback/ |
| H A D | test.js | 22 const recv = {
25 assert.strictEqual(recv, this);
30 assert.strictEqual(recv, this);
36 assert.strictEqual(makeCallback(recv, 'one'), 42);
37 assert.strictEqual(makeCallback(recv, 'two', 1337), 42);
|
| /third_party/lwip/test/unit/ip4/ |
| H A D | test_ip4.c | 87 fail_unless(lwip_stats.ip_frag.recv == 1); in START_TEST()
94 fail_unless(lwip_stats.ip_frag.recv == 2); in START_TEST()
101 fail_unless(lwip_stats.ip_frag.recv == 3); in START_TEST()
108 fail_unless(lwip_stats.ip_frag.recv == 4); in START_TEST()
115 fail_unless(lwip_stats.ip_frag.recv == 5); in START_TEST()
122 fail_unless(lwip_stats.ip_frag.recv == 6); in START_TEST()
129 fail_unless(lwip_stats.ip_frag.recv == 7); in START_TEST()
136 fail_unless(lwip_stats.ip_frag.recv == 8); in START_TEST()
143 fail_unless(lwip_stats.ip_frag.recv == 9); in START_TEST()
|
| /kernel/linux/linux-5.10/tools/testing/selftests/net/ |
| H A D | tls.c | 94 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
209 EXPECT_EQ(recv(self->cfd, recv_buf, to_send, MSG_WAITALL), to_send); in TEST_F()
213 EXPECT_EQ(recv(self->cfd, buf, st.st_size, MSG_WAITALL), st.st_size); in TEST_F()
245 EXPECT_EQ(recv(self->cfd, buf, test_payload_size, MSG_WAITALL), in chunked_sendfile()
281 EXPECT_NE(recv(self->cfd, recv_mem, send_len, 0), -1); in TEST_F()
293 EXPECT_NE(recv(self->cfd, buf, send_len, 0), -1); in TEST_F()
304 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
306 EXPECT_EQ(recv(self->cfd, buf, send_len * 2, MSG_WAITALL), in TEST_F()
318 EXPECT_EQ(recv(self->cfd, buf, send_len, MSG_DONTWAIT), -1); in TEST_F()
336 EXPECT_EQ(recv(sel in TEST_F()
[all...] |
| /kernel/linux/linux-5.10/fs/hmdfs/comm/ |
| H A D | transport.c | 117 hmdfs_err("tcp recv error %d", rc); in tcp_read_head_from_socket()
153 hmdfs_err("tcp recv error %d", rc); in tcp_read_buffer_from_socket()
166 struct hmdfs_head_cmd *recv) in hmdfs_drop_readpage_buffer()
172 len = le32_to_cpu(recv->data_len) - sizeof(struct hmdfs_head_cmd); in hmdfs_drop_readpage_buffer()
174 hmdfs_err("recv invalid readpage length %u", len); in hmdfs_drop_readpage_buffer()
190 struct hmdfs_head_cmd *recv, in hmdfs_get_readpage_buffer()
197 out_len = le32_to_cpu(recv->data_len) - sizeof(struct hmdfs_head_cmd); in hmdfs_get_readpage_buffer()
199 hmdfs_err("recv invalid readpage length %u", out_len); in hmdfs_get_readpage_buffer()
216 struct hmdfs_head_cmd *recv) in tcp_recvpage_tls()
232 rd_err = le32_to_cpu(recv in tcp_recvpage_tls()
165 hmdfs_drop_readpage_buffer(struct socket *sock, struct hmdfs_head_cmd *recv) hmdfs_drop_readpage_buffer() argument
189 hmdfs_get_readpage_buffer(struct socket *sock, struct hmdfs_head_cmd *recv, struct page *page) hmdfs_get_readpage_buffer() argument
215 tcp_recvpage_tls(struct connection *connect, struct hmdfs_head_cmd *recv) tcp_recvpage_tls() argument
393 tcp_recvbuffer_cipher(struct connection *connect, struct hmdfs_head_cmd *recv) tcp_recvbuffer_cipher() argument
452 tcp_recvbuffer_tls(struct connection *connect, struct hmdfs_head_cmd *recv) tcp_recvbuffer_tls() argument
495 struct hmdfs_head_cmd *recv = NULL; tcp_receive_from_sock() local
[all...] |
| /kernel/linux/linux-6.6/fs/hmdfs/comm/ |
| H A D | transport.c | 117 hmdfs_err("tcp recv error %d", rc); in tcp_read_head_from_socket()
153 hmdfs_err("tcp recv error %d", rc); in tcp_read_buffer_from_socket()
166 struct hmdfs_head_cmd *recv) in hmdfs_drop_readpage_buffer()
172 len = le32_to_cpu(recv->data_len) - sizeof(struct hmdfs_head_cmd); in hmdfs_drop_readpage_buffer()
174 hmdfs_err("recv invalid readpage length %u", len); in hmdfs_drop_readpage_buffer()
190 struct hmdfs_head_cmd *recv, in hmdfs_get_readpage_buffer()
197 out_len = le32_to_cpu(recv->data_len) - sizeof(struct hmdfs_head_cmd); in hmdfs_get_readpage_buffer()
199 hmdfs_err("recv invalid readpage length %u", out_len); in hmdfs_get_readpage_buffer()
216 struct hmdfs_head_cmd *recv) in tcp_recvpage_tls()
232 rd_err = le32_to_cpu(recv in tcp_recvpage_tls()
165 hmdfs_drop_readpage_buffer(struct socket *sock, struct hmdfs_head_cmd *recv) hmdfs_drop_readpage_buffer() argument
189 hmdfs_get_readpage_buffer(struct socket *sock, struct hmdfs_head_cmd *recv, struct page *page) hmdfs_get_readpage_buffer() argument
215 tcp_recvpage_tls(struct connection *connect, struct hmdfs_head_cmd *recv) tcp_recvpage_tls() argument
393 tcp_recvbuffer_cipher(struct connection *connect, struct hmdfs_head_cmd *recv) tcp_recvbuffer_cipher() argument
452 tcp_recvbuffer_tls(struct connection *connect, struct hmdfs_head_cmd *recv) tcp_recvbuffer_tls() argument
495 struct hmdfs_head_cmd *recv = NULL; tcp_receive_from_sock() local
[all...] |
| /kernel/linux/linux-5.10/drivers/usb/storage/ |
| H A D | karma.c | 39 char *recv; member
115 data->recv, RIO_RECV_LEN, NULL); in rio_karma_send_command()
119 if (data->recv[5] == seq) in rio_karma_send_command()
172 kfree(data->recv); in rio_karma_destructor()
182 data->recv = kmalloc(RIO_RECV_LEN, GFP_NOIO); in rio_karma_init()
183 if (!data->recv) { in rio_karma_init()
|
| /kernel/linux/linux-6.6/drivers/usb/storage/ |
| H A D | karma.c | 39 char *recv; member
115 data->recv, RIO_RECV_LEN, NULL); in rio_karma_send_command()
119 if (data->recv[5] == seq) in rio_karma_send_command()
172 kfree(data->recv); in rio_karma_destructor()
182 data->recv = kmalloc(RIO_RECV_LEN, GFP_NOIO); in rio_karma_init()
183 if (!data->recv) { in rio_karma_init()
|
| /third_party/ltp/utils/sctp/func_tests/ |
| H A D | test_1_to_1_shutdown.c | 150 error = recv(acpt_sk[0], msgbuf, 100, 0); in main()
152 tst_brkm(TBROK, tst_exit, "recv on a SHUTDOWN received socket " in main()
161 error = recv(clnt_sk[0], msgbuf, 100, 0); in main()
163 tst_brkm(TBROK, tst_exit, "recv on a SHUT_WR socket with no " in main()
173 error = recv(clnt_sk[1], msgbuf, 100, 0); in main()
175 tst_brkm(TBROK, tst_exit, "recv on a SHUT_RD socket " in main()
191 error = recv(clnt_sk[1], msgbuf, 100, 0); in main()
193 tst_brkm(TBROK, tst_exit, "recv on a SHUT_RD socket " in main()
202 error = recv(acpt_sk[2], msgbuf, 100, 0); in main()
204 tst_brkm(TBROK, tst_exit, "recv o in main()
[all...] |
| /kernel/linux/linux-5.10/drivers/bluetooth/ |
| H A D | hci_h4.c | 101 { 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()
|
| /kernel/linux/linux-6.6/drivers/bluetooth/ |
| H A D | hci_h4.c | 101 { 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 D | test-event-emitter-get-max-listeners.js | 17 const recv = {};
18 EventEmitter.prototype.on.call(recv, 'event', () => {});
19 EventEmitter.prototype.on.call(recv, 'event', () => {});
|
| /kernel/linux/linux-5.10/net/sunrpc/ |
| H A D | xprtsock.c | 472 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...] |