Searched refs:selector (Results 1 – 4 of 4) sorted by relevance
58 static void setInSelect(Selector* selector, bool inSelect) { in setInSelect() argument59 pthread_mutex_lock(&selector->inSelectLock); in setInSelect()60 selector->inSelect = inSelect; in setInSelect()61 pthread_mutex_unlock(&selector->inSelectLock); in setInSelect()64 static bool isInSelect(Selector* selector) { in isInSelect() argument65 pthread_mutex_lock(&selector->inSelectLock); in isInSelect()66 bool inSelect = selector->inSelect; in isInSelect()67 pthread_mutex_unlock(&selector->inSelectLock); in isInSelect()71 void selectorWakeUp(Selector* selector) { in selectorWakeUp() argument72 if (!isInSelect(selector)) { in selectorWakeUp()[all …]
141 Selector* selector; member785 SelectableFd* selectableFd = selectorAdd(peer->selector, incomingFd); in masterProxyAcceptConnection()1070 SelectableFd* socketFd = selectorAdd(masterPeer->selector, socket); in masterAcceptConnection()1099 peer->selector = selectorCreate(); in peerCreate()1172 selectorWakeUp(peer->selector); in peerSendBytes()1247 selectorWakeUp(peer->selector); in peerSendSharedBytes()1297 SelectableFd* listenerFd = selectorAdd(localPeer->selector, listenerSocket); in masterPeerInitialize()1335 SelectableFd* masterFd = selectorAdd(localPeer->selector, masterSocket); in peerInitialize()1355 selectorLoop(localPeer->selector); in peerLoop()
79 selector.c \
97 Selector* selector; member112 SelectableFd* selectorAdd(Selector* selector, int fd);118 void selectorWakeUp(Selector* selector);124 void selectorLoop(Selector* selector);