Home
last modified time | relevance | path

Searched refs:SelectableFd (Results 1 – 3 of 3) sorted by relevance

/system/core/include/cutils/
Dselector.h49 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/
Dselector.c40 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 …]
Dmq.c173 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 …]