Home
last modified time | relevance | path

Searched refs:taskfd (Results 1 – 10 of 10) sorted by relevance

/ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/core/
H A Dnstackx_smartgenius.c208 close(g_netlinkTask.taskfd); in NetlinkErrorHandle()
209 g_netlinkTask.taskfd = -1; in NetlinkErrorHandle()
228 if (g_netlinkTask.taskfd < 0) { in RecoverNetLinkTask()
235 close(g_netlinkTask.taskfd); in RecoverNetLinkTask()
236 g_netlinkTask.taskfd = -1; in RecoverNetLinkTask()
253 g_netlinkTask.taskfd = fd; in SmartGeniusInit()
274 close(g_netlinkTask.taskfd); in SmartGeniusInit()
275 g_netlinkTask.taskfd = -1; in SmartGeniusInit()
288 if (g_netlinkTask.taskfd != -1) { in SmartGeniusClean()
290 close(g_netlinkTask.taskfd); in SmartGeniusClean()
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/liteos/
H A Dsys_epoll.c244 if (taskListPtr->taskPtr->taskfd == fd) { in EpollTaskFindByFd()
554 FD_SET(task->taskfd, &epollSetPtr->readfds); in EpollFdEventAdd()
559 FD_SET(task->taskfd, &epollSetPtr->exceptfds); in EpollFdEventAdd()
567 if (task->taskfd > epollSetPtr->maxfd) { in EpollFdEventAdd()
568 epollSetPtr->maxfd = task->taskfd; in EpollFdEventAdd()
639 FD_CLR(task->taskfd, &epollSetPtr->readfds);
640 FD_CLR(task->taskfd, &epollSetPtr->writefds);
641 FD_CLR(task->taskfd, &epollSetPtr->exceptfds);
645 if (task->taskfd == epollSetPtr->maxfd) {
669 FD_CLR(task->taskfd, &epollSetPtr->readfds);
[all …]
H A Dsys_timer.c26 #define TASKFD_TO_TIMERID(taskfd) ((timer_t)(uintptr_t)(taskfd)) argument
33 if (TASKFD_TO_TIMERID(timer->task.taskfd) != NULL) { in TimerDelete()
34 if (timer_delete(TASKFD_TO_TIMERID(timer->task.taskfd)) < 0) { in TimerDelete()
37 timer->task.taskfd = TIMERID_TO_TASKFD(NULL); in TimerDelete()
77 if (timer_gettime(TASKFD_TO_TIMERID(timer->task.taskfd), &currValue) < 0) { in TimerGetRemainTime()
110 if (timer_settime(TASKFD_TO_TIMERID(timer->task.taskfd), 0, &ts, NULL) < 0) { in TimerSetTimeout()
151 timer->task.taskfd = TIMERID_TO_TASKFD(timerid); in TimerStart()
H A Dsys_event.c163 node->task.taskfd = node->pipeFd[PIPE_OUT]; in EventModuleInit()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/unix/
H A Dsys_timer.c28 if (timer->task.taskfd != INVALID_TASK_DESC) { in TimerDelete()
32 if (close(timer->task.taskfd) < 0) { in TimerDelete()
35 timer->task.taskfd = INVALID_TASK_DESC; in TimerDelete()
61 if (read(task->taskfd, &exp, sizeof(exp)) != (ssize_t)(sizeof(uint64_t))) { in TimerReadHandle()
81 if (timerfd_gettime(timer->task.taskfd, &currValue) < 0) { in TimerGetRemainTime()
114 if (timerfd_settime(timer->task.taskfd, 0, &ts, NULL) < 0) { in TimerSetTimeout()
134 timer->task.taskfd = timerfd_create(CLOCK_MONOTONIC, TFD_CLOEXEC | TFD_NONBLOCK); in TimerStart()
135 if (timer->task.taskfd < 0) { in TimerStart()
H A Dsys_epoll.c32 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()
H A Dsys_event.c164 node->task.taskfd = node->pipeFd[PIPE_OUT]; in EventModuleInit()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/core/coap_discover/
H A Dcoap_app.c119 if (task->taskfd < 0) { in CoAPEpollReadHandle()
143 if (task->taskfd < 0) { in CoAPEpollWriteHandle()
164 if (task == NULL || task->taskfd < 0) { in CoAPEpollErrorHandle()
189 task->taskfd = -1; in CoAPEpollErrorHandle()
296 if (ctx->taskList[i].taskfd < 0) { in DeRegisteCoAPEpollTaskCtx()
346 if (maxFd < task->taskfd) { in CoapSelectWait()
347 maxFd = task->taskfd; in CoapSelectWait()
350 FD_SET(task->taskfd, &readSet); in CoapSelectWait()
353 FD_SET(task->taskfd, &writeSet); in CoapSelectWait()
355 FD_SET(task->taskfd, &errorSet); in CoapSelectWait()
[all …]
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/core/mini_discover/
H A Dcoap_app.c276 CloseDesc(g_task.taskfd); in DeRegisteCoAPEpollTaskCtx()
277 g_task.taskfd = -1; in DeRegisteCoAPEpollTaskCtx()
297 if (task->taskfd < 0) { in CoAPEpollReadHandle()
301 HandleReadEvent(task->taskfd); in CoAPEpollReadHandle()
310 if (task->taskfd < 0) { in CoAPEpollErrorHandle()
318 CloseDesc(task->taskfd); in CoAPEpollErrorHandle()
319 task->taskfd = -1; in CoAPEpollErrorHandle()
374 g_coapCtx.task.taskfd = listenFd; in CoapServerInit()
398 CloseDesc(g_coapCtx.task.taskfd); in CoapServerDestroy()
402 g_coapCtx.task.taskfd = -1; in CoapServerDestroy()
/ohos5.0/foundation/communication/dsoftbus/components/nstackx/nstackx_util/interface/
H A Dnstackx_epoll.h45 TaskDesc taskfd; member