Home
last modified time | relevance | path

Searched refs:readSet (Results 1 - 6 of 6) sorted by relevance

/foundation/communication/dsoftbus/core/connection/common/src/
H A Dsoftbus_base_listener.c959 static void ProcessSpecifiedListenerNodeEvent(SoftbusListenerNode *node, SoftBusFdSet *readSet, SoftBusFdSet *writeSet, in ProcessSpecifiedListenerNodeEvent() argument
992 if (listenFd > 0 && SoftBusSocketFdIsset(listenFd, readSet)) { in ProcessSpecifiedListenerNodeEvent()
1017 if ((fdArray[i].triggerSet & READ_TRIGGER) != 0 && SoftBusSocketFdIsset(fdArray[i].fd, readSet)) { in ProcessSpecifiedListenerNodeEvent()
1040 static void ProcessEvent(SoftBusFdSet *readSet, SoftBusFdSet *writeSet, SoftBusFdSet *exceptSet, in ProcessEvent() argument
1048 ProcessSpecifiedListenerNodeEvent(node, readSet, writeSet, exceptSet, wakeupTrace); in ProcessEvent()
1052 if (SoftBusSocketFdIsset(selectState->ctrlRfd, readSet)) { in ProcessEvent()
1058 SoftbusListenerNode *node, SoftBusFdSet *readSet, SoftBusFdSet *writeSet, SoftBusFdSet *exceptSet) in CollectSpecifiedModuleListenerEvents()
1070 SoftBusSocketFdSet(node->info.listenFd, readSet); in CollectSpecifiedModuleListenerEvents()
1077 SoftBusSocketFdSet(it->fd, readSet); in CollectSpecifiedModuleListenerEvents()
1092 static int32_t CollectWaitEventFdSet(SoftBusFdSet *readSet, SoftBusFdSe argument
1057 CollectSpecifiedModuleListenerEvents( SoftbusListenerNode *node, SoftBusFdSet *readSet, SoftBusFdSet *writeSet, SoftBusFdSet *exceptSet) CollectSpecifiedModuleListenerEvents() argument
1149 SoftBusFdSet readSet; SelectTask() local
[all...]
H A Dsoftbus_socket.c165 SoftBusFdSet readSet; in WaitEvent() local
166 SoftBusSocketFdZero(&readSet); in WaitEvent()
167 SoftBusSocketFdSet(fd, &readSet); in WaitEvent()
168 rc = SOFTBUS_TEMP_FAILURE_RETRY(SoftBusSocketSelect(fd + 1, &readSet, NULL, NULL, &tv)); in WaitEvent()
172 if (!SoftBusSocketFdIsset(fd, &readSet)) { in WaitEvent()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/src/
H A Dsysio_udp.c202 (void)FILLP_FD_COPY_FD_SET(g_udpIo.readableSet, g_udpIo.readSet); in SysioSelectUdp()
314 FILLP_FD_SET((FILLP_UINT)udpSock->udpSock, g_udpIo.readSet); in SysioCreateSocketUdp()
319 FILLP_FD_CLR((FILLP_UINT32)udpSock->udpSock, g_udpIo.readSet); in SysioCreateSocketUdp()
345 if (g_udpIo.readSet != FILLP_NULL_PTR) { in SysioDestroySocketUdp()
346 if (FILLP_FD_ISSET(udpSock->udpSock, g_udpIo.readSet)) { in SysioDestroySocketUdp()
347 FILLP_FD_CLR((FILLP_UINT32)udpSock->udpSock, g_udpIo.readSet); in SysioDestroySocketUdp()
H A Dspunge_core.c597 g_udpIo.readSet = FILLP_FD_CREATE_FD_SET(); in FtInitGlobalUdpIo()
598 if (g_udpIo.readSet == FILLP_NULL_PTR) { in FtInitGlobalUdpIo()
599 FILLP_LOGERR("Malloc g_udpIo.readSet failed"); in FtInitGlobalUdpIo()
660 if (g_udpIo.readSet != FILLP_NULL_PTR) { in FtFreeGlobalUdpIo()
661 FILLP_FD_DESTROY_FD_SET(g_udpIo.readSet); in FtFreeGlobalUdpIo()
662 g_udpIo.readSet = FILLP_NULL_PTR; in FtFreeGlobalUdpIo()
/foundation/communication/dsoftbus/components/nstackx/nstackx_ctrl/core/coap_discover/
H A Dcoap_app.c337 fd_set readSet, writeSet, errorSet; in CoapSelectWait() local
341 FD_ZERO(&readSet); in CoapSelectWait()
350 FD_SET(task->taskfd, &readSet); in CoapSelectWait()
359 int ret = select(maxFd + 1, &readSet, &writeSet, &errorSet, &tv); in CoapSelectWait()
372 if (FD_ISSET(taskListInfo->taskList[i].taskfd, &readSet)) { in CoapSelectWait()
/foundation/communication/dsoftbus/components/nstackx/fillp/src/fillp_lib/include/
H A Dsysio.h70 FT_FD_SET readSet; /* socket read set for select */ member

Completed in 8 milliseconds