| /f-stack/app/redis-5.0.5/src/ |
| H A D | ae.h | 62 struct aeEventLoop;
97 typedef struct aeEventLoop { struct
109 } aeEventLoop; argument
112 aeEventLoop *aeCreateEventLoop(int setsize);
113 void aeDeleteEventLoop(aeEventLoop *eventLoop);
114 void aeStop(aeEventLoop *eventLoop);
118 int aeGetFileEvents(aeEventLoop *eventLoop, int fd);
123 int aeProcessEvents(aeEventLoop *eventLoop, int flags);
125 void aeMain(aeEventLoop *eventLoop);
129 int aeGetSetSize(aeEventLoop *eventLoop);
[all …]
|
| H A D | ae.c | 67 aeEventLoop *aeCreateEventLoop(int setsize) { in aeCreateEventLoop()
68 aeEventLoop *eventLoop; in aeCreateEventLoop()
100 int aeGetSetSize(aeEventLoop *eventLoop) { in aeGetSetSize()
111 int aeResizeSetSize(aeEventLoop *eventLoop, int setsize) { in aeResizeSetSize()
129 void aeDeleteEventLoop(aeEventLoop *eventLoop) { in aeDeleteEventLoop()
136 void aeStop(aeEventLoop *eventLoop) { in aeStop()
182 int aeGetFileEvents(aeEventLoop *eventLoop, int fd) { in aeGetFileEvents()
238 int aeDeleteTimeEvent(aeEventLoop *eventLoop, long long id) in aeDeleteTimeEvent()
278 static int processTimeEvents(aeEventLoop *eventLoop) { in processTimeEvents()
366 int aeProcessEvents(aeEventLoop *eventLoop, int flags) in aeProcessEvents()
[all …]
|
| H A D | ae_select.c | 42 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 D | ae_ff_kqueue.c | 43 static int aeApiCreate(aeEventLoop *eventLoop) { in aeApiCreate()
62 static int aeApiResize(aeEventLoop *eventLoop, int setsize) { in aeApiResize()
69 static void aeApiFree(aeEventLoop *eventLoop) { in aeApiFree()
77 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiAddEvent()
92 static void aeApiDelEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiDelEvent()
106 static int aeApiPoll(aeEventLoop *eventLoop, struct timeval *tvp) { in aeApiPoll()
|
| H A D | ae_epoll.c | 39 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 D | ae_kqueue.c | 41 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 D | ae_evport.c | 75 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 D | redis-benchmark.c | 53 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 D | server.h | 946 aeEventLoop *el;
1409 void moduleBlockedClientPipeReadable(aeEventLoop *el, int fd, void *privdata, int mask);
1432 void sendReplyToClient(aeEventLoop *el, int fd, void *privdata, int mask);
1437 void acceptHandler(aeEventLoop *el, int fd, void *privdata, int mask);
1438 void acceptTcpHandler(aeEventLoop *el, int fd, void *privdata, int mask);
1439 void acceptUnixHandler(aeEventLoop *el, int fd, void *privdata, int mask);
1440 void readQueryFromClient(aeEventLoop *el, int fd, void *privdata, int mask);
|
| H A D | sentinel.c | 273 aeEventLoop *loop;
278 static void redisAeReadEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeReadEvent()
285 static void redisAeWriteEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeWriteEvent()
294 aeEventLoop *loop = e->loop; in redisAeAddRead()
303 aeEventLoop *loop = e->loop; in redisAeDelRead()
312 aeEventLoop *loop = e->loop; in redisAeAddWrite()
321 aeEventLoop *loop = e->loop; in redisAeDelWrite()
335 static int redisAeAttach(aeEventLoop *loop, redisAsyncContext *ac) { in redisAeAttach()
|
| H A D | networking.c | 734 void acceptTcpHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in acceptTcpHandler()
754 void acceptUnixHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in acceptUnixHandler()
1072 void sendReplyToClient(aeEventLoop *el, int fd, void *privdata, int mask) { in sendReplyToClient()
1518 void readQueryFromClient(aeEventLoop *el, int fd, void *privdata, int mask) { in readQueryFromClient()
|
| H A D | replication.c | 872 void sendBulkToSlave(aeEventLoop *el, int fd, void *privdata, int mask) { in sendBulkToSlave()
1117 void readSyncBulkPayload(aeEventLoop *el, int fd, void *privdata, int mask) { in readSyncBulkPayload()
1608 void syncWithMaster(aeEventLoop *el, int fd, void *privdata, int mask) { in syncWithMaster()
|
| H A D | aof.c | 95 void aofChildWriteDiffData(aeEventLoop *el, int fd, void *privdata, int mask) { in aofChildWriteDiffData()
1476 void aofChildPipeReadable(aeEventLoop *el, int fd, void *privdata, int mask) { in aofChildPipeReadable()
|
| H A D | server.c | 1096 int serverCron(struct aeEventLoop *eventLoop, long long id, void *clientData) { in serverCron()
1365 void beforeSleep(struct aeEventLoop *eventLoop) { in beforeSleep()
1422 void afterSleep(struct aeEventLoop *eventLoop) { in afterSleep()
4044 aeMain((aeEventLoop *)arg); in loop()
|
| H A D | cluster.c | 51 void clusterAcceptHandler(aeEventLoop *el, int fd, void *privdata, int mask);
52 void clusterReadHandler(aeEventLoop *el, int fd, void *privdata, int mask);
615 void clusterAcceptHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in clusterAcceptHandler()
2120 void clusterWriteHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in clusterWriteHandler()
2141 void clusterReadHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in clusterReadHandler()
|
| H A D | module.c | 3550 void moduleBlockedClientPipeReadable(aeEventLoop *el, int fd, void *privdata, int mask) { in moduleBlockedClientPipeReadable()
4303 int moduleTimerHandler(struct aeEventLoop *eventLoop, long long id, void *clientData) { in moduleTimerHandler()
|
| /f-stack/app/redis-5.0.5/deps/hiredis/adapters/ |
| H A D | ae.h | 40 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()
|
| /f-stack/app/redis-5.0.5/deps/hiredis/examples/ |
| H A D | example-ae.c | 11 static aeEventLoop *loop;
|