Home
last modified time | relevance | path

Searched refs:recv (Results 1 – 25 of 42) sorted by relevance

12

/foundation/communication/netmanager_base/frameworks/js/napi/netconn/src/
Dnapi_net_conn_observer.cpp29 napi_value recv = nullptr; in OnNetAvailableEvent() local
33 napi_get_undefined(listen.env, &recv); in OnNetAvailableEvent()
36 …napi_call_function(listen.env, recv, callbackFunc, std::size(callbackValues), callbackValues, &res… in OnNetAvailableEvent()
44 napi_value recv = nullptr; in OnNetCapabilitiesChangeEvent() local
52 napi_get_undefined(listen.env, &recv); in OnNetCapabilitiesChangeEvent()
55 …napi_call_function(listen.env, recv, callbackFunc, std::size(callbackValues), callbackValues, &res… in OnNetCapabilitiesChangeEvent()
63 napi_value recv = nullptr; in OnNetConnectionPropertiesChangeEvent() local
71 napi_get_undefined(listen.env, &recv); in OnNetConnectionPropertiesChangeEvent()
74 …napi_call_function(listen.env, recv, callbackFunc, std::size(callbackValues), callbackValues, &res… in OnNetConnectionPropertiesChangeEvent()
81 napi_value recv = nullptr; in OnNetLostEvent() local
[all …]
Dnapi_net_conn.cpp423 napi_value recv = nullptr; in CompleteNetDetection() local
426 napi_get_undefined(env, &recv); in CompleteNetDetection()
433 … napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteNetDetection()
513 napi_value recv = nullptr; in CompleteBindSocket() local
516 napi_get_undefined(env, &recv); in CompleteBindSocket()
523 … napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteBindSocket()
622 napi_value recv = nullptr; in CompleteGetAddressesByName() local
625 napi_get_undefined(env, &recv); in CompleteGetAddressesByName()
632 … napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteGetAddressesByName()
727 napi_value recv = nullptr; in CompleteGetAddressByName() local
[all …]
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/fillp/
Dfillp_common.c385 pack.lostSeq = pcb->recv.seqNum; in FillpSendAdhocpack()
397 struct SkipList *recvList = &pcb->recv.recvList; in FillpUploadRecvBox()
415 if (start_seq != pcb->recv.seqNum) { in FillpUploadRecvBox()
422 pcb->recv.seqNum = item->seqNum; in FillpUploadRecvBox()
423 pcb->recv.recvBytes -= item->dataLen; in FillpUploadRecvBox()
442 if ((pcb->recv.pktNum - pcb->recv.lastPackPktNum) >= ADHOC_PACK_TRIGGLE_THRESHOLD) { in FillpUploadRecvBox()
444 FILLP_GET_SOCKET(pcb)->index, pcb->recv.pktNum, pcb->recv.lastPackPktNum, in FillpUploadRecvBox()
445 (pcb->recv.pktNum - pcb->recv.lastPackPktNum), pcb->mpRecvSize); in FillpUploadRecvBox()
512 pktHead->seqNum = FILLP_HTONL(pcb->recv.seqNum); in FillpSendNack()
515 (startPktNum - 1), pcb->recv.seqNum); in FillpSendNack()
[all …]
Dfillp_input.c160 if (!FillpNumIsbigger(item->seqNum, pcb->recv.seqNum)) { in FillpProcessItemData()
162 pcb->recv.seqNum, item->seqNum, item->pktNum); in FillpProcessItemData()
170 …if (SkipListInsert(&pcb->recv.recvBoxPlaceInOrder, (void *)item, &item->skipListNode, FILLP_TRUE))… in FillpProcessItemData()
177 if (pcb->recv.recvBoxPlaceInOrder.nodeNum >= g_resource.common.recvCachePktNumBufferSize) { in FillpProcessItemData()
178 struct FillpPcbItem *itemPre = SkipListPopValue(&pcb->recv.recvBoxPlaceInOrder); in FillpProcessItemData()
203 …if (FillpNumIsbigger(item->seqNum, (pcb->recv.seqNum + pcb->recv.pktRecvCache + privRecvCacheSize)… in FillpDataInput()
206 (pcb->recv.seqNum + pcb->recv.pktRecvCache + privRecvCacheSize)); in FillpDataInput()
252 node = SkipListGetPop(&pcb->recv.recvList); in ProcessPcbItem()
254 FILLP_UINT32 lostSeqNum = pcb->recv.seqNum; in ProcessPcbItem()
262 … FILLP_GET_SOCKET(pcb)->index, pktHdr->seqNum, pktHdr->pktNum, pcb->recv.seqNum, lostSeqNum, in ProcessPcbItem()
[all …]
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()
142 pcb->recv.prePackPktNum = packStastics->packPktNum; in FillpCalRecvRate()
143 packStastics->packPktNum = pcb->recv.pktNum; in FillpCalRecvRate()
Dfillp_conn.c65 if ((pcb->recv.seqNum == pcb->recv.seqStartNum) && (pcb->send.maxAckNumFromReceiver == in FillpConnReqStateCheck()
477 …newConn->pcb->fpcb.recv.pktRecvCache = (FILLP_UINT32)maxRecvCache * (FILLP_UINT32)newConn->pcb->fp… in FillpInitNewPcbByNewConn()
480 if (((newConn->pcb->fpcb.recv.pktRecvCache / newConn->pcb->fpcb.pktSize) != maxRecvCache) || in FillpInitNewPcbByNewConn()
505 newConn->pcb->fpcb.recv.lastPackPktNum = confirm->cookieContent.remotePacketSeqNumber; in FillpInitNewPcbByConfirm()
506 newConn->pcb->fpcb.recv.lastPackSeqNum = confirm->cookieContent.remoteMessageSeqNumber; in FillpInitNewPcbByConfirm()
512 newConn->pcb->fpcb.recv.prePackPktNum = confirm->cookieContent.remotePacketSeqNumber; in FillpInitNewPcbByConfirm()
513 newConn->pcb->fpcb.recv.pktNum = confirm->cookieContent.remotePacketSeqNumber; in FillpInitNewPcbByConfirm()
514 newConn->pcb->fpcb.recv.seqNum = confirm->cookieContent.remoteMessageSeqNumber; in FillpInitNewPcbByConfirm()
515 newConn->pcb->fpcb.recv.pktStartNum = confirm->cookieContent.remotePacketSeqNumber; in FillpInitNewPcbByConfirm()
516 newConn->pcb->fpcb.recv.seqStartNum = confirm->cookieContent.remoteMessageSeqNumber; in FillpInitNewPcbByConfirm()
[all …]
Dfillp_output.c454 pack.lostSeq = pcb->recv.seqNum; in FillpSendAdhocpackToDetectRtt()
469 pack->oppositeSetRate = pcb->recv.oppositeSetRate; in FillpSetSimplePack()
506 node = SkipListGetPop(&pcb->recv.recvList); in FillpSendPack()
511 pack->lostSeq = pcb->recv.seqNum; in FillpSendPack()
/foundation/communication/netmanager_base/frameworks/js/napi/netpolicy/src/
Dnapi_net_policy_observer.cpp31 napi_value recv = nullptr; in OnNetUidPolicyEvent() local
38 napi_get_undefined(eventListener.env, &recv); in OnNetUidPolicyEvent()
41 …napi_call_function(eventListener.env, recv, callbackFunc, std::size(callbackValues), callbackValue… in OnNetUidPolicyEvent()
Dnapi_net_policy.cpp151 napi_value recv = nullptr; in CompleteSetPolicyByUid() local
154 napi_get_undefined(env, &recv); in CompleteSetPolicyByUid()
161 … napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteSetPolicyByUid()
188 napi_value recv = nullptr; in CompleteGetUidsByPolicy() local
191 napi_get_undefined(env, &recv); in CompleteGetUidsByPolicy()
194 … napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteGetUidsByPolicy()
215 napi_value recv = nullptr; in CompleteGetPolicyByUid() local
218 napi_get_undefined(env, &recv); in CompleteGetPolicyByUid()
221 … napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteGetPolicyByUid()
260 napi_value recv = nullptr; in CompleteNetPolicyResultCode() local
[all …]
/foundation/communication/netmanager_base/frameworks/js/napi/netstats/src/
Dnet_stats_callback.cpp24 napi_value recv = nullptr; in OnNetStatsChangeEvent() local
27 napi_get_undefined(env, &recv); in OnNetStatsChangeEvent()
30 napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in OnNetStatsChangeEvent()
Dnapi_net_stats.cpp106 napi_value recv = nullptr; in CompleteGetBytes() local
109 napi_get_undefined(env, &recv); in CompleteGetBytes()
112 … napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteGetBytes()
185 napi_value recv = nullptr; in CompleteUpdateIfacesStats() local
188 napi_get_undefined(env, &recv); in CompleteUpdateIfacesStats()
194 … napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteUpdateIfacesStats()
221 napi_value recv = nullptr; in CompleteUpdateStatsData() local
224 napi_get_undefined(env, &recv); in CompleteUpdateStatsData()
230 … napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteUpdateStatsData()
/foundation/communication/netmanager_ext/frameworks/js/napi/ethernet/src/
Dnapi_ethernet.cpp101 napi_value recv = nullptr; in CompleteSetIfaceConfig() local
104 napi_get_undefined(env, &recv); in CompleteSetIfaceConfig()
111 … napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteSetIfaceConfig()
182 napi_value recv = nullptr; in CompleteGetIfaceConfig() local
185 napi_get_undefined(env, &recv); in CompleteGetIfaceConfig()
192 … napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteGetIfaceConfig()
226 napi_value recv = nullptr; in CompleteIsIfaceActive() local
229 napi_get_undefined(env, &recv); in CompleteIsIfaceActive()
232 … napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &result); in CompleteIsIfaceActive()
275 napi_value recv = nullptr; in CompleteGetAllActiveIfaces() local
[all …]
/foundation/communication/bluetooth/interfaces/innerkits/native_cpp/framework/src/
Dbluetooth_socket_inputstream.cpp37 auto ret = recv(socketFd_, buf, length, MSG_NOSIGNAL); in Read()
Dbluetooth_socket.cpp78 int recvBufSize = recv(fd_, recvStateBuf, sizeof(recvStateBuf), 0); in RecvSocketSignal()
80 int recvBufSize = recv(fd_, recvStateBuf, sizeof(recvStateBuf), MSG_WAITALL); in RecvSocketSignal()
90 int recvAddrSize = recv(fd_, buf, sizeof(buf), 0); in RecvSocketSignal()
92 int recvAddrSize = recv(fd_, buf, sizeof(buf), MSG_WAITALL); in RecvSocketSignal()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
Dpcb.c35 …FillpErrorType err = FillpQueuePush(conn->pcb->fpcb.recv.recvBox, buf, FILLP_TRUE, (FILLP_UINT)cou… in SpungePcbRecv()
223 pcb->rateControl.recv.curMaxRateLimitation = 0; in SpungePcbNew()
224 pcb->rateControl.recv.weight = 0; in SpungePcbNew()
259 pcb->fpcb.recv.oppositeSetRate = rate; in SpungePcbSetOppositeRate()
Dspunge_core.c292 inst->rateControl.recv.maxRate = g_resource.flowControl.maxRecvRate; in SpungeInstSendInit()
1039 if (calcRecvTotalRate > inst->rateControl.recv.maxRate) { in FillpServerRecvRateAdjustment()
1040 calcRecvTotalRate = inst->rateControl.recv.maxRate; in FillpServerRecvRateAdjustment()
1048 *connRecvCalLimit = inst->rateControl.recv.maxRate; in FillpServerRecvRateAdjustment()
1162 pcb->rateControl.recv.curMaxRateLimitation = connRecvCalLimit; in FillpCalculateFairness()
1163 pcb->fpcb.recv.oppositeSetRate = pcb->rateControl.recv.curMaxRateLimitation; in FillpCalculateFairness()
1199 nackList = &(pcb->fpcb.recv.nackList); in FillpCheckPcbNackListToSend()
1627 struct FillpPcbItem *item = SkipListPopValue(&pcb->recv.recvBoxPlaceInOrder); in SpungePushRecvdDataToStack()
1630 item = SkipListPopValue(&pcb->recv.recvBoxPlaceInOrder); in SpungePushRecvdDataToStack()
/foundation/communication/wifi/tests/wifi_standard/wifi_framework/dhcp_manage/dhcp_server/unittest/
Ddhcp_server_test.cpp668 DhcpMsgInfo recv, repl; variable
669 ASSERT_TRUE(memset_s(&recv, sizeof(DhcpMsgInfo), 0, sizeof(DhcpMsgInfo)) == EOK);
671 EXPECT_EQ(RET_ERROR, FillReply(&tempCtx, &recv, nullptr));
672 EXPECT_EQ(RET_FAILED, FillReply(&tempCtx, &recv, &repl));
673 recv.packet.flags = 1;
677 recv.packet.siaddr = ParseIpAddr("192.168.189.252");
679 recv.packet.giaddr = ParseIpAddr("192.168.189.254");
680 EXPECT_EQ(RET_SUCCESS, FillReply(&tempCtx, &recv, &repl));
681 recv.packet.giaddr = 0;
682 EXPECT_EQ(RET_SUCCESS, FillReply(&tempCtx, &recv, &repl));
/foundation/communication/dsoftbus/components/nstackx/fillp/src/public/include/
Dsockets.h158 #define SOCK_GET_RECVBOX(_sock) ((_sock)->netconn->pcb->fpcb.recv.recvBox)
168 #define SOCK_GET_RECVSEM(_sock) ((_sock)->netconn->pcb->fpcb.recv.recvSem)
Dspunge.h76 struct SpungeServerRateControlItem recv; member
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/
Dpcb.h38 struct SpungePcbRateControlItem recv; member
Dsysio.h30 void *(*recv)(void *arg, FILLP_CONST void *buf, void *databuf); member
/foundation/communication/netmanager_base/frameworks/js/napi/common/
Dnapi_common.cpp291 napi_value recv = CreateUndefined(env); in Handle1ValueCallback() local
297 …env, napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &resul… in Handle1ValueCallback()
328 napi_value recv = CreateUndefined(env); in Handle2ValueCallback() local
336 …env, napi_call_function(env, recv, callbackFunc, std::size(callbackValues), callbackValues, &resul… in Handle2ValueCallback()
/foundation/graphic/standard/utils/socketpair/src/
Dlocal_socketpair.cpp125 length = recv(receiveFd_, vaddr, size, MSG_DONTWAIT); in ReceiveData()
/foundation/communication/netstack/utils/napi_utils/include/
Dnetstack_napi_utils.h79 napi_value CallFunction(napi_env env, napi_value recv, napi_value func, size_t argc, const napi_val…
/foundation/communication/dsoftbus/adapter/common/bus_center/network/
Dlnn_netlink_monitor.c149 len = recv(sockFd, buffer, DEFAULT_NETLINK_RECVBUF, 0); in NetlinkMonitorThread()

12