| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/ |
| H A D | nstackx_dfile_send.c | 151 ret = SocketSend(session->socket[peerInfo->socketIndex], (void *)f, len); in SendFileDataFrame()
200 PeerInfo *peerInfo = ClientGetPeerInfoBySocketIndex(socketIndex, session); in DoSendDataFrame()
254 PeerInfo *peerInfo = ClientGetPeerInfoBySocketIndex(socketIndex, session); in CheckSendByBackPress()
297 PeerInfo *peerInfo = ClientGetPeerInfoBySocketIndex(socketIndex, session); in SendDataFrame()
307 CheckSendByBackPress(session, tid, socketIndex); in SendDataFrame()
311 ret = DoSendDataFrame(session, &tmpq, count, tid, socketIndex); in SendDataFrame()
340 uint8_t socketIndex = queueNode->socketIndex; in SendControlFrame() local
377 uint32_t socketIndex = queueNode->socketIndex; in SendOutboundFrame() local
378 if (session->socket[socketIndex]->protocol == NSTACKX_PROTOCOL_UDP && in SendOutboundFrame()
379 session->socket[socketIndex]->isServer == NSTACKX_TRUE) { in SendOutboundFrame()
[all …]
|
| H A D | nstackx_dfile_session.c | 87 queueNode->socketIndex = socketIndex; in CreateQueueNode()
260 SemPost(&session->outboundQueueWait[socketIndex]); in WakeSendThread()
604 uint16_t connType, uint8_t socketIndex) in CreatePeerInfo() argument
616 peerInfo->socketIndex = socketIndex; in CreatePeerInfo()
655 uint8_t socketIndex) in AllocPeerInfo() argument
1064 if (peerInfo->socketIndex == 0) { in DFileSendCalculateRate()
1401 struct timespec *before, uint8_t socketIndex) in UpdateInfoAfterSend() argument
1448 if (!session->cycleRunning[socketIndex]) { in DFileSessionSendFrame()
1504 uint8_t socketIndex = ((SenderThreadPara*)arg)->socketIndex; in DFileSenderHandle() local
1518 DFileSenderPre(session, socketIndex); in DFileSenderHandle()
[all …]
|
| H A D | nstackx_dfile_mp.c | 84 PeerInfo *ClientGetPeerInfoBySocketIndex(uint8_t socketIndex, const DFileSession *session) in ClientGetPeerInfoBySocketIndex() argument
91 if (peerInfo->socketIndex == socketIndex) { in ClientGetPeerInfoBySocketIndex()
108 para->socketIndex = 0; in CreateSenderThread()
|
| H A D | nstackx_file_manager_client.c | 468 blockFrame->socketIndex = fileList->socketIndex; in PushFileBlockFrame()
839 fmFileList->socketIndex = peerinfo->socketIndex; in FileManagerSendFileTask()
1137 uint8_t FileManagerHasPendingDataMp(FileManager *fileManager, uint8_t socketIndex) in FileManagerHasPendingDataMp() argument
1147 if (fileManager->sendBlockFrameListPara[socketIndex].sendBlockFrameList.size > 0) { in FileManagerHasPendingDataMp()
1160 if (fileList->socketIndex != socketIndex || CheckFilelistNotStop(fileList) != NSTACKX_EOK) { in FileManagerHasPendingDataMp()
|
| H A D | nstackx_dfile_retransmission.c | 68 peerInfo->socketIndex, dFileTrans->fileManager->recvListOverIo, allSize, in SendBackPressureFrame()
|
| H A D | nstackx_dfile.c | 1013 …c int32_t DFileRecverInit(DFileSession *session, struct sockaddr_in *sockAddr, uint8_t socketIndex) in DFileRecverInit() argument
1035 session->socket[socketIndex] = socket; in DFileRecverInit()
1204 … uint16_t *connType, const char *localInterface, uint8_t socketIndex) in DFileSenderInitWithTargetDev() argument
1223 session->socket[socketIndex] = socket; in DFileSenderInitWithTargetDev()
1240 PeerInfo *peerInfo = CreatePeerInfo(session, &socket->dstAddr, 0, *connType, socketIndex); in DFileSenderInitWithTargetDev()
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_congestion/core/ |
| H A D | nstackx_congestion.c | 56 WifiStationInfo GetGTxWifiStationInfo(uint8_t socketIndex) in GetGTxWifiStationInfo() argument
58 return g_txWifiStationInfo[socketIndex]; in GetGTxWifiStationInfo()
176 uint8_t socketIndex, uint16_t *sendRateResult) in GetConngestSendRate() argument
184 ret = GetWlanConngestSendRate(&g_txWifiStationInfo[socketIndex], in GetConngestSendRate()
187 ret = GetP2pCongestSendRate(&g_txWifiStationInfo[socketIndex], in GetConngestSendRate()
205 …UpdateWifiStationInfo(const char *devName, WifiStationInfo *txWifiStationInfo, uint8_t socketIndex, in UpdateWifiStationInfo() argument
221 if (txWifiStationInfo->txRate != g_txWifiStationInfo[socketIndex].txRate) { in UpdateWifiStationInfo()
222 …"new.txRate %u old.txRate %u", txWifiStationInfo->txRate, g_txWifiStationInfo[socketIndex].txRate); in UpdateWifiStationInfo()
228 return memcpy_s(&g_txWifiStationInfo[socketIndex], sizeof(g_txWifiStationInfo[socketIndex]), in UpdateWifiStationInfo()
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_congestion/interface/ |
| H A D | nstackx_congestion.h | 56 NSTACKX_EXPORT WifiStationInfo GetGTxWifiStationInfo(uint8_t socketIndex);
69 uint8_t socketIndex, int *changeStatus);
71 uint8_t socketIndex, uint16_t *sendRateResult);
|
| /ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/include/ |
| H A D | nstackx_dfile_session.h | 45 uint8_t socketIndex; member
157 uint16_t mtu, uint16_t connType, uint8_t socketIndex);
175 PeerInfo *ClientGetPeerInfoBySocketIndex(uint8_t socketIndex, const DFileSession *session);
178 struct sockaddr_in *peerAddr, uint8_t socketIndex);
|
| H A D | nstackx_dfile_mp.h | 26 uint8_t socketIndex; member
76 PeerInfo *ClientGetPeerInfoBySocketIndex(uint8_t socketIndex, const DFileSession *session);
|
| H A D | nstackx_dfile_send.h | 27 int32_t SendDataFrame(DFileSession *session, List *unsent, uint32_t threadIdx, uint8_t socketIndex);
|
| H A D | nstackx_file_manager.h | 144 uint8_t socketIndex; member
186 uint8_t socketIndex; member
|
| H A D | nstackx_dfile_transfer.h | 217 uint8_t socketIndex; member
|