Lines Matching refs:name
60 clusterNode *clusterLookupNode(char *name);
267 serverLog(LL_NOTICE,"Node configuration loaded, I'm %.40s", myself->name); in clusterLoadConfig()
433 myself->name); in clusterInit()
529 oldname = sdsnewlen(myself->name, CLUSTER_NAMELEN); in clusterReset()
532 getRandomHexChars(myself->name, CLUSTER_NAMELEN); in clusterReset()
534 serverLog(LL_NOTICE,"Node hard reset, now I'm %.40s", myself->name); in clusterReset()
657 memcpy(node->name, nodename, CLUSTER_NAMELEN); in createClusterNode()
659 getRandomHexChars(node->name, CLUSTER_NAMELEN); in createClusterNode()
832 nodename = sdsnewlen(n->name, CLUSTER_NAMELEN); in freeClusterNode()
848 sdsnewlen(node->name,CLUSTER_NAMELEN), node); in clusterAddNode()
893 clusterNode *clusterLookupNode(char *name) { in clusterLookupNode() argument
894 sds s = sdsnewlen(name, CLUSTER_NAMELEN); in clusterLookupNode()
909 sds s = sdsnewlen(node->name, CLUSTER_NAMELEN); in clusterRenameNode()
912 node->name, newname); in clusterRenameNode()
916 memcpy(node->name, newname, CLUSTER_NAMELEN); in clusterRenameNode()
1040 if (memcmp(sender->name,myself->name,CLUSTER_NAMELEN) <= 0) return; in clusterHandleConfigEpochCollision()
1048 sender->name, in clusterHandleConfigEpochCollision()
1100 sds id = sdsnewlen(node->name,CLUSTER_NAMELEN); in clusterBlacklistAddNode()
1164 "Marking node %.40s as failing (quorum reached).", node->name); in markNodeAsFailingIfNeeded()
1173 if (nodeIsMaster(myself)) clusterSendFail(node->name); in markNodeAsFailingIfNeeded()
1190 node->name, in clearNodeFailureIfNeeded()
1206 node->name); in clearNodeFailureIfNeeded()
1321 sender->name, node->name); in clusterProcessGossipSection()
1328 sender->name, node->name); in clusterProcessGossipSection()
1403 node->name, node->ip, node->port); in nodeUpdateAddressIfNeeded()
1514 "as a replica of %.40s", sender->name); in clusterUpdateSlotsConfigWith()
1698 "updating the address if needed.", sender->name); in clusterProcessPacket()
1714 link->node->name); in clusterProcessPacket()
1718 } else if (memcmp(link->node->name,hdr->sender, in clusterProcessPacket()
1725 link->node->name, in clusterProcessPacket()
1859 sender->name, server.cluster->slots[j]->name); in clusterProcessPacket()
1952 sender->name); in clusterProcessPacket()
2135 memcpy(hdr->sender,myself->name,CLUSTER_NAMELEN); in clusterBuildMessageHdr()
2140 memcpy(hdr->slaveof,myself->slaveof->name, CLUSTER_NAMELEN); in clusterBuildMessageHdr()
2264 if (memcmp(hdr->data.ping.gossip[j].nodename,this->name, in clusterSendPing()
2272 memcpy(gossip->nodename,this->name,CLUSTER_NAMELEN); in clusterSendPing()
2397 memcpy(hdr->data.update.nodecfg.nodename,node->name,CLUSTER_NAMELEN); in clusterSendUpdate()
2487 node->name, in clusterSendFailoverAuthIfNeeded()
2497 node->name, in clusterSendFailoverAuthIfNeeded()
2511 node->name); in clusterSendFailoverAuthIfNeeded()
2515 node->name); in clusterSendFailoverAuthIfNeeded()
2519 node->name); in clusterSendFailoverAuthIfNeeded()
2532 node->name, in clusterSendFailoverAuthIfNeeded()
2554 node->name, j, in clusterSendFailoverAuthIfNeeded()
2565 node->name, (unsigned long long) server.cluster->currentEpoch); in clusterSendFailoverAuthIfNeeded()
2957 if (memcmp(node->slaves[j]->name, in clusterHandleSlaveMigration()
2958 candidate->name, in clusterHandleSlaveMigration()
2977 target->name); in clusterHandleSlaveMigration()
3145 node->name, node->ip, node->port+CLUSTER_PORT_INCR); in clusterCron()
3171 serverLog(LL_DEBUG,"Pinging node %.40s", min_pong_node->name); in clusterCron()
3264 node->name); in clusterCron()
3662 char *name; member
3684 if (flags & nodeflag->flag) ci = sdscat(ci, nodeflag->name); in representClusterNodeFlags()
3701 node->name, in clusterGenNodeDescription()
3710 ci = sdscatprintf(ci," %.40s ",node->slaveof->name); in clusterGenNodeDescription()
3749 server.cluster->migrating_slots_to[j]->name); in clusterGenNodeDescription()
3752 server.cluster->importing_slots_from[j]->name); in clusterGenNodeDescription()
3858 addReplyBulkCBuffer(c, node->name, CLUSTER_NAMELEN); in clusterReplyMultiBulkSlots()
3868 addReplyBulkCBuffer(c, node->slaves[i]->name, CLUSTER_NAMELEN); in clusterReplyMultiBulkSlots()
3913 addReplyBulkCBuffer(c,myself->name, CLUSTER_NAMELEN); in clusterCommand()
4556 sds name = sdsempty(); in migrateGetSocket() local
4560 name = sdscatlen(name,host->ptr,sdslen(host->ptr)); in migrateGetSocket()
4561 name = sdscatlen(name,":",1); in migrateGetSocket()
4562 name = sdscatlen(name,port->ptr,sdslen(port->ptr)); in migrateGetSocket()
4563 cs = dictFetchValue(server.migrate_cached_sockets,name); in migrateGetSocket()
4565 sdsfree(name); in migrateGetSocket()
4584 sdsfree(name); in migrateGetSocket()
4593 sdsfree(name); in migrateGetSocket()
4605 dictAdd(server.migrate_cached_sockets,name,cs); in migrateGetSocket()
4611 sds name = sdsempty(); in migrateCloseSocket() local
4614 name = sdscatlen(name,host->ptr,sdslen(host->ptr)); in migrateCloseSocket()
4615 name = sdscatlen(name,":",1); in migrateCloseSocket()
4616 name = sdscatlen(name,port->ptr,sdslen(port->ptr)); in migrateCloseSocket()
4617 cs = dictFetchValue(server.migrate_cached_sockets,name); in migrateCloseSocket()
4619 sdsfree(name); in migrateCloseSocket()
4625 dictDelete(server.migrate_cached_sockets,name); in migrateCloseSocket()
4626 sdsfree(name); in migrateCloseSocket()