Searched refs:SelectableFd (Results 1 – 3 of 3) sorted by relevance
/system/core/include/cutils/ |
D | selector.h | 49 typedef struct SelectableFd SelectableFd; typedef 50 struct SelectableFd { struct 68 void (*beforeSelect)(SelectableFd* self); argument 74 void (*onReadable)(SelectableFd* self); argument 80 void (*onWritable)(SelectableFd* self); argument 86 void (*onExcept)(SelectableFd* self); argument 92 void (*onRemove)(SelectableFd* self); argument 112 SelectableFd* selectorAdd(Selector* selector, int fd); argument
|
/system/core/libcutils/ |
D | selector.c | 40 SelectableFd* wakeupFd; 47 static void eatWakeupData(SelectableFd* wakeupFd) { in eatWakeupData() 101 SelectableFd* wakeupFd = selectorAdd(selector, selector->wakeupPipe[0]); in selectorCreate() 112 SelectableFd* selectorAdd(Selector* selector, int fd) { in selectorAdd() 115 SelectableFd* selectableFd = calloc(1, sizeof(SelectableFd)); in selectorAdd() 130 static inline bool maybeAdd(SelectableFd* selectableFd, in maybeAdd() 131 void (*callback)(SelectableFd*), fd_set* fdSet) { in maybeAdd() argument 156 SelectableFd* selectableFd = arrayGet(selectableFds, i); in prepareForSelect() 201 static inline void maybeInvoke(SelectableFd* selectableFd, in maybeInvoke() 202 void (*callback)(SelectableFd*), fd_set* fdSet) { in maybeInvoke() argument [all …]
|
D | mq.c | 173 SelectableFd* fd; 515 static void peerProxyWrite(SelectableFd* fd) { in peerProxyWrite() 561 static void peerProxyBeforeSelect(SelectableFd* fd) { in peerProxyBeforeSelect() 703 static void peerProxyRead(SelectableFd* fd); 706 static void peerProxySetFd(PeerProxy* peerProxy, SelectableFd* fd) { in peerProxySetFd() 785 SelectableFd* selectableFd = selectorAdd(peer->selector, incomingFd); in masterProxyAcceptConnection() 965 static void peerProxyRead(SelectableFd* fd) { in peerProxyRead() 1025 static void masterAcceptConnection(SelectableFd* listenerFd) { in masterAcceptConnection() 1070 SelectableFd* socketFd = selectorAdd(masterPeer->selector, socket); in masterAcceptConnection() 1297 SelectableFd* listenerFd = selectorAdd(localPeer->selector, listenerSocket); in masterPeerInitialize() [all …]
|