Lines Matching refs:mstime

190                 n->fail_time = mstime();  in clusterLoadConfig()
216 if (atoi(argv[4])) n->ping_sent = mstime(); in clusterLoadConfig()
217 if (atoi(argv[5])) n->pong_received = mstime(); in clusterLoadConfig()
549 link->ctime = mstime(); in createClusterLink()
660 node->ctime = mstime(); in createClusterNode()
704 fr->time = mstime(); in clusterNodeAddFailureReport()
712 fr->time = mstime(); in clusterNodeAddFailureReport()
729 mstime_t now = mstime(); in clusterNodeCleanupFailureReports()
1169 node->fail_time = mstime(); in markNodeAsFailingIfNeeded()
1181 mstime_t now = mstime(); in clearNodeFailureIfNeeded()
1615 sender->repl_offset_time = mstime(); in clusterProcessPacket()
1726 (int)(mstime()-(link->node->ctime)), in clusterProcessPacket()
1748 link->node->pong_received = mstime(); in clusterProcessPacket()
1895 failing->fail_time = mstime(); in clusterProcessPacket()
1948 server.cluster->mf_end = mstime() + CLUSTER_MF_TIMEOUT; in clusterProcessPacket()
1950 pauseClients(mstime()+(CLUSTER_MF_TIMEOUT*2)); in clusterProcessPacket()
2230 link->node->ping_sent = mstime(); in clusterSendPing()
2527 if (mstime() - node->slaveof->voted_time < server.cluster_node_timeout * 2) in clusterSendFailoverAuthIfNeeded()
2534 (mstime() - node->slaveof->voted_time))); in clusterSendFailoverAuthIfNeeded()
2563 node->slaveof->voted_time = mstime(); in clusterSendFailoverAuthIfNeeded()
2635 (mstime() - myself->slaveof->fail_time) < nolog_fail_time) return; in clusterLogCantFailover()
2706 mstime_t auth_age = mstime() - server.cluster->failover_auth_time; in clusterHandleSlaveFailover()
2774 server.cluster->failover_auth_time = mstime() + in clusterHandleSlaveFailover()
2787 server.cluster->failover_auth_time = mstime(); in clusterHandleSlaveFailover()
2793 server.cluster->failover_auth_time - mstime(), in clusterHandleSlaveFailover()
2824 if (mstime() < server.cluster->failover_auth_time) { in clusterHandleSlaveFailover()
2947 if (!node->orphaned_time) node->orphaned_time = mstime(); in clusterHandleSlaveMigration()
2974 (mstime()-target->orphaned_time) > CLUSTER_SLAVE_MIGRATION_DELAY) in clusterHandleSlaveMigration()
3029 if (server.cluster->mf_end && server.cluster->mf_end < mstime()) { in manualFailoverCheckTimeout()
3069 mstime_t min_pong = 0, now = mstime(); in clusterCron()
3110 if (node->ping_sent == 0) node->ping_sent = mstime(); in clusterCron()
3188 now = mstime(); /* Use an updated time at every iteration. */ in clusterCron()
3484 if (first_call_time == 0) first_call_time = mstime(); in clusterUpdateState()
3487 mstime() - first_call_time < CLUSTER_WRITABLE_DELAY) return; in clusterUpdateState()
3535 among_minority_time = mstime(); in clusterUpdateState()
3554 mstime() - among_minority_time < rejoin_delay) in clusterUpdateState()
4301 server.cluster->mf_end = mstime() + CLUSTER_MF_TIMEOUT; in clusterCommand()
4522 if (ttl) setExpire(c->db,c->argv[1],mstime()+ttl); in restoreCommand()
4748 ttl = expireat-mstime(); in migrateCommand()