/foundation/communication/dsoftbus/components/nstackx/nstackx_util/core/ |
H A D | nstackx_event.c | 24 EventNode *SearchEventNode(const List *eventNodeChain, EpollDesc epollfd) in SearchEventNode() argument 30 LIST_FOR_EACH_SAFE(pos, tmp, eventNodeChain) { in SearchEventNode() 40 void EventModuleClean(const List *eventNodeChain, EpollDesc epollfd) in EventModuleClean() argument 44 if (eventNodeChain == NULL) { in EventModuleClean() 45 LOGE(TAG, "eventNodeChain is null"); in EventModuleClean() 48 LIST_FOR_EACH(pos, eventNodeChain) { in EventModuleClean() 63 void EventNodeChainClean(List *eventNodeChain) in EventNodeChainClean() argument 69 if (eventNodeChain == NULL) { in EventNodeChainClean() 70 LOGE(TAG, "eventNodeChain is null"); in EventNodeChainClean() 74 LIST_FOR_EACH_SAFE(pos, tmp, eventNodeChain) { in EventNodeChainClean() 82 GetEpollTask(List *eventNodeChain, EpollDesc epollfd) GetEpollTask() argument [all...] |
/foundation/communication/dsoftbus/components/nstackx/nstackx_util/interface/ |
H A D | nstackx_event.h | 36 NSTACKX_EXPORT int32_t PostEvent(const List *eventNodeChain, EpollDesc epollfd, EventHandle handle, void *arg); 37 NSTACKX_EXPORT void ClearEvent(const List *eventNodeChain, EpollDesc epollfd); 38 NSTACKX_EXPORT int32_t EventModuleInit(List *eventNodeChain, EpollDesc epollfd); 39 NSTACKX_EXPORT void EventModuleClean(const List *eventNodeChain, EpollDesc epollfd); 40 NSTACKX_EXPORT void EventNodeChainClean(List *eventNodeChain); 41 NSTACKX_EXPORT EpollTask *GetEpollTask(List *eventNodeChain, EpollDesc epollfd);
|
/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/liteos/ |
H A D | sys_event.c | 29 EventNode *SearchEventNode(const List *eventNodeChain, EpollDesc epollfd); 59 int32_t PostEvent(const List *eventNodeChain, EpollDesc epollfd, EventHandle handle, void *arg) in PostEvent() argument 68 if (eventNodeChain == NULL || handle == NULL) { in PostEvent() 72 node = SearchEventNode(eventNodeChain, epollfd); in PostEvent() 90 void ClearEvent(const List *eventNodeChain, EpollDesc epollfd) in ClearEvent() argument 95 if (eventNodeChain == NULL) { in ClearEvent() 96 LOGE(TAG, "eventNodeChain is null"); in ClearEvent() 100 node = SearchEventNode(eventNodeChain, epollfd); in ClearEvent() 137 int32_t EventModuleInit(List *eventNodeChain, EpollDesc epollfd) in EventModuleInit() argument 141 if (eventNodeChain in EventModuleInit() [all...] |
/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/ |
H A D | sys_event.c | 29 EventNode *SearchEventNode(const List *eventNodeChain, EpollDesc epollfd); 55 int32_t PostEvent(const List *eventNodeChain, EpollDesc epollfd, EventHandle handle, void *arg) in PostEvent() argument 64 if (eventNodeChain == NULL || handle == NULL) { in PostEvent() 68 node = SearchEventNode(eventNodeChain, epollfd); in PostEvent() 82 void ClearEvent(const List *eventNodeChain, EpollDesc epollfd) in ClearEvent() argument 87 if (eventNodeChain == NULL) { in ClearEvent() 88 LOGE(TAG, "eventNodeChain is null"); in ClearEvent() 92 node = SearchEventNode(eventNodeChain, epollfd); in ClearEvent() 140 int32_t EventModuleInit(List *eventNodeChain, EpollDesc epollfd) in EventModuleInit() argument 144 if (eventNodeChain in EventModuleInit() [all...] |
/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/core/ |
H A D | nstackx_dfile.c | 275 if (PostEvent(&node->session->eventNodeChain, node->session->epollfd, DFileSetStoragePathInner, ctx) != in NSTACKX_DFileSetStoragePath() 427 if (PostEvent(&node->session->eventNodeChain, node->session->epollfd, DFileSetStoragePathListInner, ctx) != in NSTACKX_DFileSetStoragePathList() 606 int32_t ret = PostEvent(&node->session->eventNodeChain, node->session->epollfd, DFileSendFileInner, ctx); in SendFilesInner() 749 if (PostEvent(&node->session->eventNodeChain, node->session->epollfd, DFileSendFileFail, ctx) == NSTACKX_EOK) { in PostSendFailAsync() 812 int32_t ret = PostEvent(&node->session->eventNodeChain, node->session->epollfd, DFileSendFileInner, ctx); in NSTACKX_DFileSendFilesWithRemotePathAndType() 833 ListInitHead(&session->eventNodeChain); in DFileSessionBaseInit() 1062 if (EventModuleInit(&session->eventNodeChain, session->epollfd) != NSTACKX_EOK) { in StartDFileThreads() 1071 EventNodeChainClean(&session->eventNodeChain); in StartDFileThreads() 1083 if (PostEvent(&session->eventNodeChain, session->epollfd, TerminateMainThreadInner, session) != NSTACKX_EOK) { in StopDFileThreads() 1108 ClearEvent(&session->eventNodeChain, sessio in StopDFileThreads() [all...] |
H A D | nstackx_file_manager.c | 81 if (PostEvent(fileManager->eventNodeChain, fileManager->epollfd, NotifyFileManagerMsgInner, ctx) != NSTACKX_EOK) { in NotifyFileManagerMsg() 118 if (PostEvent(fileList->eventNodeChain, fileList->epollfd, NotifyFileListMsgInner, ctx) != NSTACKX_EOK) { in NotifyFileListMsg() 141 if (PostEvent(fileList->eventNodeChain, fileList->epollfd, NotifyFileListMsgInner, ctx) != NSTACKX_EOK) { in NotifyFileMsg() 1395 fileManager->eventNodeChain = msgPara->eventNodeChain; in FileManagerInit() 1595 fmFileList->eventNodeChain = fileManager->eventNodeChain; in FileManagerRecvFileTask()
|
H A D | nstackx_dfile_session.c | 1215 if (PostEvent(&session->eventNodeChain, session->epollfd, TerminateMainThreadFatalInner, session) != NSTACKX_EOK) { in PostFatalEvent() 1727 if (PostEvent(&session->eventNodeChain, session->epollfd, ReadEventHandle, session) != NSTACKX_EOK) { in PostReadEventToMainLoop() 1984 if (PostEvent(&session->eventNodeChain, session->epollfd, TerminateMainThreadInner, session) != NSTACKX_EOK) { in StartDFileThreadsInner() 2029 msgPara.eventNodeChain = &session->eventNodeChain; in CreateFileManager()
|
H A D | nstackx_file_manager_client.c | 829 fmFileList->eventNodeChain = fileManager->eventNodeChain; in FileManagerSendFileTask()
|
/foundation/communication/dsoftbus/components/nstackx/nstackx_core/dfile/include/ |
H A D | nstackx_file_manager.h | 185 List *eventNodeChain; member 240 List *eventNodeChain; member 265 List *eventNodeChain; member
|
H A D | nstackx_dfile_session.h | 81 List eventNodeChain; member
|