Lines Matching refs:this
2237 clusterNode *this = dictGetVal(de); in clusterSendPing() local
2243 if (this == myself) continue; in clusterSendPing()
2247 !(this->flags & (CLUSTER_NODE_PFAIL|CLUSTER_NODE_FAIL))) in clusterSendPing()
2255 if (this->flags & (CLUSTER_NODE_HANDSHAKE|CLUSTER_NODE_NOADDR) || in clusterSendPing()
2256 (this->link == NULL && this->numslots == 0)) in clusterSendPing()
2264 if (memcmp(hdr->data.ping.gossip[j].nodename,this->name, in clusterSendPing()
2272 memcpy(gossip->nodename,this->name,CLUSTER_NAMELEN); in clusterSendPing()
2273 gossip->ping_sent = htonl(this->ping_sent); in clusterSendPing()
2274 gossip->pong_received = htonl(this->pong_received); in clusterSendPing()
2275 memcpy(gossip->ip,this->ip,sizeof(this->ip)); in clusterSendPing()
2276 gossip->port = htons(this->port); in clusterSendPing()
2277 gossip->flags = htons(this->flags); in clusterSendPing()
3159 clusterNode *this = dictGetVal(de); in clusterCron() local
3162 if (this->link == NULL || this->ping_sent != 0) continue; in clusterCron()
3163 if (this->flags & (CLUSTER_NODE_MYSELF|CLUSTER_NODE_HANDSHAKE)) in clusterCron()
3165 if (min_pong_node == NULL || min_pong > this->pong_received) { in clusterCron()
3166 min_pong_node = this; in clusterCron()
3167 min_pong = this->pong_received; in clusterCron()