| /redis-3.2.3/tests/support/ |
| H A D | redis.tcl | 126 proc ::redis::__method__read {id fd} {
134 proc ::redis::__method__flush {id fd} {
138 proc ::redis::__method__close {id fd} {
151 proc ::redis::__method__channel {id fd} {
175 proc ::redis::redis_bulk_read {fd} { argument
182 proc ::redis::redis_multi_bulk_read {id fd} {
198 proc ::redis::redis_read_line fd { argument
202 proc ::redis::redis_read_reply {id fd} {
|
| /redis-3.2.3/src/ |
| H A D | anet.c | 84 int anetNonBlock(char *err, int fd) { in anetNonBlock()
88 int anetBlock(char *err, int fd) { in anetBlock()
151 int anetEnableTcpNoDelay(char *err, int fd) in anetEnableTcpNoDelay()
156 int anetDisableTcpNoDelay(char *err, int fd) in anetDisableTcpNoDelay()
172 int anetTcpKeepAlive(char *err, int fd) in anetTcpKeepAlive()
238 static int anetSetReuseAddr(char *err, int fd) { in anetSetReuseAddr()
410 int anetRead(int fd, char *buf, int count) in anetRead()
425 int anetWrite(int fd, char *buf, int count) in anetWrite()
529 int fd; in anetGenericAccept() local
546 int fd; in anetTcpAccept() local
[all …]
|
| H A D | syncio.c | 49 ssize_t syncWrite(int fd, char *ptr, ssize_t size, long long timeout) { in syncWrite()
85 ssize_t syncRead(int fd, char *ptr, ssize_t size, long long timeout) { in syncRead()
125 ssize_t syncReadLine(int fd, char *ptr, ssize_t size, long long timeout) { in syncReadLine()
|
| H A D | ae_evport.c | 109 static int aeApiLookupPending(aeApiState *state, int fd) { in aeApiLookupPending()
123 static int aeApiAssociate(const char *where, int portfd, int fd, int mask) { in aeApiAssociate()
152 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiAddEvent()
183 static void aeApiDelEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiDelEvent()
|
| H A D | ae.c | 135 int aeCreateFileEvent(aeEventLoop *eventLoop, int fd, int mask, in aeCreateFileEvent()
155 void aeDeleteFileEvent(aeEventLoop *eventLoop, int fd, int mask) in aeDeleteFileEvent()
173 int aeGetFileEvents(aeEventLoop *eventLoop, int fd) { in aeGetFileEvents()
404 int fd = eventLoop->fired[j].fd; in aeProcessEvents() local
430 int aeWait(int fd, int mask, long long milliseconds) { in aeWait()
|
| H A D | ae_select.c | 62 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiAddEvent()
70 static void aeApiDelEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiDelEvent()
|
| H A D | ae_epoll.c | 73 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiAddEvent()
90 static void aeApiDelEvent(aeEventLoop *eventLoop, int fd, int delmask) { in aeApiDelEvent()
|
| H A D | ae_kqueue.c | 75 static int aeApiAddEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiAddEvent()
90 static void aeApiDelEvent(aeEventLoop *eventLoop, int fd, int mask) { in aeApiDelEvent()
|
| H A D | config.h | 112 #define rdb_fsync_range(fd,off,size) sync_file_range(fd,off,size,SYNC_FILE_RANGE_WAIT_BEFORE|SYNC_F… argument
114 #define rdb_fsync_range(fd,off,size) fsync(fd) argument
|
| H A D | replication.c | 798 void sendBulkToSlave(aeEventLoop *el, int fd, void *privdata, int mask) { in sendBulkToSlave()
968 void replicationCreateMasterClient(int fd) { in replicationCreateMasterClient()
984 void readSyncBulkPayload(aeEventLoop *el, int fd, void *privdata, int mask) { in readSyncBulkPayload()
1181 char *sendSynchronousCommand(int flags, int fd, ...) { in sendSynchronousCommand()
1280 int slaveTryPartialResynchronization(int fd, int read_reply) { in slaveTryPartialResynchronization()
1386 void syncWithMaster(aeEventLoop *el, int fd, void *privdata, int mask) { in syncWithMaster()
1655 int fd; in connectWithMaster() local
1684 int fd = server.repl_transfer_s; in undoConnectWithMaster() local
|
| H A D | networking.c | 64 client *createClient(int fd) { in createClient()
616 static void acceptCommonHandler(int fd, int flags, char *ip) { in acceptCommonHandler()
686 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()
902 int writeToClient(int fd, client *c, int handler_installed) { in writeToClient()
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 D | debug.c | 830 int fd = log_to_stdout ? in openDirectLogFiledes() local
837 void closeDirectLogFiledes(int fd) { in closeDirectLogFiledes()
846 int trace_size = 0, fd = openDirectLogFiledes(); in logStackTrace() local
922 int fd = openDirectLogFiledes(); in memtest_test_linux_anonymous_maps() local
|
| H A D | aof.c | 95 void aofChildWriteDiffData(aeEventLoop *el, int fd, void *privdata, int mask) { in aofChildWriteDiffData()
173 ssize_t aofRewriteBufferWrite(int fd) { in aofRewriteBufferWrite()
201 void aof_background_fsync(int fd) { in aof_background_fsync()
1180 void aofChildPipeReadable(aeEventLoop *el, int fd, void *privdata, int mask) { in aofChildPipeReadable()
|
| H A D | cluster.c | 301 int fd; in clusterSaveConfig() local
369 int fd = open(filename,O_WRONLY|O_CREAT,0644); in clusterLockConfig() local
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()
3098 int fd; in clusterCron() local
4538 int fd; member
4555 int fd; in migrateGetSocket() local
|
| H A D | redis-benchmark.c | 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()
|
| H A D | ae.h | 85 int fd; member
|
| /redis-3.2.3/deps/hiredis/adapters/ |
| H A D | ae.h | 41 int fd; member
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()
|
| H A D | libevent.h | 42 static void redisLibeventReadEvent(int fd, short event, void *arg) { in redisLibeventReadEvent()
48 static void redisLibeventWriteEvent(int fd, short event, void *arg) { in redisLibeventWriteEvent()
|
| /redis-3.2.3/tests/ |
| H A D | test_helper.tcl | 246 proc read_from_test_client fd { argument
321 proc signal_idle_client fd { argument
|
| /redis-3.2.3/utils/ |
| H A D | corrupt_rdb.c | 16 int fd, cycles; in main() local
|
| /redis-3.2.3/deps/jemalloc/test/unit/ |
| H A D | prof_idump.c | 14 int fd; in prof_dump_open_intercept() local
|
| H A D | prof_gdump.c | 12 int fd; in prof_dump_open_intercept() local
|
| H A D | prof_accum.c | 16 int fd; in prof_dump_open_intercept() local
|
| H A D | prof_reset.c | 11 int fd; in prof_dump_open_intercept() local
|
| /redis-3.2.3/deps/linenoise/ |
| H A D | linenoise.c | 218 static int enableRawMode(int fd) { in enableRawMode()
253 static void disableRawMode(int fd) { in disableRawMode()
505 int fd = l->ofd; in refreshSingleLine() local
551 int fd = l->ofd, j; in refreshMultiLine() local
|