Home
last modified time | relevance | path

Searched refs:aeEventLoop (Results 1 – 16 of 16) sorted by relevance

/redis-3.2.3/src/
H A Dae.h56 struct aeEventLoop;
90 typedef struct aeEventLoop { struct
101 } aeEventLoop; argument
104 aeEventLoop *aeCreateEventLoop(int setsize);
105 void aeDeleteEventLoop(aeEventLoop *eventLoop);
106 void aeStop(aeEventLoop *eventLoop);
110 int aeGetFileEvents(aeEventLoop *eventLoop, int fd);
115 int aeProcessEvents(aeEventLoop *eventLoop, int flags);
117 void aeMain(aeEventLoop *eventLoop);
120 int aeGetSetSize(aeEventLoop *eventLoop);
[all …]
H A Dae.c63 aeEventLoop *aeCreateEventLoop(int setsize) { in aeCreateEventLoop()
64 aeEventLoop *eventLoop; in aeCreateEventLoop()
95 int aeGetSetSize(aeEventLoop *eventLoop) { in aeGetSetSize()
106 int aeResizeSetSize(aeEventLoop *eventLoop, int setsize) { in aeResizeSetSize()
124 void aeDeleteEventLoop(aeEventLoop *eventLoop) { in aeDeleteEventLoop()
131 void aeStop(aeEventLoop *eventLoop) { in aeStop()
173 int aeGetFileEvents(aeEventLoop *eventLoop, int fd) { in aeGetFileEvents()
222 int aeDeleteTimeEvent(aeEventLoop *eventLoop, long long id) in aeDeleteTimeEvent()
262 static int processTimeEvents(aeEventLoop *eventLoop) { in processTimeEvents()
349 int aeProcessEvents(aeEventLoop *eventLoop, int flags) in aeProcessEvents()
[all …]
H A Dae_select.c42 static int aeApiCreate(aeEventLoop *eventLoop) { in aeApiCreate()
52 static int aeApiResize(aeEventLoop *eventLoop, int setsize) { in aeApiResize()
58 static void aeApiFree(aeEventLoop *eventLoop) { in aeApiFree()
62 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiAddEvent()
70 static void aeApiDelEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiDelEvent()
77 static int aeApiPoll(aeEventLoop *eventLoop, struct timeval *tvp) { in aeApiPoll()
H A Dae_epoll.c39 static int aeApiCreate(aeEventLoop *eventLoop) { in aeApiCreate()
58 static int aeApiResize(aeEventLoop *eventLoop, int setsize) { in aeApiResize()
65 static void aeApiFree(aeEventLoop *eventLoop) { in aeApiFree()
73 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiAddEvent()
90 static void aeApiDelEvent(aeEventLoop *eventLoop, int fd, int delmask) { in aeApiDelEvent()
108 static int aeApiPoll(aeEventLoop *eventLoop, struct timeval *tvp) { in aeApiPoll()
H A Dae_kqueue.c41 static int aeApiCreate(aeEventLoop *eventLoop) { in aeApiCreate()
60 static int aeApiResize(aeEventLoop *eventLoop, int setsize) { in aeApiResize()
67 static void aeApiFree(aeEventLoop *eventLoop) { in aeApiFree()
75 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiAddEvent()
90 static void aeApiDelEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiDelEvent()
104 static int aeApiPoll(aeEventLoop *eventLoop, struct timeval *tvp) { in aeApiPoll()
H A Dae_evport.c75 static int aeApiCreate(aeEventLoop *eventLoop) { in aeApiCreate()
97 static int aeApiResize(aeEventLoop *eventLoop, int setsize) { in aeApiResize()
102 static void aeApiFree(aeEventLoop *eventLoop) { in aeApiFree()
152 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiAddEvent()
183 static void aeApiDelEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiDelEvent()
243 static int aeApiPoll(aeEventLoop *eventLoop, struct timeval *tvp) { in aeApiPoll()
H A Dredis-benchmark.c53 aeEventLoop *el;
101 static void writeHandler(aeEventLoop *el, int fd, void *privdata, int mask);
189 static void readHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in readHandler()
258 static void writeHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in writeHandler()
612 int showThroughput(struct aeEventLoop *eventLoop, long long id, void *clientData) { in showThroughput()
H A Dserver.h714 aeEventLoop *el;
1097 void sendReplyToClient(aeEventLoop *el, int fd, void *privdata, int mask);
1101 void acceptHandler(aeEventLoop *el, int fd, void *privdata, int mask);
1102 void acceptTcpHandler(aeEventLoop *el, int fd, void *privdata, int mask);
1103 void acceptUnixHandler(aeEventLoop *el, int fd, void *privdata, int mask);
1104 void readQueryFromClient(aeEventLoop *el, int fd, void *privdata, int mask);
H A Dnetworking.c686 void acceptTcpHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in acceptTcpHandler()
706 void acceptUnixHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in acceptUnixHandler()
988 void sendReplyToClient(aeEventLoop *el, int fd, void *privdata, int mask) { in sendReplyToClient()
1307 void readQueryFromClient(aeEventLoop *el, int fd, void *privdata, int mask) { in readQueryFromClient()
H A Dsentinel.c266 aeEventLoop *loop;
271 static void redisAeReadEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeReadEvent()
278 static void redisAeWriteEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeWriteEvent()
287 aeEventLoop *loop = e->loop; in redisAeAddRead()
296 aeEventLoop *loop = e->loop; in redisAeDelRead()
305 aeEventLoop *loop = e->loop; in redisAeAddWrite()
314 aeEventLoop *loop = e->loop; in redisAeDelWrite()
328 static int redisAeAttach(aeEventLoop *loop, redisAsyncContext *ac) { in redisAeAttach()
H A Dreplication.c798 void sendBulkToSlave(aeEventLoop *el, int fd, void *privdata, int mask) { in sendBulkToSlave()
984 void readSyncBulkPayload(aeEventLoop *el, int fd, void *privdata, int mask) { in readSyncBulkPayload()
1386 void syncWithMaster(aeEventLoop *el, int fd, void *privdata, int mask) { in syncWithMaster()
H A Daof.c95 void aofChildWriteDiffData(aeEventLoop *el, int fd, void *privdata, int mask) { in aofChildWriteDiffData()
1180 void aofChildPipeReadable(aeEventLoop *el, int fd, void *privdata, int mask) { in aofChildPipeReadable()
H A Dcluster.c52 void clusterAcceptHandler(aeEventLoop *el, int fd, void *privdata, int mask);
53 void clusterReadHandler(aeEventLoop *el, int fd, void *privdata, int mask);
574 void clusterAcceptHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in clusterAcceptHandler()
1994 void clusterWriteHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in clusterWriteHandler()
2015 void clusterReadHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in clusterReadHandler()
H A Dserver.c1090 int serverCron(struct aeEventLoop *eventLoop, long long id, void *clientData) { in serverCron()
1312 void beforeSleep(struct aeEventLoop *eventLoop) { in beforeSleep()
/redis-3.2.3/deps/hiredis/adapters/
H A Dae.h40 aeEventLoop *loop;
45 static void redisAeReadEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeReadEvent()
52 static void redisAeWriteEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeWriteEvent()
61 aeEventLoop *loop = e->loop; in redisAeAddRead()
70 aeEventLoop *loop = e->loop; in redisAeDelRead()
79 aeEventLoop *loop = e->loop; in redisAeAddWrite()
88 aeEventLoop *loop = e->loop; in redisAeDelWrite()
102 static int redisAeAttach(aeEventLoop *loop, redisAsyncContext *ac) { in redisAeAttach()
/redis-3.2.3/deps/hiredis/examples/
H A Dexample-ae.c11 static aeEventLoop *loop;