/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/liteos/ |
H A D | sys_epoll.h | 48 #define REPRESENT_EPOLL_DESC(epollfd) ((epollfd)->recvFd) 50 int32_t CreateEpollFdPair(struct EpollDescStr *epollfd); 52 void CloseEpollDescInner(EpollDesc epollfd); 55 static inline bool IsEpollDescValid(EpollDesc epollfd) in IsEpollDescValid() argument 57 return (epollfd != INVALID_EPOLL_DESC); in IsEpollDescValid() 65 static inline void CloseEpollDesc(EpollDesc epollfd) in CloseEpollDesc() argument 67 CloseEpollDescInner(epollfd); in CloseEpollDesc()
|
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 72 node = SearchEventNode(eventNodeChain, epollfd); in PostEvent() 74 LOGE(TAG, "Cannot find event node for %d", epollfd->recvFd); in PostEvent() 90 void ClearEvent(const List *eventNodeChain, EpollDesc epollfd) in ClearEvent() argument 100 node = SearchEventNode(eventNodeChain, epollfd); in ClearEvent() 137 int32_t EventModuleInit(List *eventNodeChain, EpollDesc epollfd) in EventModuleInit() argument 147 if (IsEpollDescEqual(node->epollfd, epollfd)) { in EventModuleInit() 164 node->task.epollfd in EventModuleInit() [all...] |
H A D | sys_epoll.c | 41 struct EpollDescStr epollfd; member 91 (!IsEpollDescValid(task->epollfd))) { in CtlEpollDesc() 101 LOGD(TAG, "%d op %d event seq: %u", task->epollfd->recvFd, op, event.evtSeq); in CtlEpollDesc() 103 if (sendto(task->epollfd->sendFd, (const void *)&event, sizeof(event), 0, NULL, 0) < 0) { in CtlEpollDesc() 104 LOGE(TAG, "ctrl epollfd failed: %d", errno); in CtlEpollDesc() 114 if ((task == NULL) || IS_INVALID_SOCKET_DESC(task->taskfd) || (!IsEpollDescValid(task->epollfd))) { in CtlEpollDescSync() 119 epollSetPtr = container_of(task->epollfd, EpollSet, epollfd); in CtlEpollDescSync() 323 int32_t CreateEpollFdPair(struct EpollDescStr *epollfd) in CreateEpollFdPair() argument 325 if (epollfd in CreateEpollFdPair() 811 EpollLoop(EpollDesc epollfd, int32_t timeout) global() argument 901 CloseEpollDescInner(EpollDesc epollfd) global() argument [all...] |
H A D | sys_timer.c | 127 Timer *TimerStart(EpollDesc epollfd, uint32_t ms, uint8_t repeated, TimeoutHandle handle, void *data) in TimerStart() argument 152 timer->task.epollfd = epollfd; in TimerStart()
|
/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/ |
H A D | sys_epoll.h | 28 #define REPRESENT_EPOLL_DESC(epollfd) (epollfd) 30 static inline bool IsEpollDescValid(EpollDesc epollfd) in IsEpollDescValid() argument 32 return (epollfd >= 0); in IsEpollDescValid() 40 static inline void CloseEpollDesc(EpollDesc epollfd) in CloseEpollDesc() argument 42 CloseDesc(epollfd); in CloseEpollDesc()
|
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 68 node = SearchEventNode(eventNodeChain, epollfd); in PostEvent() 70 LOGE(TAG, "Cannot find event node for %d", epollfd); in PostEvent() 82 void ClearEvent(const List *eventNodeChain, EpollDesc epollfd) in ClearEvent() argument 92 node = SearchEventNode(eventNodeChain, epollfd); in ClearEvent() 140 int32_t EventModuleInit(List *eventNodeChain, EpollDesc epollfd) in EventModuleInit() argument 150 if (node->epollfd == epollfd) { in EventModuleInit() 165 node->task.epollfd in EventModuleInit() [all...] |
H A D | sys_epoll.c | 32 if (epoll_ctl(task->epollfd, EPOLL_CTL_MOD, task->taskfd, &event) < 0) { in RefreshEpollTask() 48 if (epoll_ctl(task->epollfd, EPOLL_CTL_ADD, task->taskfd, &event) < 0) { in RegisterEpollTask() 60 if (epoll_ctl(task->epollfd, EPOLL_CTL_DEL, task->taskfd, NULL) < 0) { in DeRegisterEpollTask() 73 int32_t EpollLoop(EpollDesc epollfd, int32_t timeout) in EpollLoop() argument 79 nfds = epoll_wait(epollfd, events, MAX_EPOLL_SIZE, timeout); in EpollLoop()
|
H A D | sys_timer.c | 122 Timer *TimerStart(EpollDesc epollfd, uint32_t ms, uint8_t repeated, TimeoutHandle handle, void *data) in TimerStart() argument 140 timer->task.epollfd = epollfd; in TimerStart()
|
/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 32 if (IsEpollDescEqual(node->epollfd, epollfd)) { in SearchEventNode() 40 void EventModuleClean(const List *eventNodeChain, EpollDesc epollfd) in EventModuleClean() argument 50 if (IsEpollDescEqual(node->epollfd, epollfd)) { in EventModuleClean() 82 EpollTask *GetEpollTask(List *eventNodeChain, EpollDesc epollfd) in GetEpollTask() argument 89 EventNode *node = SearchEventNode(eventNodeChain, epollfd); in GetEpollTask() 91 LOGE(TAG, "Cannot find event node for %d", REPRESENT_EPOLL_DESC(epollfd)); in GetEpollTask()
|
/foundation/communication/dsoftbus/components/nstackx/nstackx_util/interface/ |
H A D | nstackx_event.h | 31 EpollDesc epollfd; member 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); 41 NSTACKX_EXPORT EpollTask *GetEpollTask(List *eventNodeChain, EpollDesc epollfd);
|
H A D | nstackx_epoll.h | 44 EpollDesc epollfd; member 57 NSTACKX_EXPORT int32_t EpollLoop(EpollDesc epollfd, int32_t timeout); 58 static inline bool IsEpollDescValid(EpollDesc epollfd); 60 static inline void CloseEpollDesc(EpollDesc epollfd);
|
H A D | nstackx_timer.h | 44 NSTACKX_EXPORT Timer *TimerStart(EpollDesc epollfd, uint32_t ms, uint8_t repeated, TimeoutHandle handle, void *data);
|
/foundation/systemabilitymgr/samgr/services/samgr/native/source/ |
H A D | samgr_time_handler.cpp | 45 epollfd = epoll_create(INIT_NUM); in SamgrTimeHandler() 46 if (epollfd == -1) { in SamgrTimeHandler() 59 int number = epoll_wait(this->epollfd, events, MAX_EVENT, -1); in StartThread() 86 epoll_ctl(this->epollfd, EPOLL_CTL_DEL, timerfd, nullptr); in OnTime() 95 epoll_ctl(this->epollfd, EPOLL_CTL_DEL, fd, nullptr); in ~SamgrTimeHandler() 99 ::close(epollfd); in ~SamgrTimeHandler() 128 if (epoll_ctl(epollfd, EPOLL_CTL_ADD, timerfd, &event) == -1) { in PostTask()
|
/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/core/coap_discover/ |
H A D | coap_app.c | 43 static uint32_t GetTimeout(CoapCtxType *ctx, EpollDesc epollfd); 192 static uint32_t RegisterCtxTask(EpollDesc epollfd) in RegisterCtxTask() argument 198 uint32_t currentTimeout = GetTimeout(ctx, epollfd); in RegisterCtxTask() 208 uint32_t RegisterCoAPEpollTask(EpollDesc epollfd) in RegisterCoAPEpollTask() argument 211 uint32_t timeout = RegisterCtxTask(epollfd); in RegisterCoAPEpollTask() 212 g_taskListInfo.epollFd = epollfd; in RegisterCoAPEpollTask() 229 uint32_t RegisterCoAPEpollTask(EpollDesc epollfd) in RegisterCoAPEpollTask() argument 231 return RegisterCtxTask(epollfd); in RegisterCoAPEpollTask() 235 static uint32_t GetTimeout(CoapCtxType *ctx, EpollDesc epollfd) in GetTimeout() argument 266 ctx->taskList[i].epollfd in GetTimeout() [all...] |
/foundation/resourceschedule/memmgr/services/memmgrservice/src/event/ |
H A D | memory_pressure_observer.cpp | 136 int MemoryPressureObserver::AddLevelFileFdToEpoll(int epollfd, int fd, void* data)
in AddLevelFileFdToEpoll() argument 143 ret = epoll_ctl(epollfd, EPOLL_CTL_ADD, fd, &epollEvent);
in AddLevelFileFdToEpoll() 220 int MemoryPressureObserver::delLevelFileFdFromEpoll(int epollfd, int fd)
in delLevelFileFdFromEpoll() argument 222 return epoll_ctl(epollfd, EPOLL_CTL_DEL, fd, NULL);
in delLevelFileFdFromEpoll()
|
/foundation/resourceschedule/memmgr/services/memmgrservice/include/event/ |
H A D | memory_pressure_observer.h | 85 int AddLevelFileFdToEpoll(int epollfd, int fd, void* data);
87 int delLevelFileFdFromEpoll(int epollfd, int fd);
|
/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/core/ |
H A D | nstackx_smartgenius.c | 243 int32_t SmartGeniusInit(EpollDesc epollfd) in SmartGeniusInit() argument 254 g_netlinkTask.epollfd = epollfd; in SmartGeniusInit() 263 g_recoverTimer = TimerStart(epollfd, 0, NSTACKX_FALSE, RecoverNetLinkTask, NULL); in SmartGeniusInit() 314 int32_t SmartGeniusInit(EpollDesc epollfd) in SmartGeniusInit() argument 316 (void)epollfd; in SmartGeniusInit()
|
/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/include/ |
H A D | nstackx_smartgenius.h | 25 int32_t SmartGeniusInit(EpollDesc epollfd);
|
H A D | nstackx_device_local.h | 33 int LocalDeviceInit(EpollDesc epollfd);
|
/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/include/coap_discover/ |
H A D | coap_app.h | 50 uint32_t RegisterCoAPEpollTask(EpollDesc epollfd);
|
H A D | coap_discover.h | 83 int32_t CoapDiscoverInit(EpollDesc epollfd);
|
/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/include/mini_discover/ |
H A D | coap_discover.h | 32 int32_t CoapDiscoverInit(EpollDesc epollfd);
|
/foundation/systemabilitymgr/samgr/services/samgr/native/include/ |
H A D | samgr_time_handler.h | 56 int epollfd = -1; member in OHOS::SamgrTimeHandler
|
/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() 932 session->epollfd = CreateEpollDesc(); in DFileSessionCreate() 933 if (!IsEpollDescValid(session->epollfd)) { in DFileSessionCreate() 951 CloseEpollDesc(session->epollfd); in DFileSessionCreate() 996 if (IsEpollDescValid(session->epollfd)) { in DFileSessionClean() 997 CloseEpollDesc(session->epollfd); in DFileSessionClean() [all...] |
H A D | nstackx_file_manager.c | 70 if (fileManager->msgReceiver == NULL || !IsEpollDescValid(fileManager->epollfd)) { in NotifyFileManagerMsg() 81 if (PostEvent(fileManager->eventNodeChain, fileManager->epollfd, NotifyFileManagerMsgInner, ctx) != NSTACKX_EOK) { in NotifyFileManagerMsg() 95 if (fileList->msgReceiver == NULL || !IsEpollDescValid(fileList->epollfd)) { in NotifyFileListMsg() 118 if (PostEvent(fileList->eventNodeChain, fileList->epollfd, NotifyFileListMsgInner, ctx) != NSTACKX_EOK) { in NotifyFileListMsg() 127 if (fileList->msgReceiver == NULL || !IsEpollDescValid(fileList->epollfd) || fileId == 0 || in NotifyFileMsg() 141 if (PostEvent(fileList->eventNodeChain, fileList->epollfd, NotifyFileListMsgInner, ctx) != NSTACKX_EOK) { in NotifyFileMsg() 1391 if (IsEpollDescValid(msgPara->epollfd) && msgPara->msgReceiver != NULL) { in FileManagerInit() 1394 fileManager->epollfd = msgPara->epollfd; in FileManagerInit() 1594 fmFileList->epollfd in FileManagerRecvFileTask() [all...] |