Home
last modified time | relevance | path

Searched refs:peerInfo (Results 1 - 21 of 21) sorted by relevance

/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/
H A Dnstackx_dfile_session.c339 PeerInfo *peerInfo = dFileTrans->context; in DTransMsgReceiver() local
340 DFileSession *session = peerInfo->session; in DTransMsgReceiver()
346 WakeSendThread(session, dFileTrans->isSender, peerInfo->socketIndex); in DTransMsgReceiver()
380 PeerInfo *peerInfo = data; in ServerSettingTimeoutHandle() local
381 ListRemoveNode(&peerInfo->list); in ServerSettingTimeoutHandle()
382 TimerDelete(peerInfo->settingTimer); in ServerSettingTimeoutHandle()
383 peerInfo->session->peerInfoCnt--; in ServerSettingTimeoutHandle()
384 free(peerInfo); in ServerSettingTimeoutHandle()
390 PeerInfo *peerInfo = data; in ClientSettingTimeoutHandle() local
391 uint8_t cnt = peerInfo in ClientSettingTimeoutHandle()
434 PeerInfo *peerInfo = NULL; SearchPeerInfoNode() local
445 DFileSessionSendSetting(PeerInfo *peerInfo) DFileSessionSendSetting() argument
496 SetDFileSessionConfig(DFileSession *session, DFileConfig *dFileConfig, uint16_t connType, PeerInfo *peerInfo) SetDFileSessionConfig() argument
533 DFileSessionSetPeerInfo(PeerInfo *peerInfo, SettingState state, SettingFrame *settingFrame) DFileSessionSetPeerInfo() argument
553 PeerInfo *peerInfo = SearchPeerInfoNode(session, peerAddr); DFileSessionHandleClientSetting() local
608 PeerInfo *peerInfo = calloc(1, sizeof(PeerInfo)); CreatePeerInfo() local
656 PeerInfo *peerInfo = NULL; AllocPeerInfo() local
687 PeerInfo *peerInfo = SearchPeerInfoNode(session, peerAddr); DFileSessionHandleServerSetting() local
732 PeerInfo *peerInfo = SearchPeerInfoNode(session, peerAddr); HandleWithoutSettingError() local
814 PeerInfo *peerInfo = SearchPeerInfoNode(session, peerAddr); DFileSessionHandleBackPressure() local
833 CreateTrans(uint16_t transId, DFileSession *session, PeerInfo *peerInfo, uint8_t isSender) CreateTrans() argument
857 PeerInfo *peerInfo = SearchPeerInfoNode(session, peerAddr); DFileSessionHandleFrame() local
907 PeerInfo *peerInfo = context; DFileWriteHandle() local
1041 AmendPeerInfoSendRate(PeerInfo *peerInfo) AmendPeerInfoSendRate() argument
1048 DFileSendCalculateRate(DFileSession *session, PeerInfo *peerInfo) DFileSendCalculateRate() argument
1100 UpdateAllTransRetryCount(DFileSession *session, PeerInfo *peerInfo) UpdateAllTransRetryCount() argument
1123 PeerInfo *peerInfo = SearchPeerInfoNode(session, peerAddr); DFileRecvCalculateRate() local
1198 PeerInfo *peerInfo = ClientGetPeerInfoBySocketIndex(socketIndex, session); DFileSenderUpdateMeasureTime() local
1361 UpdatePeerinfoQdiscInfo(PeerInfo *peerInfo, uint32_t qDiscLeft) UpdatePeerinfoQdiscInfo() argument
1375 UpdatePeerinfoAmendSendrateByQdisc(PeerInfo *peerInfo) UpdatePeerinfoAmendSendrateByQdisc() argument
1399 UpdateInfoAfterSend(DFileSession *session, PeerInfo *peerInfo, int32_t curAmendSendRate, struct timespec *before, uint8_t socketIndex) UpdateInfoAfterSend() argument
1437 PeerInfo *peerInfo = ClientGetPeerInfoBySocketIndex(socketIndex, session); DFileSessionSendFrame() local
1888 PeerInfo *peerInfo = TransSelectPeerInfo(session); DFileStartTransInner() local
[all...]
H A Dnstackx_dfile_send.c85 static int32_t TcpSendFileDataFrame(Socket *socket, PeerInfo *peerInfo, List *p, BlockFrame *block, uint16_t len) in TcpSendFileDataFrame() argument
88 DFileSession *session = peerInfo->session; in TcpSendFileDataFrame()
96 NSTACKX_ATOM_FETCH_INC(&peerInfo->sendCount); in TcpSendFileDataFrame()
97 NSTACKX_ATOM_FETCH_INC(&peerInfo->intervalSendCount); in TcpSendFileDataFrame()
100 NSTACKX_ATOM_FETCH_INC(&peerInfo->eAgainCount); in TcpSendFileDataFrame()
104 NSTACKX_ATOM_FETCH_INC(&peerInfo->eAgainCount); in TcpSendFileDataFrame()
114 static void UdpSendFileDataSuccess(DFileSession *session, PeerInfo *peerInfo, List *p, FileDataFrameZS *f, in UdpSendFileDataSuccess() argument
120 NSTACKX_ATOM_FETCH_INC(&peerInfo->sendCount); in UdpSendFileDataSuccess()
121 NSTACKX_ATOM_FETCH_INC(&peerInfo->intervalSendCount); in UdpSendFileDataSuccess()
125 static int32_t SendFileDataFrame(DFileSession *session, PeerInfo *peerInfo, Lis argument
169 SendFileDataFrameEx(DFileSession *session, PeerInfo *peerInfo, List *head, uint32_t tid) SendFileDataFrameEx() argument
200 PeerInfo *peerInfo = ClientGetPeerInfoBySocketIndex(socketIndex, session); DoSendDataFrame() local
254 PeerInfo *peerInfo = ClientGetPeerInfoBySocketIndex(socketIndex, session); CheckSendByBackPress() local
297 PeerInfo *peerInfo = ClientGetPeerInfoBySocketIndex(socketIndex, session); SendDataFrame() local
[all...]
H A Dnstackx_dfile_control.c27 static void SendSessionFileTransferDoneAckFrame(PeerInfo *peerInfo, uint16_t transId) in SendSessionFileTransferDoneAckFrame() argument
35 int32_t ret = DFileWriteHandle(buf, frameLen, peerInfo); in SendSessionFileTransferDoneAckFrame()
38 NotifyMsgRecver(peerInfo->session, DFILE_ON_CONNECT_FAIL, &data); in SendSessionFileTransferDoneAckFrame()
48 PeerInfo *peerInfo = NULL; in DFileSendTransferDoneAck() local
64 peerInfo = ClientGetPeerInfoByTransId(session); in DFileSendTransferDoneAck()
65 if (!peerInfo) { in DFileSendTransferDoneAck()
71 SendSessionFileTransferDoneAckFrame(peerInfo, transferDoneAckNode->transId); in DFileSendTransferDoneAck()
H A Dnstackx_dfile_mp.c72 PeerInfo *peerInfo = (PeerInfo *)ListGetFront(&session->peerInfoChain); in TransSelectPeerInfo() local
73 return peerInfo; in TransSelectPeerInfo()
79 PeerInfo *peerInfo = (PeerInfo *)ListGetFront(&session->peerInfoChain); in ClientGetPeerInfoByTransId() local
80 return peerInfo; in ClientGetPeerInfoByTransId()
86 PeerInfo *peerInfo = NULL; in ClientGetPeerInfoBySocketIndex() local
90 peerInfo = (PeerInfo *)pos; in ClientGetPeerInfoBySocketIndex()
91 if (peerInfo->socketIndex == socketIndex) { in ClientGetPeerInfoBySocketIndex()
92 return peerInfo; in ClientGetPeerInfoBySocketIndex()
H A Dnstackx_dfile_retransmission.c26 PeerInfo *peerInfo = (PeerInfo *)(dFileTrans->context); in SendBackPressureFrame() local
62 int32_t ret = DFileWriteHandle(buf, frameLen, peerInfo); in SendBackPressureFrame()
68 peerInfo->socketIndex, dFileTrans->fileManager->recvListOverIo, allSize, in SendBackPressureFrame()
H A Dnstackx_dfile.c847 session->transSlot[i].peerInfo = NULL; in DFileSessionBaseInit()
985 PeerInfo *peerInfo = NULL; in DFileSessionClean() local
988 peerInfo = (PeerInfo *)pos; in DFileSessionClean()
989 if (peerInfo->settingTimer != NULL) { in DFileSessionClean()
990 TimerDelete(peerInfo->settingTimer); in DFileSessionClean()
991 peerInfo->settingTimer = NULL; in DFileSessionClean()
993 ListRemoveNode(&peerInfo->list); in DFileSessionClean()
994 free(peerInfo); in DFileSessionClean()
1240 PeerInfo *peerInfo = CreatePeerInfo(session, &socket->dstAddr, 0, *connType, socketIndex); in DFileSenderInitWithTargetDev() local
1241 if (peerInfo in DFileSenderInitWithTargetDev()
1266 PeerInfo *peerInfo = (PeerInfo *)pos; DFileSenderDestory() local
1308 PeerInfo *peerInfo = NULL; SendSettingToServer() local
[all...]
H A Dnstackx_dfile_transfer.c844 PeerInfo *peerInfo = dFileTrans->context; in ReceiveFileDataPrepare() local
851 dFileTrans->ackInterval = peerInfo->ackInterval; in ReceiveFileDataPrepare()
/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/include/
H A Dnstackx_dfile_transfer.h271 static inline void ClearPeerinfoStats(PeerInfo *peerInfo) in ClearPeerinfoStats() argument
273 peerInfo->sendCount = 0; in ClearPeerinfoStats()
274 peerInfo->qdiscMinLeft = 0; in ClearPeerinfoStats()
275 peerInfo->qdiscMaxLeft = 0; in ClearPeerinfoStats()
276 peerInfo->qdiscAveLeft = 0; in ClearPeerinfoStats()
277 peerInfo->qdiscSearchNum = 0; in ClearPeerinfoStats()
H A Dnstackx_dfile_session.h69 PeerInfo *peerInfo; member
171 void DFileSessionSendSetting(PeerInfo *peerInfo);
172 void UpdateAllTransRetryCount(DFileSession *session, PeerInfo *peerInfo);
/foundation/communication/wifi/wifi/relation_services/wifi_hal_service/
H A Dwifi_hal_crpc_p2p.c806 P2pDeviceInfo peerInfo; in RpcP2pGetPeer() local
807 if (memset_s(&peerInfo, sizeof(peerInfo), 0, sizeof(peerInfo)) != EOK || in RpcP2pGetPeer()
811 WifiErrorNo err = P2pGetPeer(bssid, &peerInfo); in RpcP2pGetPeer()
815 WriteStr(context, peerInfo.p2pDeviceAddress); in RpcP2pGetPeer()
816 WriteStr(context, peerInfo.deviceName); in RpcP2pGetPeer()
817 WriteStr(context, peerInfo.primaryDeviceType); in RpcP2pGetPeer()
818 WriteInt(context, peerInfo.configMethods); in RpcP2pGetPeer()
819 WriteInt(context, peerInfo in RpcP2pGetPeer()
[all...]
H A Dwifi_hal_p2p_interface.h389 WifiErrorNo P2pGetPeer(const char *bssid, P2pDeviceInfo *peerInfo);
H A Dwifi_hal_p2p_interface.c990 WifiErrorNo P2pGetPeer(const char *bssid, P2pDeviceInfo *peerInfo)
992 if (bssid == NULL || peerInfo == NULL) {
1000 P2pSupplicantErrCode ret = pMainIfc->wpaP2pCliCmdP2pGetPeer(pMainIfc, bssid, peerInfo);
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_native/client/idl_client/idl_interface/
H A Di_wifi_p2p_iface.c973 WifiErrorNo P2pGetPeer(const char *deviceAddress, P2pDeviceInfo *peerInfo) in P2pGetPeer() argument
990 ReadStr(context, peerInfo->p2pDeviceAddress, sizeof(peerInfo->p2pDeviceAddress)); in P2pGetPeer()
991 ReadStr(context, peerInfo->deviceName, sizeof(peerInfo->deviceName)); in P2pGetPeer()
992 ReadStr(context, peerInfo->primaryDeviceType, sizeof(peerInfo->primaryDeviceType)); in P2pGetPeer()
993 ReadInt(context, &peerInfo->configMethods); in P2pGetPeer()
994 ReadInt(context, &peerInfo->deviceCapabilities); in P2pGetPeer()
995 ReadInt(context, &peerInfo in P2pGetPeer()
[all...]
H A Di_wifi_p2p_iface.h394 WifiErrorNo P2pGetPeer(const char *deviceAddress, P2pDeviceInfo *peerInfo);
/foundation/communication/wifi/wifi/test/wifi_standard/wifi_hal/unittest/
H A Dwifi_hal_p2p_interface_test.cpp316 P2pDeviceInfo peerInfo; in HWTEST_F() local
319 EXPECT_TRUE(P2pGetPeer(type, &peerInfo) == WIFI_HAL_FAILED); in HWTEST_F()
324 int peerInfo = 1; in HWTEST_F() local
328 EXPECT_TRUE(P2pGetFrequencies(0, &frequencies, &peerInfo) == WIFI_HAL_NOT_SUPPORT); in HWTEST_F()
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_native/client/hdi_client/
H A Dwifi_hdi_wpa_client.cpp1326 HdiP2pDeviceInfo peerInfo; in ReqGetP2pPeer() local
1327 if (memset_s(&peerInfo, sizeof(peerInfo), 0, sizeof(peerInfo)) != EOK) { in ReqGetP2pPeer()
1330 WifiErrorNo ret = HdiP2pGetPeer(deviceAddress.c_str(), &peerInfo); in ReqGetP2pPeer()
1332 device.SetDeviceAddress((char *)peerInfo.p2pDeviceAddress); in ReqGetP2pPeer()
1333 device.SetDeviceName((char *)peerInfo.deviceName); in ReqGetP2pPeer()
1334 device.SetPrimaryDeviceType((char *)peerInfo.primaryDeviceType); in ReqGetP2pPeer()
1335 device.SetWpsConfigMethod(peerInfo.configMethods); in ReqGetP2pPeer()
1336 device.SetDeviceCapabilitys(peerInfo in ReqGetP2pPeer()
[all...]
/foundation/communication/wifi/wifi/relation_services/wifi_hal_service/wifi_hal_module/wpa_supplicant_hal/wpa_p2p_hal/
H A Dwifi_p2p_hal.c1130 WifiWpaP2pInterface *this, const char *bssid, P2pDeviceInfo *peerInfo) in WpaP2pCliCmdP2pGetPeer()
1132 if (this == NULL || bssid == NULL || peerInfo == NULL) { in WpaP2pCliCmdP2pGetPeer()
1156 StrSafeCopy(peerInfo->p2pDeviceAddress, sizeof(peerInfo->p2pDeviceAddress), token); /* copy first line */ in WpaP2pCliCmdP2pGetPeer()
1161 StrSafeCopy(peerInfo->primaryDeviceType, sizeof(peerInfo->primaryDeviceType), retMsg.value); in WpaP2pCliCmdP2pGetPeer()
1163 StrSafeCopy(peerInfo->deviceName, sizeof(peerInfo->deviceName), retMsg.value); in WpaP2pCliCmdP2pGetPeer()
1165 peerInfo->configMethods = Hex2Dec(retMsg.value); in WpaP2pCliCmdP2pGetPeer()
1167 peerInfo in WpaP2pCliCmdP2pGetPeer()
1129 WpaP2pCliCmdP2pGetPeer( WifiWpaP2pInterface *this, const char *bssid, P2pDeviceInfo *peerInfo) WpaP2pCliCmdP2pGetPeer() argument
[all...]
H A Dwifi_p2p_hal.h79 WifiWpaP2pInterface *p, const char *bssid, P2pDeviceInfo *peerInfo);
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_native/client/idl_client/
H A Dwifi_idl_client.cpp1699 P2pDeviceInfo peerInfo; in ReqGetP2pPeer() local
1700 if (memset_s(&peerInfo, sizeof(peerInfo), 0, sizeof(peerInfo)) != EOK) { in ReqGetP2pPeer()
1703 WifiErrorNo ret = P2pGetPeer(deviceAddress.c_str(), &peerInfo); in ReqGetP2pPeer()
1705 device.SetDeviceAddress(peerInfo.p2pDeviceAddress); in ReqGetP2pPeer()
1706 device.SetDeviceName(peerInfo.deviceName); in ReqGetP2pPeer()
1707 device.SetPrimaryDeviceType(peerInfo.primaryDeviceType); in ReqGetP2pPeer()
1708 device.SetWpsConfigMethod(peerInfo.configMethods); in ReqGetP2pPeer()
1709 device.SetDeviceCapabilitys(peerInfo in ReqGetP2pPeer()
[all...]
/foundation/communication/wifi/wifi/test/wifi_standard/wifi_framework/wifi_manage/idl_client/unittest/
H A Dmock_wifi_hal_service.c732 WifiErrorNo P2pGetPeer(const char *bssid, P2pDeviceInfo *peerInfo) in P2pGetPeer() argument
/foundation/multimedia/media_library/frameworks/js/src/
H A Dmedia_library_napi.cpp4189 unique_ptr<PeerInfo> peerInfo = make_unique<PeerInfo>(); in JSGetActivePeersCompleteCallback() local
4190 if (peerInfo != nullptr) { in JSGetActivePeersCompleteCallback()
4191 peerInfo->deviceName = get<string>(ResultSetUtils::GetValFromColumn(DEVICE_DB_NAME, resultSet, in JSGetActivePeersCompleteCallback()
4193 peerInfo->networkId = get<string>(ResultSetUtils::GetValFromColumn(DEVICE_DB_NETWORK_ID, resultSet, in JSGetActivePeersCompleteCallback()
4195 peerInfo->deviceTypeId = (DistributedHardware::DmDeviceType) in JSGetActivePeersCompleteCallback()
4197 peerInfo->isOnline = true; in JSGetActivePeersCompleteCallback()
4198 peerInfoArray.push_back(move(peerInfo)); in JSGetActivePeersCompleteCallback()
4239 unique_ptr<PeerInfo> peerInfo = make_unique<PeerInfo>(); in JSGetAllPeersCompleteCallback() local
4240 if (peerInfo != nullptr) { in JSGetAllPeersCompleteCallback()
4241 peerInfo in JSGetAllPeersCompleteCallback()
[all...]

Completed in 33 milliseconds