| /ohos5.0/foundation/communication/netmanager_base/services/netstatsmanager/src/ |
| H A D | net_stats_history.cpp | 23 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, … 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, uint… 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, uint… in GetHistory() argument
62 return handler->ReadStatsData(recv, iface, uid, start, end); in GetHistory()
73 return handler->ReadStatsDataByIdent(recv, ident, start, end); in GetHistoryByIdent()
76 int32_t NetStatsHistory::GetHistory(std::vector<NetStatsInfo> &recv, uint32_t uid, const std::strin… in GetHistory() argument
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/tests/ |
| H A D | signal.rs | 54 stream.recv().await; in sdv_signal_recv_test()
139 signal.recv().await; in sdv_signal_alarm()
154 signal.recv().await; in sdv_signal_child()
169 signal.recv().await; in sdv_signal_hangup()
184 signal.recv().await; in sdv_signal_interrupt()
199 signal.recv().await; in sdv_signal_io()
214 signal.recv().await; in sdv_signal_pipe()
229 signal.recv().await; in sdv_signal_terminate()
244 signal.recv().await; in sdv_signal_user_defined1()
259 signal.recv().await; in sdv_signal_user_defined2()
[all …]
|
| H A D | mpsc_test.rs | 31 assert_eq!(rx.recv().await, Ok(1)); in sdv_unbounded_send_recv_test()
32 assert_eq!(rx.recv().await, Ok(2)); in sdv_unbounded_send_recv_test()
33 assert_eq!(rx.recv().await, Err(RecvError)); in sdv_unbounded_send_recv_test()
51 assert_eq!(rx.recv().await, Ok(1)); in sdv_unbounded_send_recv_drop_test()
52 assert_eq!(rx.recv().await, Ok(2)); in sdv_unbounded_send_recv_drop_test()
106 assert_eq!(rx.recv().await, Ok(1)); in sdv_bounded_send_recv_test()
107 assert_eq!(rx.recv().await, Ok(2)); in sdv_bounded_send_recv_test()
128 assert_eq!(rx.recv().await, Ok(1)); in sdv_bounded_send_recv_drop_test()
129 assert_eq!(rx.recv().await, Ok(2)); in sdv_bounded_send_recv_drop_test()
287 assert!(rx.recv().await.is_ok()); in sdv_multi_send_recv_test()
[all …]
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/ |
| H A D | fillp_common.c | 375 pack.lostSeq = pcb->recv.seqNum; in FillpSendAdhocpack()
410 pcb->recv.seqNum = item->seqNum; in FillpUploadRecvBox()
430 if ((pcb->recv.pktNum - pcb->recv.lastPackPktNum) >= ADHOC_PACK_TRIGGLE_THRESHOLD) { in FillpUploadRecvBox()
432 FILLP_GET_SOCKET(pcb)->index, pcb->recv.pktNum, pcb->recv.lastPackPktNum, in FillpUploadRecvBox()
433 (pcb->recv.pktNum - pcb->recv.lastPackPktNum), pcb->mpRecvSize); in FillpUploadRecvBox()
537 list = &(pcb->recv.nackList); in FillpCheckAndUpdateDelayNackList()
616 pcb->recv.pktNum = item->pktNum; in FillBiggerItem()
678 pcb->recv.recvBytes += item->dataLen; in FillpDataToStack()
771 pktHead->seqNum = pcb->recv.seqNum; in FillpBuildAndSendPack()
787 pcb->recv.lastPackPktNum = pcb->recv.pktNum; in FillpBuildAndSendPack()
[all …]
|
| H A D | fillp_input.c | 161 if (!FillpNumIsbigger(item->seqNum, pcb->recv.seqNum)) { in FillpProcessItemData()
200 …if (FillpNumIsbigger(item->seqNum, (pcb->recv.seqNum + pcb->recv.pktRecvCache + privRecvCacheSize)… in FillpDataInput()
203 (pcb->recv.seqNum + pcb->recv.pktRecvCache + privRecvCacheSize)); in FillpDataInput()
249 node = SkipListGetPop(&pcb->recv.recvList); in ProcessPcbItem()
251 FILLP_UINT32 lostSeqNum = pcb->recv.seqNum; in ProcessPcbItem()
271 (void)FillpMallocBufItem(pcb->recv.itemPool, (void **)&pcbBuf, FILLP_FALSE); in FillpHdlDataInput()
275 pcb->recv.curItemCount = (FILLP_UINT32)DYMP_GET_CUR_SIZE(pcb->recv.itemPool); in FillpHdlDataInput()
282 struct SkipListNode *node = SkipListGetTail(&pcb->recv.recvList); in FillpHdlDataInput()
287 FillpNumIsbigger(pktHdr->seqNum, pcb->recv.seqNum)) { in FillpHdlDataInput()
288 item = (struct FillpPcbItem *)SkipListPopTail(&pcb->recv.recvList); in FillpHdlDataInput()
[all …]
|
| H A D | fillp_conn.c | 67 if ((pcb->recv.seqNum == pcb->recv.seqStartNum) && (pcb->send.maxAckNumFromReceiver == in FillpConnReqStateCheck()
725 if ((pcb->recv.seqNum == pcb->recv.seqStartNum) && (pcb->send.maxAckNumFromReceiver == in FillpConfirmCheckState()
885 pcb->recv.pktRecvCache); in FillpCheckConfirmAckInfoIsValid()
1032 pcb->recv.prePackPktNum = tmpHeader->pktNum; in FillpSaveConfirmActToPcb()
1033 pcb->recv.pktNum = tmpHeader->pktNum; in FillpSaveConfirmActToPcb()
1034 pcb->recv.seqNum = tmpHeader->seqNum; in FillpSaveConfirmActToPcb()
1035 pcb->recv.pktStartNum = tmpHeader->pktNum; in FillpSaveConfirmActToPcb()
1036 pcb->recv.seqStartNum = tmpHeader->seqNum; in FillpSaveConfirmActToPcb()
1037 pcb->recv.endSeqNum = pcb->recv.seqStartNum; in FillpSaveConfirmActToPcb()
1038 pcb->statistics.pack.packPktNum = pcb->recv.pktNum; in FillpSaveConfirmActToPcb()
[all …]
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/benches/ |
| H A D | ylong_tokio_multi_threaded.rs | 56 let (send, recv) = mpsc::sync_channel(TASK_NUM);
68 let _ = recv.recv().unwrap();
104 let (send, recv) = mpsc::sync_channel(TASK_NUM); in chained_spawn()
113 recv.recv().unwrap(); in chained_spawn()
147 let (send, recv) = mpsc::sync_channel(TASK_NUM); in chained_spawn()
154 recv.recv().unwrap(); in chained_spawn()
|
| H A D | sync_benchmarks.rs | 101 let (send, recv) = mpsc::sync_channel(TASK_NUM); in std_multi_threaded_ping()
112 recv.recv().unwrap(); in std_multi_threaded_ping()
119 let (send, recv) = mpsc::sync_channel(TASK_NUM); in std_multi_threaded_ping_pong()
129 recv1.recv().unwrap(); in std_multi_threaded_ping_pong()
134 recv2.recv().unwrap(); in std_multi_threaded_ping_pong()
141 recv.recv().unwrap(); in std_multi_threaded_ping_pong()
|
| H A D | ylong_tokio_signal.rs | 41 stream.recv().await;
66 stream.recv().await;
90 stream.recv().await;
115 stream.recv().await;
|
| /ohos5.0/foundation/communication/netmanager_base/services/netstatsmanager/include/ |
| H A D | net_stats_history.h | 31 … 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…
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…
37 …int32_t GetHistoryByIdent(std::vector<NetStatsInfo> &recv, const std::string &ident, uint64_t star…
39 …int32_t GetHistory(std::vector<NetStatsInfo> &recv, uint32_t uid, const std::string &ident, uint64…
|
| /ohos5.0/foundation/communication/netmanager_base/test/netpolicymanager/unittest/net_policy_manager_test/ |
| H A D | ut_net_quota_policy.cpp | 110 NetQuotaPolicy recv; variable
111 ret = NetQuotaPolicy::Unmarshalling(parcel, recv);
113 EXPECT_EQ(recv.networkmatchrule.simId, data.networkmatchrule.simId);
114 EXPECT_EQ(recv.networkmatchrule.ident, data.networkmatchrule.ident);
132 std::vector<NetQuotaPolicy> recv; variable
133 ret = NetQuotaPolicy::Unmarshalling(parcel, recv);
135 std::for_each(recv.begin(), recv.end(), [this](const auto &cv) { in __anond094590c0202()
|
| /ohos5.0/commonlibrary/rust/ylong_runtime/ylong_runtime/src/signal/unix/ |
| H A D | mod.rs | 456 signal.recv().await; in ut_signal_recv_and_poll_recv()
475 signal.recv().await; in ut_signal_alarm()
490 signal.recv().await; in ut_signal_child()
505 signal.recv().await; in ut_signal_hangup()
520 signal.recv().await; in ut_signal_interrupt()
535 signal.recv().await; in ut_signal_io()
550 signal.recv().await; in ut_signal_pipe()
565 signal.recv().await; in ut_signal_terminate()
580 signal.recv().await; in ut_signal_user_defined1()
595 signal.recv().await; in ut_signal_user_defined2()
[all …]
|
| /ohos5.0/foundation/multimodalinput/input/intention/ipc/socket/src/ |
| H A D | socket_connection.cpp | 32 std::function<void(NetPacket&)> recv, in SocketConnection() argument
34 : socketFd_(socketFd), recv_(recv), onDisconnected_(onDisconnected) in SocketConnection()
45 std::function<void(NetPacket&)> recv, std::function<void()> onDisconnected) in Connect() argument
53 return std::make_shared<SocketConnection>(sockFd, recv, onDisconnected); in Connect()
63 numRead = ::recv(fd, buf, sizeof(buf), MSG_DONTWAIT); in OnReadable()
|
| /ohos5.0/base/msdp/device_status/intention/ipc/socket/src/ |
| H A D | socket_connection.cpp | 32 std::function<void(NetPacket&)> recv, in SocketConnection() argument
34 : socketFd_(socketFd), recv_(recv), onDisconnected_(onDisconnected) in SocketConnection()
45 std::function<void(NetPacket&)> recv, std::function<void()> onDisconnected) in Connect() argument
53 return std::make_shared<SocketConnection>(sockFd, recv, onDisconnected); in Connect()
63 numRead = ::recv(fd, buf, sizeof(buf), MSG_DONTWAIT); in OnReadable()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/tests/ |
| H A D | sdv_async_http2.rs | 123 .recv()
158 .recv() in sdv_async_h2_client_send_request()
165 let mut handle = rx.recv().expect("recv Handle failed !"); in sdv_async_h2_client_send_request()
212 .recv() in sdv_async_h2_client_send_request()
238 .recv() in sdv_async_h2_client_send_request_concurrently()
245 let mut handle = rx.recv().expect("recv Handle failed !"); in sdv_async_h2_client_send_request_concurrently()
300 .recv() in sdv_async_h2_client_send_request_concurrently()
|
| /ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/util/h2/ |
| H A D | streams.rs | 88 recv: ActiveState,
155 recv: ActiveState::WaitData,
165 recv: ActiveState::WaitData,
579 recv: ActiveState::WaitHeaders, in send_headers_frame()
585 recv, in send_headers_frame()
588 H2StreamState::LocalHalfClosed(*recv) in send_headers_frame()
592 recv: *recv, in send_headers_frame()
618 recv, in send_data_frame()
676 recv: ActiveState::WaitHeaders, in recv_headers()
706 recv: ActiveState::WaitData, in recv_data()
[all …]
|
| /ohos5.0/base/request/request/frameworks/js/napi/src/legacy/ |
| H A D | request_manager.cpp | 68 napi_ref recv{}; in CallFunctionAsync() local
69 data->generator_(data->env_, &recv, argc, argv); in CallFunctionAsync()
73 napi_get_reference_value(data->env_, recv, &thiz); in CallFunctionAsync()
77 napi_delete_reference(data->env_, recv); in CallFunctionAsync()
103 [descriptor](napi_env env, napi_ref *recv, int &argc, napi_value *argv) { in OnTaskDone() argument
104 *recv = descriptor.this_; in OnTaskDone()
112 [descriptor, errMsg](napi_env env, napi_ref *recv, int &argc, napi_value *argv) { in OnTaskDone() argument
113 *recv = descriptor.this_; in OnTaskDone()
|
| /ohos5.0/base/request/request/services/src/manage/ |
| H A D | notifier.rs | 225 let info = client_rx.recv().await.unwrap(); in ut_notify_progress()
235 let info = client_rx.recv().await.unwrap(); in ut_notify_progress()
282 let info = client_rx.recv().await.unwrap(); in ut_notify_pause_resume()
295 let info = client_rx.recv().await.unwrap(); in ut_notify_pause_resume()
332 let info = client_rx.recv().await.unwrap(); in ut_notify_remove()
370 let info = client_rx.recv().await.unwrap(); in ut_notify_completed()
408 let info = client_rx.recv().await.unwrap(); in ut_notify_failed()
448 let info = client_rx.recv().await.unwrap(); in ut_notify_pause_resume_completed()
453 let info = client_rx.recv().await.unwrap(); in ut_notify_pause_resume_completed()
486 let info = client_rx.recv().await.unwrap(); in ut_notify_pause_resume_failed()
[all …]
|
| /ohos5.0/foundation/communication/netmanager_base/frameworks/js/napi/netpolicy/src/ |
| H A D | napi_net_policy.cpp | 146 napi_value recv = nullptr; in CompleteSetPolicyByUid() local
149 napi_get_undefined(env, &recv); in CompleteSetPolicyByUid()
183 napi_value recv = nullptr; in CompleteGetUidsByPolicy() local
186 napi_get_undefined(env, &recv); in CompleteGetUidsByPolicy()
210 napi_value recv = nullptr; in CompleteGetPolicyByUid() local
213 napi_get_undefined(env, &recv); in CompleteGetPolicyByUid()
255 napi_value recv = nullptr; in CompleteNetPolicyResultCode() local
258 napi_get_undefined(env, &recv); in CompleteNetPolicyResultCode()
285 napi_value recv = nullptr; in CompleteOn() local
313 napi_value recv = nullptr; in CompleteOff() local
[all …]
|
| /ohos5.0/foundation/arkui/ace_engine/interfaces/napi/kits/measure/ |
| H A D | js_measure.cpp | 104 ResourceInfo recv; in HandleIntStyle() local
105 if (!ParseResourceParam(env, fontStyleNApi, recv)) { in HandleIntStyle()
108 if (!ParseString(recv, fontStyleStr)) { in HandleIntStyle()
134 ResourceInfo recv; in HandleStringType() local
135 if (!ParseResourceParam(env, ParameterNApi, recv)) { in HandleStringType()
138 if (!ParseString(recv, ParameterStr)) { in HandleStringType()
168 ResourceInfo recv; in HandleDimensionType() local
169 if (!ParseResourceParam(env, ParameterNApi, recv)) { in HandleDimensionType()
172 if (!ParseString(recv, ParameterStr)) { in HandleDimensionType()
175 if (!ParseIntegerToString(recv, ParameterStr)) { in HandleDimensionType()
|
| /ohos5.0/foundation/arkui/ui_lite/test/autotest/src/ |
| H A D | tcp_socket_manager.cpp | 124 void TcpSocketClientManager::RecvMsg(QByteArray recv) in RecvMsg() argument
126 std::shared_ptr<QByteArray> recvmsg = std::make_shared<QByteArray>(recv); in RecvMsg()
131 void TcpSocketClientManager::OnGetMsgInfo(const std::shared_ptr<QByteArray> recv) in OnGetMsgInfo() argument
134 QJsonDocument document = QJsonDocument::fromJson(recv->toStdString().data(), &parseError); in OnGetMsgInfo()
287 std::shared_ptr<QByteArray> recv = recv_.front(); in OnRunRecvMsg() local
290 OnGetMsgInfo(recv); in OnRunRecvMsg()
|
| /ohos5.0/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcameradata/feedingsmoother/derived/ |
| H A D | dcamera_time_statistician.cpp | 28 int64_t trans = frameInfo.timePonit.recv - frameInfo.timePonit.send + frameInfo.offset; in CalProcessTime()
32 int64_t recv2Feed = frameInfo.timePonit.startSmooth - frameInfo.timePonit.recv; in CalProcessTime()
40 SetRecvTime(frameInfo.timePonit.recv); in CalProcessTime()
54 int64_t source = frameInfo.timePonit.finishSmooth - frameInfo.timePonit.recv; in CalWholeProcessTime()
|
| /ohos5.0/base/msdp/device_status/test/fuzztest/ipcsocket_fuzzer/ |
| H A D | ipcsocket_fuzzer.cpp | 67 auto recv = [](const NetPacket &pkt) { in SocketConnectionFuzzTest() local
77 SocketConnection socketConnection(1, recv, onDisconnected); in SocketConnectionFuzzTest()
85 Msdp::DeviceStatus::SocketConnection::Connect(socket, recv, onDisconnected); in SocketConnectionFuzzTest()
|
| /ohos5.0/docs/zh-cn/application-dev/performance/ |
| H A D | application-performance-analysis.md | 319 hdc file recv /data/app/el2/100/base/com.ohos.example/files/com.ohos.example_次数.cpuprofile ./
321 hdc file recv /data/app/el2/0/base/com.ohos.example/files/com.ohos.example_次数.cpuprofile ./
327 … hdc file recv /data/app/el2/100/base/com.ohos.example/files/com.ohos.example_线程id_次数.cpuprofile ./
329 hdc file recv /data/app/el2/0/base/com.ohos.example/files/com.ohos.example_线程id_次数.cpuprofile ./
362 hdc file recv /data/app/el2/100/base/com.ohos.example/files/filename.json ./filename.cpuprofile
365 hdc file recv /data/app/el2/0/base/com.ohos.example/files/filename.json ./filename.cpuprofile
|
| /ohos5.0/base/request/request/services/src/service/run_count/ |
| H A D | manager.rs | 94 let recv = match self.rx.recv().await { in run() localVariable
102 match recv { in run()
|