Home
last modified time | relevance | path

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

1234

/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...]
/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/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/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...]
H A Dfillp_input.c42 /* init the sock->transmit by current transmit when recv the fist data packet */ in FillpCalRecvJitter()
161 if (!FillpNumIsbigger(item->seqNum, pcb->recv.seqNum)) { in FillpProcessItemData()
168 if (SkipListInsert(&pcb->recv.recvBoxPlaceInOrder, (void *)item, &item->skipListNode, FILLP_TRUE)) { in FillpProcessItemData()
175 if (pcb->recv.recvBoxPlaceInOrder.nodeNum >= g_resource.common.recvCachePktNumBufferSize) { in FillpProcessItemData()
176 struct FillpPcbItem *itemPre = SkipListPopValue(&pcb->recv.recvBoxPlaceInOrder); 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 in ProcessPcbItem()
[all...]
H A Dfillp_timer.c58 FILLP_UINT32 pktData = pcb->recv.pktNum - appFcStastics->pktNum; in FillpCalFcAppStastics()
67 FILLP_GET_SOCKET(pcb)->index, pcb->recv.pktNum, appFcStastics->pktNum, in FillpCalFcAppStastics()
94 appFcStastics->pktNum = pcb->recv.pktNum; in FillpCalFcAppStastics()
107 FILLP_UINT32 pktData = pcb->recv.pktNum - packStastics->packPktNum; in FillpCalRecvRate()
130 "total_recvd_count: %u recv rate: %u pack input interval: %lld", in FillpCalRecvRate()
142 pcb->recv.prePackPktNum = packStastics->packPktNum; in FillpCalRecvRate()
143 packStastics->packPktNum = pcb->recv.pktNum; in FillpCalRecvRate()
H A Dfillp_conn.c67 if ((pcb->recv.seqNum == pcb->recv.seqStartNum) && (pcb->send.maxAckNumFromReceiver == in FillpConnReqStateCheck()
129 FILLP_LOGINF("fillp_sock_id:%d recv cache or sendCache size or timestamp is not correct" in FillpConnReqInput()
500 newConn->pcb->fpcb.recv.pktRecvCache = (FILLP_UINT32)maxRecvCache * (FILLP_UINT32)newConn->pcb->fpcb.pktSize; in FillpInitNewPcbByNewConn()
503 if (((newConn->pcb->fpcb.recv.pktRecvCache / newConn->pcb->fpcb.pktSize) != maxRecvCache) || in FillpInitNewPcbByNewConn()
528 newConn->pcb->fpcb.recv.lastPackPktNum = confirm->cookieContent.remotePacketSeqNumber; in FillpInitNewPcbByConfirm()
529 newConn->pcb->fpcb.recv.lastPackSeqNum = confirm->cookieContent.remoteMessageSeqNumber; in FillpInitNewPcbByConfirm()
535 newConn->pcb->fpcb.recv.prePackPktNum = confirm->cookieContent.remotePacketSeqNumber; in FillpInitNewPcbByConfirm()
536 newConn->pcb->fpcb.recv.pktNum = confirm->cookieContent.remotePacketSeqNumber; in FillpInitNewPcbByConfirm()
537 newConn->pcb->fpcb.recv in FillpInitNewPcbByConfirm()
[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()
H A Djs_component_test_utils.h163 bool CheckAndParseStr(napi_env env, napi_value arg, std::string& recv, std::string& errMsg);
165 bool CheckAndParseInt32(napi_env env, napi_value arg, int32_t& recv, std::string& errMsg);
167 bool CheckAndParseUInt32(napi_env env, napi_value arg, uint32_t& recv, std::string& errMsg);
169 bool CheckAndParseBool(napi_env env, napi_value arg, bool& recv, std::string& errMsg);
/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...]
H A Daction.h210 virtual void Decompose(EventMatrix& recv) const = 0;
231 void Decompose(EventMatrix& recv) const override;
247 void Decompose(EventMatrix& recv) const override;
261 void Decompose(EventMatrix& recv) const override;
272 void Decompose(EventMatrix& recv) const override;
284 void Decompose(EventMatrix& recv) const override;
/foundation/multimodalinput/input/intention/ipc/socket/include/
H A Dsocket_connection.h35 std::function<void(NetPacket&)> recv,
47 std::function<void(NetPacket&)> recv, std::function<void()> onDisconnected);
/foundation/arkui/ace_engine/interfaces/napi/kits/measure/
H A Djs_measure.cpp90 ResourceInfo recv; in HandleIntStyle() local
91 if (!ParseResourceParam(env, fontStyleNApi, recv)) { in HandleIntStyle()
94 if (!ParseString(recv, fontStyleStr)) { in HandleIntStyle()
120 ResourceInfo recv; in HandleStringType() local
121 if (!ParseResourceParam(env, ParameterNApi, recv)) { in HandleStringType()
124 if (!ParseString(recv, ParameterStr)) { in HandleStringType()
154 ResourceInfo recv; in HandleDimensionType() local
155 if (!ParseResourceParam(env, ParameterNApi, recv)) { in HandleDimensionType()
158 if (!ParseString(recv, ParameterStr)) { in HandleDimensionType()
161 if (!ParseIntegerToString(recv, ParameterSt in HandleDimensionType()
[all...]
/foundation/distributedhardware/distributed_camera/services/cameraservice/sourceservice/src/distributedcameramgr/dcameradata/feedingsmoother/derived/
H A Ddcamera_time_statistician.cpp28 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()
/foundation/communication/netmanager_base/frameworks/js/napi/netpolicy/src/
H A Dnapi_net_policy.cpp146 napi_value recv = nullptr; in CompleteSetPolicyByUid() local
149 napi_get_undefined(env, &recv); in CompleteSetPolicyByUid()
156 napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteSetPolicyByUid()
183 napi_value recv = nullptr; in CompleteGetUidsByPolicy() local
186 napi_get_undefined(env, &recv); in CompleteGetUidsByPolicy()
189 napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteGetUidsByPolicy()
210 napi_value recv = nullptr; in CompleteGetPolicyByUid() local
213 napi_get_undefined(env, &recv); in CompleteGetPolicyByUid()
216 napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteGetPolicyByUid()
255 napi_value recv in CompleteNetPolicyResultCode() local
285 napi_value recv = nullptr; CompleteOn() local
313 napi_value recv = nullptr; CompleteOff() local
531 napi_value recv = nullptr; CompleteSetBackgroundPolicy() local
[all...]
/foundation/arkui/ui_lite/test/autotest/src/
H A Dtcp_socket_manager.cpp124 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()
H A Dtcp_socket.cpp98 QByteArray recv = tcpSocket_->readAll(); in OnSocketReadyRead() local
99 tcpSocketManager_->RecvMsg(recv); in OnSocketReadyRead()
/foundation/ability/ability_runtime/test/unittest/js_ability_context_test/
H A Djs_ability_context_test.cpp217 napi_value recv = nullptr; in Connect() local
218 napi_create_object(env_, &recv); in Connect()
219 napi_status wrapret = napi_wrap(env_, recv, jsAbilityContext_.get(), in Connect()
227 napi_call_function(env_, recv, funcValue, argc, argv, &funcResultValue); in Connect()
239 napi_value recv = nullptr; in Disconnect() local
240 napi_create_object(env_, &recv); in Disconnect()
241 napi_status wrapret = napi_wrap(env_, recv, jsAbilityContext_.get(), [](napi_env env, void* data, void* hint) {}, in Disconnect()
248 napi_call_function(env_, recv, funcValue, argc, argv, &funcResultValue); in Disconnect()
/foundation/ability/ability_runtime/test/unittest/js_ui_extension_context_test/
H A Djs_ui_extension_context_test.cpp215 napi_value recv = nullptr; in Connect() local
216 napi_create_object(env_, &recv); in Connect()
217 napi_status wrapret = napi_wrap(env_, recv, jsUIExtensionContext_.get(), in Connect()
225 napi_call_function(env_, recv, funcValue, argc, argv, &funcResultValue); in Connect()
237 napi_value recv = nullptr; in Disconnect() local
238 napi_create_object(env_, &recv); in Disconnect()
239 napi_status wrapret = napi_wrap(env_, recv, jsUIExtensionContext_.get(), in Disconnect()
246 napi_call_function(env_, recv, funcValue, argc, argv, &funcResultValue); in Disconnect()
/foundation/arkui/ui_lite/test/autotest/include/
H A Dtcp_socket_manager.h42 void RecvMsg(QByteArray recv);
62 void OnGetMsgInfo(const std::shared_ptr<QByteArray> recv);
/foundation/communication/bluetooth/frameworks/inner/src/
H A Dbluetooth_socket_inputstream.cpp37 auto ret = recv(socketFd_, buf, length, MSG_NOSIGNAL); in Read()
/foundation/graphic/graphic_2d/rosen/test/2d_graphics/drawing_ndk/cpp/interface/
H A Dpath_test.cpp292 OH_Drawing_Rect* recv = OH_Drawing_RectCreate(l, t, r, b); in OnTestPerformance() local
293 OH_Drawing_RectSetLeft(recv, renderer.nextF()); in OnTestPerformance()
294 OH_Drawing_CanvasDrawOval(canvas, recv); in OnTestPerformance()
298 OH_Drawing_PathAddOvalWithInitialPoint(path, recv, start, PATH_DIRECTION_CW); in OnTestPerformance()
300 OH_Drawing_RectDestroy(recv); // 在循环内部销毁 OH_Drawing_Rect 对象 in OnTestPerformance()
318 OH_Drawing_Rect* recv = OH_Drawing_RectCreate(l, t, r, b); in OnTestPerformance() local
319 OH_Drawing_RectSetLeft(recv, renderer.nextF()); in OnTestPerformance()
320 OH_Drawing_CanvasDrawOval(canvas, recv); in OnTestPerformance()
322 OH_Drawing_PathAddArc(path, recv, renderer.nextF(), renderer.nextF()); in OnTestPerformance()
323 OH_Drawing_RectDestroy(recv); // 在循环内部销毁 OH_Drawing_Rec in OnTestPerformance()
[all...]
/foundation/communication/wifi/wifi/relation_services/wifi_hal_service/wifi_hal_module/wpa_supplicant_hal/
H A Dwifi_wpa_hal.c613 LOGI("recv notify message is NULL"); in WpaP2pCallBackFunc()
686 LOGI("recv notify message is NULL"); in WpaCallBackFuncTwo()
728 LOGI("recv notify message is NULL"); in WpaCallBackFunc()
912 LOGD("wpa recv buf: %{public}s!", buf); in WpaReceiveCallback()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dpcb.c36 FillpErrorType err = FillpQueuePush(conn->pcb->fpcb.recv.recvBox, buf, FILLP_TRUE, (FILLP_UINT)count); in SpungePcbRecv()
227 pcb->rateControl.recv.curMaxRateLimitation = 0; in SpungePcbNew()
228 pcb->rateControl.recv.weight = 0; in SpungePcbNew()
263 pcb->fpcb.recv.oppositeSetRate = rate; in SpungePcbSetOppositeRate()

Completed in 18 milliseconds

1234