diff options
Diffstat (limited to 'Untitled Project.si4project/Untitled Project.SearchResults')
| -rw-r--r-- | Untitled Project.si4project/Untitled Project.SearchResults | 141 |
1 files changed, 141 insertions, 0 deletions
diff --git a/Untitled Project.si4project/Untitled Project.SearchResults b/Untitled Project.si4project/Untitled Project.SearchResults new file mode 100644 index 0000000..a647c44 --- /dev/null +++ b/Untitled Project.si4project/Untitled Project.SearchResults @@ -0,0 +1,141 @@ +---- delay Matches (161 in 16 files) ---- +ae.c (src) line 237 : * put in sleep without to delay any event. +processTimeEvents in ae.c (src) : * right value, time events may be delayed in a random way. Often this +processTimeEvents in ae.c (src) : * processing events earlier is less dangerous than delaying them +anetKeepAlive in anet.c (src) : * delay as interval / 3, as we send three probes before detecting +anet.c (src) line 141 : static int anetSetTcpNoDelay(char *err, int fd, int val) +anetSetTcpNoDelay in anet.c (src) : if (setsockopt(fd, IPPROTO_TCP, TCP_NODELAY, &val, sizeof(val)) == -1) +anetSetTcpNoDelay in anet.c (src) : anetSetError(err, "setsockopt TCP_NODELAY: %s", strerror(errno)); +anet.c (src) line 151 : int anetEnableTcpNoDelay(char *err, int fd) +anetEnableTcpNoDelay in anet.c (src) : return anetSetTcpNoDelay(err, fd, 1); +anet.c (src) line 156 : int anetDisableTcpNoDelay(char *err, int fd) +anetDisableTcpNoDelay in anet.c (src) : return anetSetTcpNoDelay(err, fd, 0); +anet.h (src) line 69 : int anetEnableTcpNoDelay(char *err, int fd); +anet.h (src) line 70 : int anetDisableTcpNoDelay(char *err, int fd); +aof.c (src) line 278 : * When the fsync policy is set to 'everysec' we may delay the flush if there +flushAppendOnlyFile in aof.c (src) : * If the fsync is still in progress we can try to delay +flushAppendOnlyFile in aof.c (src) : server.aof_delayed_fsync++; +flushAppendOnlyFile in aof.c (src) : /* We want to capture different events for delayed writes: +flushAppendOnlyFile in aof.c (src) : * when the delay happens with a pending fsync, or with a saving child +clusterAcceptHandler in cluster.c (src) : anetEnableTcpNoDelay(NULL,cfd); +cluster.c (src) line 2636 : * The slave rank is used to add a delay to start an election in order to +clusterLogCantFailover in cluster.c (src) : case CLUSTER_CANT_FAILOVER_WAITING_DELAY: +clusterLogCantFailover in cluster.c (src) : msg = "Waiting the delay before I can start a new failover."; +clusterHandleSlaveFailover in cluster.c (src) : 500 + /* Fixed delay of 500 milliseconds, let FAIL msg propagate. */ +clusterHandleSlaveFailover in cluster.c (src) : random() % 500; /* Random delay between 0 and 500 milliseconds. */ +clusterHandleSlaveFailover in cluster.c (src) : /* We add another delay that is proportional to the slave rank. +clusterHandleSlaveFailover in cluster.c (src) : /* However if this is a manual failover, no delay is needed. */ +clusterHandleSlaveFailover in cluster.c (src) : "Start of election delayed for %lld milliseconds " +clusterHandleSlaveFailover in cluster.c (src) : * slaves for the same master since we computed our election delay. +clusterHandleSlaveFailover in cluster.c (src) : * Update the delay if our rank changed. +clusterHandleSlaveFailover in cluster.c (src) : long long added_delay = +clusterHandleSlaveFailover in cluster.c (src) : server.cluster->failover_auth_time += added_delay; +clusterHandleSlaveFailover in cluster.c (src) : "Slave rank updated to #%d, added %lld milliseconds of delay.", +clusterHandleSlaveFailover in cluster.c (src) : newrank, added_delay); +clusterHandleSlaveFailover in cluster.c (src) : clusterLogCantFailover(CLUSTER_CANT_FAILOVER_WAITING_DELAY); +clusterHandleSlaveMigration in cluster.c (src) : (mstime()-target->orphaned_time) > CLUSTER_SLAVE_MIGRATION_DELAY) +clusterCron in cluster.c (src) : mstime_t delay; +clusterCron in cluster.c (src) : * a too big delay. */ +clusterCron in cluster.c (src) : /* Compute the delay of the PONG. Note that if we already received +clusterCron in cluster.c (src) : delay = now - node->ping_sent; +clusterCron in cluster.c (src) : if (delay > server.cluster_node_timeout) { +cluster.c (src) line 3547 : * writable delay is that they should be a few orders of magnitude larger +cluster.c (src) line 3549 : #define CLUSTER_MAX_REJOIN_DELAY 5000 +cluster.c (src) line 3550 : #define CLUSTER_MIN_REJOIN_DELAY 500 +cluster.c (src) line 3551 : #define CLUSTER_WRITABLE_DELAY 2000 +clusterUpdateState in cluster.c (src) : * reconfigure this node. Note that the delay is calculated starting from +clusterUpdateState in cluster.c (src) : mstime() - first_call_time < CLUSTER_WRITABLE_DELAY) return; +clusterUpdateState in cluster.c (src) : mstime_t rejoin_delay = server.cluster_node_timeout; +clusterUpdateState in cluster.c (src) : if (rejoin_delay > CLUSTER_MAX_REJOIN_DELAY) +clusterUpdateState in cluster.c (src) : rejoin_delay = CLUSTER_MAX_REJOIN_DELAY; +clusterUpdateState in cluster.c (src) : if (rejoin_delay < CLUSTER_MIN_REJOIN_DELAY) +clusterUpdateState in cluster.c (src) : rejoin_delay = CLUSTER_MIN_REJOIN_DELAY; +clusterUpdateState in cluster.c (src) : mstime() - among_minority_time < rejoin_delay) +migrateGetSocket in cluster.c (src) : anetEnableTcpNoDelay(server.neterr,fd); +cluster.h (src) line 22 : #define CLUSTER_FAILOVER_DELAY 5 /* Seconds */ +cluster.h (src) line 26 : #define CLUSTER_SLAVE_MIGRATION_DELAY 5000 /* Delay for slave migration. */ +cluster.h (src) line 71 : #define CLUSTER_CANT_FAILOVER_WAITING_DELAY 2 +loadServerConfigFromString in config.c (src) : } else if (!strcasecmp(argv[0],"repl-disable-tcp-nodelay") && argc==2) { +loadServerConfigFromString in config.c (src) : if ((server.repl_disable_tcp_nodelay = yesnotoi(argv[1])) == -1) { +loadServerConfigFromString in config.c (src) : } else if (!strcasecmp(argv[0],"repl-diskless-sync-delay") && argc==2) { +loadServerConfigFromString in config.c (src) : server.repl_diskless_sync_delay = atoi(argv[1]); +loadServerConfigFromString in config.c (src) : if (server.repl_diskless_sync_delay < 0) { +loadServerConfigFromString in config.c (src) : err = "repl-diskless-sync-delay can't be negative"; +configSetCommand in config.c (src) : "repl-disable-tcp-nodelay",server.repl_disable_tcp_nodelay) { +configSetCommand in config.c (src) : "repl-diskless-sync-delay",server.repl_diskless_sync_delay,0,LLONG_MAX) { +configGetCommand in config.c (src) : config_get_numerical_field("repl-diskless-sync-delay",server.repl_diskless_sync_delay); +configGetCommand in config.c (src) : config_get_bool_field("repl-disable-tcp-nodelay", +configGetCommand in config.c (src) : server.repl_disable_tcp_nodelay); +rewriteConfig in config.c (src) : rewriteConfigYesNoOption(state,"repl-disable-tcp-nodelay",server.repl_disable_tcp_nodelay,CONFIG_DEFAULT_REPL_DISABLE_TCP_NODELAY); +rewriteConfig in config.c (src) : rewriteConfigNumericalOption(state,"repl-diskless-sync-delay",server.repl_diskless_sync_delay,CONFIG_DEFAULT_REPL_DISKLESS_SYNC_DELAY); +debugCommand in debug.c (src) : "crash-and-recovery <milliseconds> -- Hard crash and restart after <milliseconds> delay."); +debugCommand in debug.c (src) : long long delay = 0; +debugCommand in debug.c (src) : if (getLongLongFromObjectOrReply(c, c->argv[2], &delay, NULL) +debugCommand in debug.c (src) : if (delay < 0) delay = 0; +debugCommand in debug.c (src) : restartServer(flags,delay); +HelloBlock_ThreadMain in helloblock.c (src\modules) : long long delay = (unsigned long)targ[1]; +HelloBlock_ThreadMain in helloblock.c (src\modules) : sleep(delay); +helloblock.c (src\modules) line 75 : /* HELLO.BLOCK <delay> <timeout> -- Block for <count> seconds, then reply with +helloblock.c (src\modules) line 77 : * what happens when the delay is greater than the timeout. */ +HelloBlock_RedisCommand in helloblock.c (src\modules) : long long delay; +HelloBlock_RedisCommand in helloblock.c (src\modules) : if (RedisModule_StringToLongLong(argv[1],&delay) != REDISMODULE_OK) { +HelloBlock_RedisCommand in helloblock.c (src\modules) : * the delay and a reference to the blocked client handle. */ +HelloBlock_RedisCommand in helloblock.c (src\modules) : targ[1] = (void*)(unsigned long) delay; +latency.c (src) line 475 : /* latencyCommand() helper to produce a time-delay reply for all the samples +createClient in networking.c (src) : anetEnableTcpNoDelay(NULL,fd); +getMemoryDoctorReport in object.c (src) : s = sdscat(s," * Big slave buffers: The slave output buffers in this instance are greater than 10MB for each slave (on average). This likely means that there is some slave instance that is struggling receiving data, either because it is too slow or because of networking issues. As a result, data piles on the master output buffers. Please try to identify what slave is not receiving data correctly and why. You can use the INFO output in order to check the slaves delays and the CLIENT LIST command to check the output buffers of each slave.\n\n"); +masterTryPartialResynchronization in replication.c (src) : * is generated, so we need to delay the reply to that moment. */ +syncCommand in replication.c (src) : if (server.repl_disable_tcp_nodelay) +syncCommand in replication.c (src) : anetDisableTcpNoDelay(NULL, c->fd); /* Non critical if it fails. */ +syncCommand in replication.c (src) : * replicationCron() since we want to delay its start a +syncCommand in replication.c (src) : if (server.repl_diskless_sync_delay) +syncCommand in replication.c (src) : serverLog(LL_NOTICE,"Delay next BGSAVE for diskless SYNC"); +syncCommand in replication.c (src) : "BGSAVE for replication delayed"); +readSyncBulkPayload in replication.c (src) : * we may suffer a big delay as the memory buffers are copied into the +replicationCron in replication.c (src) : max_idle > server.repl_diskless_sync_delay)) +sentinel.c (src) line 115 : #define SENTINEL_SCRIPT_RETRY_DELAY 30000 /* 30 seconds between retries. */ +sentinelRedisInstance in sentinel.c (src) : * This is useful in order to delay replacing what the instance reports +sentinelRedisInstance in sentinel.c (src) : mstime_t failover_delay_logged; /* For what failover_start_time value we +sentinelRedisInstance in sentinel.c (src) : logged the failover delay. */ +sentinel.c (src) line 777 : /* How much to delay the execution of a script that we need to retry after +sentinel.c (src) line 780 : * We double the retry delay for every further retry we do. So for instance +sentinel.c (src) line 781 : * if RETRY_DELAY is set to 30 seconds and the max number of retries is 10 +sentinel.c (src) line 782 : * starting from the second attempt to execute the script the delays are: +sentinel.c (src) line 784 : mstime_t sentinelScriptRetryDelay(int retry_num) { +sentinelScriptRetryDelay in sentinel.c (src) : mstime_t delay = SENTINEL_SCRIPT_RETRY_DELAY; +sentinelScriptRetryDelay in sentinel.c (src) : while (retry_num-- > 1) delay *= 2; +sentinelScriptRetryDelay in sentinel.c (src) : return delay; +sentinelCollectTerminatedScripts in sentinel.c (src) : sentinelScriptRetryDelay(sj->retry_num); +sentinelPendingScriptsCommand in sentinel.c (src) : mstime_t delay = sj->start_time ? (sj->start_time-mstime()) : 0; +sentinelPendingScriptsCommand in sentinel.c (src) : if (delay < 0) delay = 0; +sentinelPendingScriptsCommand in sentinel.c (src) : addReplyBulkCString(c,"run-delay"); +sentinelPendingScriptsCommand in sentinel.c (src) : addReplyBulkLongLong(c,delay); +createSentinelRedisInstance in sentinel.c (src) : ri->failover_delay_logged = 0; +sentinel.c (src) line 1392 : * failover timeout delay. +sentinelCheckSubjectivelyDown in sentinel.c (src) : /* The pending ping is delayed, and we did not received +sentinel.c (src) line 3469 : * However messages can be delayed so there are no strong guarantees about +sentinelVoteLeader in sentinel.c (src) : * time to now, in order to force a delay before we can start a +sentinelStartFailoverIfNeeded in sentinel.c (src) : if (master->failover_delay_logged != master->failover_start_time) { +sentinelStartFailoverIfNeeded in sentinel.c (src) : master->failover_delay_logged = master->failover_start_time; +sentinelStartFailoverIfNeeded in sentinel.c (src) : "Next failover delay: I will not start a failover before %s", +sentinelSelectSlave in sentinel.c (src) : * a larger delay. */ +server.c (src) line 120 : * F: Fast command: O(1) or O(log(N)) command that should never delay +serverCron in server.c (src) : * CONFIG_BGSAVE_RETRY_DELAY seconds already elapsed. */ +serverCron in server.c (src) : CONFIG_BGSAVE_RETRY_DELAY || +serverCron in server.c (src) : (server.unixtime-server.lastbgsave_try > CONFIG_BGSAVE_RETRY_DELAY || +initServerConfig in server.c (src) : server.aof_delayed_fsync = 0; +initServerConfig in server.c (src) : server.repl_disable_tcp_nodelay = CONFIG_DEFAULT_REPL_DISABLE_TCP_NODELAY; +initServerConfig in server.c (src) : server.repl_diskless_sync_delay = CONFIG_DEFAULT_REPL_DISKLESS_SYNC_DELAY; +server.c (src) line 1513 : int restartServer(int flags, mstime_t delay) { +restartServer in server.c (src) : if (delay) usleep(delay*1000); +resetServerStats in server.c (src) : server.aof_delayed_fsync = 0; +initServer in server.c (src) : openlog(server.syslog_ident, LOG_PID | LOG_NDELAY | LOG_NOWAIT, +genRedisInfoString in server.c (src) : "aof_delayed_fsync:%lu\r\n", +genRedisInfoString in server.c (src) : server.aof_delayed_fsync); +server.h (src) line 109 : #define CONFIG_BGSAVE_RETRY_DELAY 5 /* Wait a few secs before trying again. */ +server.h (src) line 127 : #define CONFIG_DEFAULT_REPL_DISKLESS_SYNC_DELAY 5 +server.h (src) line 132 : #define CONFIG_DEFAULT_REPL_DISABLE_TCP_NODELAY 0 +redisServer in server.h (src) : unsigned long aof_delayed_fsync; /* delayed AOF fsync() counter */ +redisServer in server.h (src) : int repl_diskless_sync_delay; /* Delay to start a diskless repl BGSAVE. */ +redisServer in server.h (src) : int repl_disable_tcp_nodelay; /* Disable TCP_NODELAY after SYNC? */ +server.h (src) line 1605 : int restartServer(int flags, mstime_t delay); |