53     static char buf[NET_PEER_ID_LEN];  in replicationGetSlaveName()  local
57     buf[0] = '\0';  in replicationGetSlaveName()
65             anetFormatAddr(buf,sizeof(buf),ip,c->slave_listening_port);  in replicationGetSlaveName()
67             snprintf(buf,sizeof(buf),"%s:<unknown-slave-port>",ip);  in replicationGetSlaveName()
69         snprintf(buf,sizeof(buf),"client id #%llu",  in replicationGetSlaveName()
72     return buf;  in replicationGetSlaveName()
388     char buf[128];  in replicationSetupSlaveForFullResync()  local
401         buflen = snprintf(buf,sizeof(buf),"+FULLRESYNC %s %lld\r\n",  in replicationSetupSlaveForFullResync()
403         if (write(slave->fd,buf,buflen) != buflen) {  in replicationSetupSlaveForFullResync()
419     char buf[128];  in masterTryPartialResynchronization()  local
466     buflen = snprintf(buf,sizeof(buf),"+CONTINUE\r\n");  in masterTryPartialResynchronization()
467     if (write(c->fd,buf,buflen) != buflen) {  in masterTryPartialResynchronization()
802     char buf[PROTO_IOBUF_LEN];  in sendBulkToSlave()  local
829     buflen = read(slave->repldbfd,buf,PROTO_IOBUF_LEN);  in sendBulkToSlave()
836     if ((nwritten = write(fd,buf,buflen)) == -1) {  in sendBulkToSlave()
883             struct redis_stat buf;  in updateSlavesWaitingBgsave()  local
909                     redis_fstat(slave->repldbfd,&buf) == -1) {  in updateSlavesWaitingBgsave()
915                 slave->repldbsize = buf.st_size;  in updateSlavesWaitingBgsave()
985     char buf[4096];  in readSyncBulkPayload()  local
1001         if (syncReadLine(fd,buf,1024,server.repl_syncio_timeout*1000) == -1) {  in readSyncBulkPayload()
1008         if (buf[0] == '-') {  in readSyncBulkPayload()
1011                 buf+1);  in readSyncBulkPayload()
1013         } else if (buf[0] == '\0') {  in readSyncBulkPayload()
1019         } else if (buf[0] != '$') {  in readSyncBulkPayload()
1020 …ER, the first byte is not '$' (we received '%s'), are you sure the host and port are right?", buf);  in readSyncBulkPayload()
1034         if (strncmp(buf+1,"EOF:",4) == 0 && strlen(buf+5) >= CONFIG_RUN_ID_SIZE) {  in readSyncBulkPayload()
1036             memcpy(eofmark,buf+5,CONFIG_RUN_ID_SIZE);  in readSyncBulkPayload()
1045             server.repl_transfer_size = strtol(buf+1,NULL,10);  in readSyncBulkPayload()
1055         readlen = sizeof(buf);  in readSyncBulkPayload()
1058         readlen = (left < (signed)sizeof(buf)) ? left : (signed)sizeof(buf);  in readSyncBulkPayload()
1061     nread = read(fd,buf,readlen);  in readSyncBulkPayload()
1077             memcpy(lastbytes,buf+nread-CONFIG_RUN_ID_SIZE,CONFIG_RUN_ID_SIZE);  in readSyncBulkPayload()
1081             memcpy(lastbytes+rem,buf,nread);  in readSyncBulkPayload()
1087     if (write(server.repl_transfer_fd,buf,nread) != nread) {  in readSyncBulkPayload()
1214         char buf[256];  in sendSynchronousCommand()  local
1216         if (syncReadLine(fd,buf,sizeof(buf),server.repl_syncio_timeout*1000)  in sendSynchronousCommand()
1223         return sdsnew(buf);  in sendSynchronousCommand()