Home
last modified time | relevance | path

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

/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()
/foundation/communication/dsoftbus/components/nstackx/nstackx_util/platform/liteos/
H A Dsys_epoll.c90 if ((task == NULL) || ((op != EPOLL_CTL_RUN) && IS_INVALID_SOCKET_DESC(task->taskfd)) || in CtlEpollDesc()
114 if ((task == NULL) || IS_INVALID_SOCKET_DESC(task->taskfd) || (!IsEpollDescValid(task->epollfd))) { in CtlEpollDescSync()
244 if (taskListPtr->taskPtr->taskfd == fd) { in EpollTaskFindByFd()
527 g_epollEventPtrArray[EVENT_PTR_IDX(task->taskfd)].epollSetPtr = epollSetPtr; in EpollFdEventTaskAdd()
528 g_epollEventPtrArray[EVENT_PTR_IDX(task->taskfd)].taskPtr = task; in EpollFdEventTaskAdd()
539 EpollSet *setPtr = g_epollEventPtrArray[EVENT_PTR_IDX(task->taskfd)].epollSetPtr; in EpollFdEventAdd()
541 LOGE(TAG, "ADD: fd %d ptr has been used", task->taskfd); in EpollFdEventAdd()
545 if (FD_ISSET(task->taskfd, &epollSetPtr->exceptfds)) { in EpollFdEventAdd()
546 LOGD(TAG, "ADD: fd %d has in epoll ctl", task->taskfd); in EpollFdEventAdd()
554 FD_SET(task->taskfd, in EpollFdEventAdd()
[all...]
H A Dsys_timer.c26 #define TASKFD_TO_TIMERID(taskfd) ((timer_t)(uintptr_t)(taskfd))
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()
/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/core/
H A Dnstackx_smartgenius.c159 len = recvfrom(task->taskfd, innerBuf, BUFLEN, 0, (struct sockaddr *)&peer, &socklen); in SmartGeniusCallback()
208 close(g_netlinkTask.taskfd); in NetlinkErrorHandle()
209 g_netlinkTask.taskfd = -1; in NetlinkErrorHandle()
227 g_netlinkTask.taskfd = CreateNetLinkSocketFd(); in RecoverNetLinkTask()
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 in SmartGeniusInit()
[all...]
/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()
265 ctx->taskList[i].taskfd = sockets[i]->fd; in GetTimeout()
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, in CoapSelectWait()
[all...]
/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 in CoapServerDestroy()
[all...]
/foundation/communication/dsoftbus/components/nstackx/nstackx_util/interface/
H A Dnstackx_epoll.h45 TaskDesc taskfd; member

Completed in 5 milliseconds