Searched refs:readlen (Results 1 – 4 of 4) sorted by relevance
| /redis-3.2.3/src/ |
| H A D | rdb.c | 1496 int readlen = sizeof(uint64_t); in backgroundSaveDoneHandlerSocket() local
1498 if (read(server.rdb_pipe_read_result_from_child, ok_slaves, readlen) == in backgroundSaveDoneHandlerSocket()
1499 readlen) in backgroundSaveDoneHandlerSocket()
1501 readlen = ok_slaves[0]*sizeof(uint64_t)*2; in backgroundSaveDoneHandlerSocket()
1505 ok_slaves = zrealloc(ok_slaves,sizeof(uint64_t)+readlen); in backgroundSaveDoneHandlerSocket()
1506 if (readlen && in backgroundSaveDoneHandlerSocket()
1508 readlen) != readlen) in backgroundSaveDoneHandlerSocket()
|
| H A D | networking.c | 1309 int nread, readlen; in readQueryFromClient() local
1314 readlen = PROTO_IOBUF_LEN; in readQueryFromClient()
1326 if (remaining < readlen) readlen = remaining; in readQueryFromClient()
1331 c->querybuf = sdsMakeRoomFor(c->querybuf, readlen); in readQueryFromClient()
1332 nread = read(fd, c->querybuf+qblen, readlen); in readQueryFromClient()
|
| H A D | replication.c | 986 ssize_t nread, readlen; in readSyncBulkPayload() local
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()
|
| H A D | cluster.c | 2020 unsigned int readlen, rcvbuflen; in clusterReadHandler() local
2029 readlen = 8 - rcvbuflen; in clusterReadHandler()
2046 readlen = ntohl(hdr->totlen) - rcvbuflen; in clusterReadHandler()
2047 if (readlen > sizeof(buf)) readlen = sizeof(buf); in clusterReadHandler()
2050 nread = read(fd,buf,readlen); in clusterReadHandler()
|