Lines Matching refs:nread
986 ssize_t nread, readlen; in readSyncBulkPayload() local
1061 nread = read(fd,buf,readlen); in readSyncBulkPayload()
1062 if (nread <= 0) { in readSyncBulkPayload()
1064 (nread == -1) ? strerror(errno) : "connection lost"); in readSyncBulkPayload()
1068 server.stat_net_input_bytes += nread; in readSyncBulkPayload()
1076 if (nread >= CONFIG_RUN_ID_SIZE) { in readSyncBulkPayload()
1077 memcpy(lastbytes,buf+nread-CONFIG_RUN_ID_SIZE,CONFIG_RUN_ID_SIZE); in readSyncBulkPayload()
1079 int rem = CONFIG_RUN_ID_SIZE-nread; in readSyncBulkPayload()
1080 memmove(lastbytes,lastbytes+nread,rem); in readSyncBulkPayload()
1081 memcpy(lastbytes+rem,buf,nread); in readSyncBulkPayload()
1087 if (write(server.repl_transfer_fd,buf,nread) != nread) { in readSyncBulkPayload()
1091 server.repl_transfer_read += nread; in readSyncBulkPayload()