| /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...] |