| /redis-3.2.3/src/ |
| H A D | syncio.c | 49 ssize_t syncWrite(int fd, char *ptr, ssize_t size, long long timeout) { in syncWrite() argument
52 long long remaining = timeout; in syncWrite()
73 if (elapsed >= timeout) { in syncWrite()
77 remaining = timeout - elapsed; in syncWrite()
85 ssize_t syncRead(int fd, char *ptr, ssize_t size, long long timeout) { in syncRead() argument
88 long long remaining = timeout; in syncRead()
112 if (elapsed >= timeout) { in syncRead()
116 remaining = timeout - elapsed; in syncRead()
125 ssize_t syncReadLine(int fd, char *ptr, ssize_t size, long long timeout) { in syncReadLine() argument
132 if (syncRead(fd,&c,1,timeout) == -1) return -1; in syncReadLine()
|
| H A D | ae_kqueue.c | 109 struct timespec timeout; in aeApiPoll() local
110 timeout.tv_sec = tvp->tv_sec; in aeApiPoll()
111 timeout.tv_nsec = tvp->tv_usec * 1000; in aeApiPoll()
113 &timeout); in aeApiPoll()
|
| H A D | ae_evport.c | 245 struct timespec timeout, *tsp; in aeApiPoll() local
273 timeout.tv_sec = tvp->tv_sec; in aeApiPoll()
274 timeout.tv_nsec = tvp->tv_usec * 1000; in aeApiPoll()
275 tsp = &timeout; in aeApiPoll()
|
| H A D | blocked.c | 76 int getTimeoutFromObjectOrReply(client *c, robj *object, mstime_t *timeout, int unit) { in getTimeoutFromObjectOrReply() argument
92 *timeout = tval; in getTimeoutFromObjectOrReply()
|
| H A D | t_list.c | 616 void blockForKeys(client *c, robj **keys, int numkeys, mstime_t timeout, robj *target) { in blockForKeys() argument
621 c->bpop.timeout = timeout; in blockForKeys()
873 mstime_t timeout; in blockingPopGenericCommand() local
876 if (getTimeoutFromObjectOrReply(c,c->argv[c->argc-1],&timeout,UNIT_SECONDS) in blockingPopGenericCommand()
924 blockForKeys(c, c->argv + 1, c->argc - 2, timeout, NULL); in blockingPopGenericCommand()
936 mstime_t timeout; in brpoplpushCommand() local
938 if (getTimeoutFromObjectOrReply(c,c->argv[3],&timeout,UNIT_SECONDS) in brpoplpushCommand()
950 blockForKeys(c, c->argv + 1, 1, timeout, c->argv[2]); in brpoplpushCommand()
|
| H A D | server.h | 533 mstime_t timeout; /* Blocking operation timeout. If UNIX current time member
1227 ssize_t syncWrite(int fd, char *ptr, ssize_t size, long long timeout);
1228 ssize_t syncRead(int fd, char *ptr, ssize_t size, long long timeout);
1229 ssize_t syncReadLine(int fd, char *ptr, ssize_t size, long long timeout);
1470 int getTimeoutFromObjectOrReply(client *c, robj *object, mstime_t *timeout, int unit);
|
| H A D | redis-trib.rb | 1394 timeout = argv[1].to_i
1395 if timeout < 100
1409 n.r.config("set","cluster-node-timeout",timeout)
|
| H A D | cluster.c | 4554 migrateCachedSocket* migrateGetSocket(client *c, robj *host, robj *port, long timeout) { in migrateGetSocket() argument
4592 if ((aeWait(fd,AE_WRITABLE,timeout) & AE_WRITABLE) == 0) { in migrateGetSocket()
4653 long timeout; in migrateCommand() local
4695 if (getLongFromObjectOrReply(c,c->argv[5],&timeout,NULL) != C_OK || in migrateCommand()
4700 if (timeout <= 0) timeout = 1000; in migrateCommand()
4728 cs = migrateGetSocket(c,c->argv[1],c->argv[2],timeout); in migrateCommand()
4785 nwritten = syncWrite(cs->fd,buf+pos,towrite,timeout); in migrateCommand()
4798 if (select && syncReadLine(cs->fd, buf1, sizeof(buf1), timeout) <= 0) in migrateCommand()
4809 if (syncReadLine(cs->fd, buf2, sizeof(buf2), timeout) <= 0) { in migrateCommand()
|
| H A D | replication.c | 2138 mstime_t timeout; in waitCommand() local
2145 if (getTimeoutFromObjectOrReply(c,c->argv[2],&timeout,UNIT_MILLISECONDS) in waitCommand()
2157 c->bpop.timeout = timeout; in waitCommand()
|
| H A D | scripting.c | 2349 int timeout = 0; in luaLdbLineHook() local
2360 timeout = 1; in luaLdbLineHook()
2371 else if (timeout) reason = "timeout reached, infinite loop?"; in luaLdbLineHook()
2379 if (ldbRepl(lua) == C_ERR && timeout) { in luaLdbLineHook()
|
| H A D | sentinel.c | 4045 int not_reconfigured = 0, timeout = 0; in sentinelFailoverDetectEnd() local
4070 timeout = 1; in sentinelFailoverDetectEnd()
4083 if (timeout) { in sentinelFailoverDetectEnd()
|
| /redis-3.2.3/deps/jemalloc/test/src/ |
| H A D | mq.c | 17 struct timespec timeout; in mq_nanosleep() local
20 timeout.tv_sec = 0; in mq_nanosleep()
21 timeout.tv_nsec = ns; in mq_nanosleep()
23 timeout.tv_sec = 1; in mq_nanosleep()
24 timeout.tv_nsec = 0; in mq_nanosleep()
26 nanosleep(&timeout, NULL); in mq_nanosleep()
|
| /redis-3.2.3/deps/hiredis/ |
| H A D | net.c | 178 static int redisContextWaitReady(redisContext *c, const struct timeval *timeout) { in redisContextWaitReady() argument
187 if (timeout != NULL) { in redisContextWaitReady()
188 if (timeout->tv_usec > 1000000 || timeout->tv_sec > __MAX_MSEC) { in redisContextWaitReady()
194 msec = (timeout->tv_sec * 1000) + ((timeout->tv_usec + 999) / 1000); in redisContextWaitReady()
257 const struct timeval *timeout, in _redisContextConnectTcp() argument
318 if (redisContextWaitReady(c,timeout) != REDIS_OK) in _redisContextConnectTcp()
346 const struct timeval *timeout) { in redisContextConnectTcp() argument
347 return _redisContextConnectTcp(c, addr, port, timeout, NULL); in redisContextConnectTcp()
351 const struct timeval *timeout, in redisContextConnectBindTcp() argument
353 return _redisContextConnectTcp(c, addr, port, timeout, source_addr); in redisContextConnectBindTcp()
[all …]
|
| H A D | net.h | 44 …redisContextConnectTcp(redisContext *c, const char *addr, int port, const struct timeval *timeout);
46 const struct timeval *timeout,
48 int redisContextConnectUnix(redisContext *c, const char *path, const struct timeval *timeout);
|
| H A D | test.c | 27 struct timeval timeout; member
480 config.tcp.timeout.tv_sec = 0; in test_invalid_timeout_errors()
481 config.tcp.timeout.tv_usec = 10000001; in test_invalid_timeout_errors()
483 c = redisConnectWithTimeout(config.tcp.host, config.tcp.port, config.tcp.timeout); in test_invalid_timeout_errors()
489 config.tcp.timeout.tv_sec = (((LONG_MAX) - 999) / 1000) + 1; in test_invalid_timeout_errors()
490 config.tcp.timeout.tv_usec = 0; in test_invalid_timeout_errors()
492 c = redisConnectWithTimeout(config.tcp.host, config.tcp.port, config.tcp.timeout); in test_invalid_timeout_errors()
|
| /redis-3.2.3/deps/hiredis/examples/ |
| H A D | example.c | 14 struct timeval timeout = { 1, 500000 }; // 1.5 seconds in main() local
15 c = redisConnectWithTimeout(hostname, port, timeout); in main()
|
| /redis-3.2.3/ |
| H A D | sentinel.conf | 115 sentinel failover-timeout mymaster 180000
|
| H A D | redis.conf | 105 timeout 0
|
| /redis-3.2.3/tests/assets/ |
| H A D | default.conf | 7 timeout 0
|
| /redis-3.2.3/utils/create-cluster/ |
| H A D | create-cluster | 25 …ster-enabled yes --cluster-config-file nodes-${PORT}.conf --cluster-node-timeout $TIMEOUT --append…
|
| /redis-3.2.3/tests/integration/ |
| H A D | replication.tcl | 44 test {Slave is able to detect timeout during handshake} {
|
| /redis-3.2.3/tests/ |
| H A D | test_helper.tcl | 451 } elseif {$opt eq {--timeout}} {
|
| /redis-3.2.3/tests/unit/ |
| H A D | dump.tcl | 202 test {MIGRATE timeout actually works} {
|
| /redis-3.2.3/deps/jemalloc/bin/ |
| H A D | jeprof.in | 3276 my $timeout = shift;
3278 if (defined($timeout)) {
3280 push(@fetcher, "--max-time", sprintf("%d", $timeout));
3282 push(@fetcher, sprintf("--deadline=%d", $timeout));
|
| /redis-3.2.3/tests/unit/type/ |
| H A D | list.tcl | 390 test {BRPOPLPUSH timeout} {
|