| /foundation/deviceprofile/device_info_manager/old/services/core/src/contentsensor/ |
| H A D | content_sensor_manager.cpp | 45 std::list<std::shared_ptr<ContentCollector>> taskList; in Collect()
46 taskList.push_back(std::make_shared<DeviceInfoCollector>()); in Collect()
47 taskList.push_back(std::make_shared<SystemInfoCollector>()); in Collect()
48 taskList.push_back(std::make_shared<SyscapInfoCollector>()); in Collect()
49 taskList.push_back(std::make_shared<StorageInfoCollector>()); in Collect()
50 taskList.push_back(std::make_shared<AppInfoCollector>()); in Collect()
51 taskList.push_back(std::make_shared<PasteboardInfoCollector>()); in Collect()
53 for (auto& task : taskList) { in Collect()
|
| /foundation/deviceprofile/device_info_manager/services/core/src/contentsensormanager/ |
| H A D | content_sensor_manager.cpp | 59 std::list<std::shared_ptr<Collector>> taskList; in Collect()
60 taskList.push_back(std::make_shared<SystemInfoCollector>()); in Collect()
61 taskList.push_back(std::make_shared<SyscapInfoCollector>()); in Collect()
62 taskList.push_back(std::make_shared<DmsInfoCollector>()); in Collect()
63 taskList.push_back(std::make_shared<CollaborationInfoCollector>()); in Collect()
64 taskList.push_back(std::make_shared<PasteboardInfoCollector>()); in Collect()
65 taskList.push_back(std::make_shared<SwitchStatusCollector>()); in Collect()
69 for (const auto& task : taskList) { in Collect()
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/core/coap_discover/ |
| H A D | coap_app.c | 85 EpollTask taskList[3 * MAX_COAP_SOCKET_NUM]; member
265 ctx->taskList[i].taskfd = sockets[i]->fd; in GetTimeout()
266 ctx->taskList[i].epollfd = epollfd; in GetTimeout()
267 ctx->taskList[i].readHandle = CoAPEpollReadHandle; in GetTimeout()
268 ctx->taskList[i].writeHandle = CoAPEpollWriteHandle; in GetTimeout()
269 ctx->taskList[i].errorHandle = CoAPEpollErrorHandle; in GetTimeout()
270 ctx->taskList[i].ptr = sockets[i]; in GetTimeout()
273 (void)memcpy_s(&info->taskList[info->count], sizeof(info->taskList[info->count]), in GetTimeout()
274 &ctx->taskList[ in GetTimeout()
[all...] |
| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/ |
| H A D | nstackx_file_manager.c | 248 if (PthreadMutexLock(&fileManager->taskList.lock) != 0) { in PrepareOneTaskByStatus()
253 LIST_FOR_EACH_SAFE(pos, tmp, &fileManager->taskList.head) { in PrepareOneTaskByStatus()
264 fileManager->taskList.size--; in PrepareOneTaskByStatus()
271 if (PthreadMutexUnlock(&fileManager->taskList.lock) != 0) { in PrepareOneTaskByStatus()
942 if (PthreadMutexLock(&fileManager->taskList.lock) != 0) { in WakeAllThread()
946 LIST_FOR_EACH(list, &fileManager->taskList.head) { in WakeAllThread()
952 if (PthreadMutexUnlock(&fileManager->taskList.lock) != 0) { in WakeAllThread()
1070 FileListTask *GetFileListById(MutexList *taskList, uint16_t transId, uint8_t *isErrorOccurred) in GetFileListById() argument
1078 if (taskList == NULL) { in GetFileListById()
1081 if (PthreadMutexLock(&taskList in GetFileListById()
1108 GetFileBlockListSize(MutexList *taskList, uint32_t *recvListAllSize, uint32_t *recvInnerAllSize) GetFileBlockListSize() argument
[all...] |
| H A D | nstackx_dfile_retransmission.c | 43 if (GetFileBlockListSize(&dFileTrans->fileManager->taskList, &recvListAllSize, &recvInnerAllSize) != NSTACKX_EOK) { in SendBackPressureFrame()
|
| H A D | nstackx_file_manager_client.c | 812 if (fileManager->taskList.size >= fileManager->taskList.maxSize) { in FileManagerSendFileTask()
841 if (MutexListAddNode(&fileManager->taskList, &fmFileList->list, NSTACKX_FALSE) != NSTACKX_EOK) { in FileManagerSendFileTask()
908 fileList = GetFileListById(&fileManager->taskList, transId, &isErrorOccurred); in FileManagerResetSendOutSet()
1121 fileList = GetFileListById(&fileManager->taskList, transId, &isErrorOccurred); in FileManagerIsLastBlockRead()
1151 if (PthreadMutexLock(&fileManager->taskList.lock) != 0) { in FileManagerHasPendingDataMp()
1158 LIST_FOR_EACH(list, &fileManager->taskList.head) { in FileManagerHasPendingDataMp()
1183 if (PthreadMutexUnlock(&fileManager->taskList.lock) != 0) { in FileManagerHasPendingDataMp()
1202 if (PthreadMutexLock(&fileManager->taskList.lock) != 0) { in FileManagerHasPendingDataInner()
1209 LIST_FOR_EACH(list, &fileManager->taskList in FileManagerHasPendingDataInner()
[all...] |
| /foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/include/coap_discover/ |
| H A D | coap_app.h | 36 EpollTask taskList[MAX_COAP_SOCKET_NUM]; member
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/liteos/ |
| H A D | sys_epoll.c | 57 List taskList; member
183 LIST_FOR_EACH(curr, &(ptr->taskList)) { in EpollTaskListFind()
217 ListInsertTail(&(ptr->taskList), &(taskListPtr->list)); in EpollEventTaskListAdd()
242 LIST_FOR_EACH(curr, &(ptr->taskList)) { in EpollTaskFindByFd()
392 ListInitHead(&(ptr->taskList)); in EpollEventRecordAdd()
892 LIST_FOR_EACH_SAFE(pos, tmp, &(ptr->taskList)) {
|
| /foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/include/ |
| H A D | nstackx_file_manager.h | 237 MutexList taskList; /* DATA:FileListTask */ member
457 FileListTask *GetFileListById(MutexList *taskList, uint16_t transId, uint8_t *isErrorOccurred);
460 int32_t GetFileBlockListSize(MutexList *taskList, uint32_t *recvListAllSize, uint32_t *recvInnerAllSize);
|