Home
last modified time | relevance | path

Searched refs:recv (Results 1 - 25 of 759) sorted by relevance

12345678910>>...31

/kernel/linux/linux-5.10/net/rds/
H A Dib_recv.c49 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 Dib_recv.c50 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...]
/foundation/communication/netmanager_base/services/netstatsmanager/src/
H A Dnet_stats_history.cpp23 int32_t NetStatsHistory::GetHistory(std::vector<NetStatsInfo> &recv, uint64_t start, uint64_t end) in GetHistory() argument
30 return handler->ReadStatsData(recv, start, end); in GetHistory()
33 int32_t NetStatsHistory::GetHistory(std::vector<NetStatsInfo> &recv, uint32_t uid, uint64_t start, uint64_t end) in GetHistory() argument
40 return handler->ReadStatsData(recv, uid, start, end); in GetHistory()
43 int32_t NetStatsHistory::GetHistory(std::vector<NetStatsInfo> &recv, const std::string &iface, uint64_t start, in GetHistory() argument
51 return handler->ReadStatsData(recv, iface, start, end); in GetHistory()
54 int32_t NetStatsHistory::GetHistory(std::vector<NetStatsInfo> &recv, const std::string &iface, uint32_t uid, in GetHistory() argument
62 return handler->ReadStatsData(recv, iface, uid, start, end); in GetHistory()
65 int32_t NetStatsHistory::GetHistoryByIdent(std::vector<NetStatsInfo> &recv, const std::string &ident, uint64_t start, in GetHistoryByIdent() argument
73 return handler->ReadStatsDataByIdent(recv, iden in GetHistoryByIdent()
76 GetHistory(std::vector<NetStatsInfo> &recv, uint32_t uid, const std::string &ident, uint64_t start, uint64_t end) GetHistory() argument
[all...]
/third_party/node/deps/v8/src/regexp/
H A Dregexp-utils.cc40 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 Dgt215.c54 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 Dgt215.c54 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 Dtest-ipc-send-recv.c51 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 Dhmdfs_server.c540 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 Dhmdfs_server.c540 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 Dcallback.cc172 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...]
/foundation/communication/netmanager_base/services/netstatsmanager/include/
H A Dnet_stats_history.h31 int32_t GetHistory(std::vector<NetStatsInfo> &recv, uint64_t start = 0, uint64_t end = LONG_MAX);
32 int32_t GetHistory(std::vector<NetStatsInfo> &recv, uint32_t uid, uint64_t start = 0, uint64_t end = LONG_MAX);
33 int32_t GetHistory(std::vector<NetStatsInfo> &recv, const std::string &iface, uint64_t start = 0,
35 int32_t GetHistory(std::vector<NetStatsInfo> &recv, const std::string &iface, uint32_t uid, uint64_t start = 0,
37 int32_t GetHistoryByIdent(std::vector<NetStatsInfo> &recv, const std::string &ident, uint64_t start = 0,
39 int32_t GetHistory(std::vector<NetStatsInfo> &recv, uint32_t uid, const std::string &ident, uint64_t start = 0,
/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/
H A Dut_net_quota_policy.cpp110 NetQuotaPolicy recv; in HWTEST_F() local
111 ret = NetQuotaPolicy::Unmarshalling(parcel, recv); in HWTEST_F()
113 EXPECT_EQ(recv.networkmatchrule.simId, data.networkmatchrule.simId); in HWTEST_F()
114 EXPECT_EQ(recv.networkmatchrule.ident, data.networkmatchrule.ident); in HWTEST_F()
132 std::vector<NetQuotaPolicy> recv; in HWTEST_F() local
133 ret = NetQuotaPolicy::Unmarshalling(parcel, recv); in HWTEST_F()
135 std::for_each(recv.begin(), recv.end(), [this](const auto &cv) { in HWTEST_F()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
H A Dfillp_common.c173 FILLP_LOGINF("cost between send-recv: last seq:%u, cost:%lld, size:%u", item->seqNum, in LogForMsgRTT()
375 pack.lostSeq = pcb->recv.seqNum; in FillpSendAdhocpack()
385 struct SkipList *recvList = &pcb->recv.recvList; in FillpUploadRecvBox()
399 1.startSeq = recv.seqNum : This pkt is we expected in FillpUploadRecvBox()
400 2.startSeq < recv.seqNum : This pkt has been recved in FillpUploadRecvBox()
401 3.startSeq > recv.seqNum : There is a gap between this pkt and last recved one in FillpUploadRecvBox()
403 if (start_seq != pcb->recv.seqNum) { in FillpUploadRecvBox()
410 pcb->recv.seqNum = item->seqNum; in FillpUploadRecvBox()
411 pcb->recv.recvBytes -= item->dataLen; in FillpUploadRecvBox()
430 if ((pcb->recv in FillpUploadRecvBox()
[all...]
/kernel/linux/linux-5.10/sound/soc/sh/
H A Ddma-sh7760.c123 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 Ddma-sh7760.c123 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...]
/third_party/protobuf/ruby/src/main/java/com/google/protobuf/jruby/
H A DRubyEnum.java51 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()
/kernel/linux/linux-6.6/tools/testing/selftests/net/
H A Dtls.c240 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/node/test/addons/make-callback/
H A Dtest.js22 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 Dtest_ip4.c87 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()
/foundation/multimodalinput/input/intention/ipc/socket/src/
H A Dsocket_connection.cpp32 std::function<void(NetPacket&)> recv, in SocketConnection()
34 : socketFd_(socketFd), recv_(recv), onDisconnected_(onDisconnected) in SocketConnection()
45 std::function<void(NetPacket&)> recv, std::function<void()> onDisconnected) in Connect()
53 return std::make_shared<SocketConnection>(sockFd, recv, onDisconnected); in Connect()
63 numRead = ::recv(fd, buf, sizeof(buf), MSG_DONTWAIT); in OnReadable()
69 FI_HILOGD("recv was interrupted, read again"); in OnReadable()
75 FI_HILOGE("recv failed:%{public}s", ::strerror(errno)); in OnReadable()
31 SocketConnection(int32_t socketFd, std::function<void(NetPacket&)> recv, std::function<void()> onDisconnected) SocketConnection() argument
44 Connect(std::function<int32_t()> socket, std::function<void(NetPacket&)> recv, std::function<void()> onDisconnected) Connect() argument
/foundation/arkui/ace_engine/frameworks/component_test/core/
H A Daction.cpp25 static void DecomposeTap(EventMatrix& recv, const NG::PointF& point) in DecomposeTap() argument
32 recv = std::move(pointerEventMatrix); in DecomposeTap()
35 static void DecomposeDoubleTap(EventMatrix& recv, const NG::PointF& point) in DecomposeDoubleTap() argument
45 recv = std::move(pointerEventMatrix); in DecomposeDoubleTap()
48 static void DecomposePress(EventMatrix& recv, const NG::PointF& point, uint32_t duration) in DecomposePress() argument
56 recv = std::move(pointerEventMatrix); in DecomposePress()
120 void ClickAction::Decompose(EventMatrix& recv) const in Decompose()
124 DecomposeTap(recv, point_); in Decompose()
127 DecomposeDoubleTap(recv, point_); in Decompose()
130 DecomposePress(recv, point in Decompose()
[all...]
/foundation/arkui/ace_engine/interfaces/napi/kits/component_test/
H A Djs_component_test_utils.cpp89 bool CheckAndParseStr(napi_env env, napi_value arg, std::string& recv, std::string& errMsg) in CheckAndParseStr() argument
111 recv = message.get(); in CheckAndParseStr()
115 bool CheckAndParseInt32(napi_env env, napi_value arg, int32_t& recv, std::string& errMsg) in CheckAndParseInt32() argument
129 napi_get_value_int32(env, arg, &recv); in CheckAndParseInt32()
133 bool CheckAndParseUInt32(napi_env env, napi_value arg, uint32_t& recv, std::string& errMsg) in CheckAndParseUInt32() argument
147 napi_get_value_uint32(env, arg, &recv); in CheckAndParseUInt32()
151 bool CheckAndParseBool(napi_env env, napi_value arg, bool& recv, std::string& errMsg) in CheckAndParseBool() argument
165 napi_get_value_bool(env, arg, &recv); in CheckAndParseBool()
/kernel/linux/linux-5.10/tools/testing/selftests/net/
H A Dtls.c94 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 Dtransport.c117 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 Dtransport.c117 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...]

Completed in 18 milliseconds

12345678910>>...31