| /redis-3.2.3/src/ |
| H A D | redis-benchmark.c | 53 aeEventLoop *el; member
127 aeDeleteFileEvent(config.el,c->context->fd,AE_WRITABLE); in freeClient()
128 aeDeleteFileEvent(config.el,c->context->fd,AE_READABLE); in freeClient()
150 aeDeleteFileEvent(config.el,c->context->fd,AE_WRITABLE); in resetClient()
151 aeDeleteFileEvent(config.el,c->context->fd,AE_READABLE); in resetClient()
176 aeStop(config.el); in clientDone()
192 UNUSED(el); in readHandler()
260 UNUSED(el); in writeHandler()
472 aeMain(config.el); in benchmark()
662 config.el = aeCreateEventLoop(1024*10); in main()
[all …]
|
| H A D | replication.c | 787 if (aeCreateFileEvent(server.el, slave->fd, AE_WRITABLE, in putSlaveOnline()
800 UNUSED(el); in sendBulkToSlave()
849 aeDeleteFileEvent(server.el,slave->fd,AE_WRITABLE); in sendBulkToSlave()
988 UNUSED(el); in readSyncBulkPayload()
1309 aeDeleteFileEvent(server.el,fd,AE_READABLE); in slaveTryPartialResynchronization()
1324 aeDeleteFileEvent(server.el,fd,AE_READABLE); in slaveTryPartialResynchronization()
1391 UNUSED(el); in syncWithMaster()
1416 aeDeleteFileEvent(server.el,fd,AE_WRITABLE); in syncWithMaster()
1642 aeDeleteFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE); in syncWithMaster()
1686 aeDeleteFileEvent(server.el,fd,AE_READABLE|AE_WRITABLE); in undoConnectWithMaster()
[all …]
|
| H A D | networking.c | 76 if (aeCreateFileEvent(server.el,fd,AE_READABLE, in createClient()
686 void acceptTcpHandler(aeEventLoop *el, int fd, void *privdata, int mask) { in acceptTcpHandler() argument
689 UNUSED(el); in acceptTcpHandler()
708 UNUSED(el); in acceptUnixHandler()
762 aeDeleteFileEvent(server.el,c->fd,AE_READABLE); in unlinkClient()
763 aeDeleteFileEvent(server.el,c->fd,AE_WRITABLE); in unlinkClient()
989 UNUSED(el); in sendReplyToClient()
1015 aeCreateFileEvent(server.el, c->fd, AE_WRITABLE, in handleClientsWithPendingWrites()
1311 UNUSED(el); in readQueryFromClient()
1443 emask = client->fd == -1 ? 0 : aeGetFileEvents(server.el,client->fd); in catClientInfoString()
[all …]
|
| H A D | aof.c | 95 void aofChildWriteDiffData(aeEventLoop *el, int fd, void *privdata, int mask) { in aofChildWriteDiffData() argument
99 UNUSED(el); in aofChildWriteDiffData()
108 aeDeleteFileEvent(server.el,server.aof_pipe_write_data_to_child, in aofChildWriteDiffData()
164 if (aeGetFileEvents(server.el,server.aof_pipe_write_data_to_child) == 0) { in aofRewriteBufferAppend()
165 aeCreateFileEvent(server.el, server.aof_pipe_write_data_to_child, in aofRewriteBufferAppend()
1180 void aofChildPipeReadable(aeEventLoop *el, int fd, void *privdata, int mask) { in aofChildPipeReadable() argument
1182 UNUSED(el); in aofChildPipeReadable()
1200 aeDeleteFileEvent(server.el,server.aof_pipe_read_ack_from_child,AE_READABLE); in aofChildPipeReadable()
1218 …if (aeCreateFileEvent(server.el, fds[2], AE_READABLE, aofChildPipeReadable, NULL) == AE_ERR) goto … in aofCreatePipes()
1237 aeDeleteFileEvent(server.el,server.aof_pipe_read_ack_from_child,AE_READABLE); in aofClosePipes()
[all …]
|
| H A D | server.h | 714 aeEventLoop *el; member
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 D | cluster.c | 52 void clusterAcceptHandler(aeEventLoop *el, int fd, void *privdata, int mask);
53 void clusterReadHandler(aeEventLoop *el, int fd, void *privdata, int mask);
462 if (aeCreateFileEvent(server.el, server.cfd[j], AE_READABLE, in clusterInit()
562 aeDeleteFileEvent(server.el, link->fd, AE_WRITABLE); in freeClusterLink()
563 aeDeleteFileEvent(server.el, link->fd, AE_READABLE); in freeClusterLink()
579 UNUSED(el); in clusterAcceptHandler()
1997 UNUSED(el); in clusterWriteHandler()
2009 aeDeleteFileEvent(server.el, link->fd, AE_WRITABLE); in clusterWriteHandler()
2021 UNUSED(el); in clusterReadHandler()
2085 aeCreateFileEvent(server.el,link->fd,AE_WRITABLE, in clusterSendMessage()
[all …]
|
| H A D | server.c | 1880 server.el = aeCreateEventLoop(server.maxclients+CONFIG_FDSET_INCR); in initServer()
1946 if(aeCreateTimeEvent(server.el, 1, serverCron, NULL, NULL) == AE_ERR) { in initServer()
1954 if (aeCreateFileEvent(server.el, server.ipfd[j], AE_READABLE, in initServer()
1961 if (server.sofd > 0 && aeCreateFileEvent(server.el,server.sofd,AE_READABLE, in initServer()
4102 aeSetBeforeSleepProc(server.el,beforeSleep); in main()
4103 aeMain(server.el); in main()
4104 aeDeleteEventLoop(server.el); in main()
|
| H A D | sentinel.c | 271 static void redisAeReadEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeReadEvent() argument
272 ((void)el); ((void)fd); ((void)mask); in redisAeReadEvent()
278 static void redisAeWriteEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeWriteEvent() argument
279 ((void)el); ((void)fd); ((void)mask); in redisAeWriteEvent()
1923 redisAeAttach(server.el,link->cc); in sentinelReconnectInstance()
1947 redisAeAttach(server.el,link->pc); in sentinelReconnectInstance()
|
| H A D | scripting.c | 1196 aeDeleteFileEvent(server.el, server.lua_caller->fd, AE_READABLE); in luaMaskCountHook()
1327 aeCreateFileEvent(server.el,c->fd,AE_READABLE, in evalGenericCommand()
|
| H A D | config.c | 756 if ((unsigned int) aeGetSetSize(server.el) <
759 if (aeResizeSetSize(server.el,
|
| /redis-3.2.3/deps/hiredis/adapters/ |
| H A D | ae.h | 45 static void redisAeReadEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeReadEvent() argument
46 ((void)el); ((void)fd); ((void)mask); in redisAeReadEvent()
52 static void redisAeWriteEvent(aeEventLoop *el, int fd, void *privdata, int mask) { in redisAeWriteEvent() argument
53 ((void)el); ((void)fd); ((void)mask); in redisAeWriteEvent()
|
| /redis-3.2.3/deps/jemalloc/ |
| H A D | config.guess | 960 CPU=${UNAME_MACHINE}el
|