Home
last modified time | relevance | path

Searched refs:mstime_t (Results 1 – 25 of 25) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dcluster.h42 mstime_t ctime; /* Link creation time */
113 mstime_t time; /* Time of the last report from this node. */
117 mstime_t ctime; /* Node object creation time. */
129 mstime_t ping_sent; /* Unix time we sent latest ping */
130 mstime_t pong_received; /* Unix time we received the pong */
131 mstime_t fail_time; /* Unix time when FAIL flag was set */
132 mstime_t voted_time; /* Last time we voted for a slave of this master */
133 mstime_t repl_offset_time; /* Unix time we received offset for this node */
134 mstime_t orphaned_time; /* Starting time of orphaned master condition */
156 mstime_t failover_auth_time; /* Time of previous or next election. */
[all …]
H A Dsentinel.c192 mstime_t role_reported_time;
219 mstime_t failover_state_change_time;
756 mstime_t now = mstime(); in sentinelRunPendingScripts()
868 mstime_t now = mstime(); in sentinelKillTimedoutScripts()
1545 mstime_t most_recent; in sentinelRedisInstanceNoDownFor()
2000 mstime_t now = mstime(); in sentinelReconnectInstance()
2661 mstime_t now = mstime(); in sentinelSendPeriodicCommands()
3209 mstime_t now = mstime(); in sentinelCommand()
3575 mstime_t elapsed = 0; in sentinelCheckSubjectivelyDown()
4108 mstime_t info_validity_time; in sentinelSelectSlave()
[all …]
H A Dstream.h68 mstime_t seen_time; /* Last time this consumer was active. */
83 mstime_t delivery_time; /* Last time this message was delivered. */
H A Dlatency.h65 void latencyAddSample(char *event, mstime_t latency);
H A Dserver.h53 typedef long long mstime_t; /* millisecond time type. */ typedef
671 mstime_t timeout; /* Blocking operation timeout. If UNIX current time
684 mstime_t xread_retry_time, xread_retry_ttl;
986 mstime_t clients_pause_end_time; /* Time when we undo clients_paused */
1234 mstime_t cluster_node_timeout; /* Cluster node timeout. */
1256 mstime_t lua_time_limit; /* Script timeout in milliseconds */
1257 mstime_t lua_time_start; /* Start time of script, milliseconds time */
1480 void pauseClients(mstime_t duration);
1755 int restartServer(int flags, mstime_t delay);
1910 int getTimeoutFromObjectOrReply(client *c, robj *object, mstime_t *timeout, int unit);
[all …]
H A Dredismodule.h144 typedef long long mstime_t; typedef
244 mstime_t REDISMODULE_API_FUNC(RedisModule_GetExpire)(RedisModuleKey *key);
245 int REDISMODULE_API_FUNC(RedisModule_SetExpire)(RedisModuleKey *key, mstime_t expire);
338 RedisModuleTimerID REDISMODULE_API_FUNC(RedisModule_CreateTimer)(RedisModuleCtx *ctx, mstime_t peri…
H A Dblocked.c78 int getTimeoutFromObjectOrReply(client *c, robj *object, mstime_t *timeout, int unit) { in getTimeoutFromObjectOrReply()
497 void blockForKeys(client *c, int btype, robj **keys, int numkeys, mstime_t timeout, robj *target, s… in blockForKeys()
H A Dcluster.c769 mstime_t maxtime = server.cluster_node_timeout * in clusterNodeCleanupFailureReports()
771 mstime_t now = mstime(); in clusterNodeCleanupFailureReports()
1223 mstime_t now = mstime(); in clearNodeFailureIfNeeded()
2947 mstime_t data_age; in clusterHandleSlaveFailover()
2952 mstime_t auth_timeout, auth_retry_time; in clusterHandleSlaveFailover()
3316 mstime_t min_pong = 0, now = mstime(); in clusterCron()
3319 mstime_t handshake_timeout; in clusterCron()
3386 mstime_t old_ping_sent; in clusterCron()
3475 mstime_t delay; in clusterCron()
3762 static mstime_t among_minority_time; in clusterUpdateState()
[all …]
H A Dt_stream.c2023 mstime_t now = mstime(); in xpendingCommand()
2049 mstime_t elapsed = now - nack->delivery_time; in xpendingCommand()
2132 mstime_t deliverytime = -1; /* -1 means IDLE/TIME options not given. */ in xclaimCommand()
2168 mstime_t now = mstime(); in xclaimCommand()
2268 mstime_t this_idle = now - nack->delivery_time; in xclaimCommand()
2477 mstime_t now = mstime(); in xinfoCommand()
2480 mstime_t idle = now - consumer->seen_time; in xinfoCommand()
H A Daof.c340 mstime_t latency; in flushAppendOnlyFile()
1414 mstime_t start = mstime(); in rewriteAppendOnlyFile()
1646 mstime_t latency; in aofUpdateCurrentSize()
1666 mstime_t latency; in backgroundRewriteDoneHandler()
H A Dexpire.c290 mstime_t start = mstime(); in expireSlaveKeys()
H A Dt_list.c688 mstime_t timeout; in blockingPopGenericCommand()
751 mstime_t timeout; in brpoplpushCommand()
H A Devict.c452 mstime_t latency, eviction_latency; in freeMemoryIfNeeded()
H A Dlatency.c98 void latencyAddSample(char *event, mstime_t latency) { in latencyAddSample()
H A Ddb.c1131 mstime_t when = getExpire(db,key); in keyIsExpired()
1143 mstime_t now = server.lua_caller ? server.lua_time_start : mstime(); in keyIsExpired()
H A Dserver.c442 mstime_t mstime(void) { in mstime()
820 int clientsCronHandleTimeout(client *c, mstime_t now_ms) { in clientsCronHandleTimeout()
974 mstime_t now = mstime(); in clientsCron()
1753 int restartServer(int flags, mstime_t delay) { in restartServer()
H A Dmodule.c1620 mstime_t RM_GetExpire(RedisModuleKey *key) { in RM_GetExpire()
1621 mstime_t expire = getExpire(key->db,key->key); in RM_GetExpire()
1636 int RM_SetExpire(RedisModuleKey *key, mstime_t expire) { in RM_SetExpire()
4345 RedisModuleTimerID RM_CreateTimer(RedisModuleCtx *ctx, mstime_t period, RedisModuleTimerProc callba… in RM_CreateTimer()
H A Dscripting.c2423 mstime_t elapsed = mstime() - server.lua_time_start; in luaLdbLineHook()
2424 mstime_t timelimit = server.lua_time_limit ? in luaLdbLineHook()
H A Ddefrag.c1039 mstime_t latency; in activeDefragCycle()
H A Dreplication.c2437 mstime_t timeout; in waitCommand()
H A Dnetworking.c2181 void pauseClients(mstime_t end) { in pauseClients()
H A Drdb.c2097 mstime_t latency; in backgroundSaveDoneHandlerDisk()
H A Dt_zset.c3262 mstime_t timeout; in blockingGenericZpopCommand()
/f-stack/app/redis-5.0.5/src/modules/
H A Dhelloworld.c354 mstime_t addms, expire; in HelloMoreExpire_RedisCommand()
/f-stack/app/redis-5.0.5/
H A D00-RELEASENOTES825 Use typedef'd mstime_t instead of time_t