Searched refs:sendBlockFrameListPara (Results 1 – 3 of 3) sorted by relevance
457 …SendBlockFrameListPara *para = &fileManager->sendBlockFrameListPara[fileList->bindedSendBlockListI… in PushFileBlockFrame()794 if (fileManager->sendBlockFrameListPara[i].bandingTransNum < bindingNum) { in GetTargetSendBlockListIdx()795 bindingNum = fileManager->sendBlockFrameListPara[i].bandingTransNum; in GetTargetSendBlockListIdx()849 fileManager->sendBlockFrameListPara[fmFileList->bindedSendBlockListIdx].bandingTransNum++; in FileManagerSendFileTask()954 para = &fileManager->sendBlockFrameListPara[tid]; in GetSendBlockFrameListPara()961 para = &fileManager->sendBlockFrameListPara[i]; in GetSendBlockFrameListPara()1051 para = &fileManager->sendBlockFrameListPara[i]; in InitSendBlockLists()1062 para = &fileManager->sendBlockFrameListPara[i - 1]; in InitSendBlockLists()1093 para = &fileManager->sendBlockFrameListPara[i]; in ClearSendFrameList()1147 if (fileManager->sendBlockFrameListPara[socketIndex].sendBlockFrameList.size > 0) { in FileManagerHasPendingDataMp()[all …]
949 para = &fileManager->sendBlockFrameListPara[fileList->bindedSendBlockListIdx]; in WakeAllThread()1190 … if (fileManager->sendBlockFrameListPara[fileList->bindedSendBlockListIdx].bandingTransNum > 0) { in FileManagerStopTask()1191 … fileManager->sendBlockFrameListPara[fileList->bindedSendBlockListIdx].bandingTransNum--; in FileManagerStopTask()1330 para = &fileManager->sendBlockFrameListPara[i]; in AtomicParameterInit()1341 para = &fileManager->sendBlockFrameListPara[i - 1]; in AtomicParameterInit()1353 SemDestroy(&fileManager->sendBlockFrameListPara[i].semBlockListNotFull); in AtomicParameterDestory()1450 MutexListDestory(&fileManager->sendBlockFrameListPara[i].sendBlockFrameList); in FileManagerCreate()1451 fileManager->sendBlockFrameListPara[i].sendRetranListTail = NULL; in FileManagerCreate()
248 SendBlockFrameListPara sendBlockFrameListPara[NSTACKX_MAX_CLIENT_SEND_THREAD_NUM]; member