| /redis-3.2.3/src/ |
| H A D | syncio.c | 86 ssize_t nread, totread = 0; in syncRead() local
98 nread = read(fd,ptr,size); in syncRead()
99 if (nread == 0) return -1; /* short read. */ in syncRead()
100 if (nread == -1) { in syncRead()
103 ptr += nread; in syncRead()
104 size -= nread; in syncRead()
105 totread += nread; in syncRead()
126 ssize_t nread = 0; in syncReadLine() local
136 return nread; in syncReadLine()
140 nread++; in syncReadLine()
[all …]
|
| H A D | redis-cli.c | 1087 if (nread == 0) break; in readArgFromStdin()
1378 size_t nread; in evalMode() local
1659 ssize_t nread; in sendSync() local
1670 nread = read(fd,p,1); in sendSync()
1671 if (nread <= 0) { in sendSync()
1697 ssize_t nread; in slaveMode() local
1700 if (nread <= 0) { in slaveMode()
1704 payload -= nread; in slaveMode()
1745 if (nread <= 0) { in getRDB()
1755 payload -= nread; in getRDB()
[all …]
|
| H A D | anet.c | 412 ssize_t nread, totlen = 0; in anetRead() local
414 nread = read(fd,buf,count-totlen); in anetRead()
415 if (nread == 0) return totlen; in anetRead()
416 if (nread == -1) return -1; in anetRead()
417 totlen += nread; in anetRead()
418 buf += nread; in anetRead()
|
| H A D | replication.c | 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()
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()
[all …]
|
| H A D | networking.c | 1309 int nread, readlen; in readQueryFromClient() local
1332 nread = read(fd, c->querybuf+qblen, readlen); in readQueryFromClient()
1333 if (nread == -1) { in readQueryFromClient()
1341 } else if (nread == 0) { in readQueryFromClient()
1347 sdsIncrLen(c->querybuf,nread); in readQueryFromClient()
1349 if (c->flags & CLIENT_MASTER) c->reploff += nread; in readQueryFromClient()
1350 server.stat_net_input_bytes += nread; in readQueryFromClient()
|
| H A D | aof.c | 998 ssize_t nread, total = 0; in aofReadDiffFromParent() local
1000 while ((nread = in aofReadDiffFromParent()
1002 server.aof_child_diff = sdscatlen(server.aof_child_diff,buf,nread); in aofReadDiffFromParent()
1003 total += nread; in aofReadDiffFromParent()
|
| H A D | cluster.c | 2017 ssize_t nread; in clusterReadHandler() local
2050 nread = read(fd,buf,readlen); in clusterReadHandler()
2051 if (nread == -1 && errno == EAGAIN) return; /* No more data ready. */ in clusterReadHandler()
2053 if (nread <= 0) { in clusterReadHandler()
2056 (nread == 0) ? "connection closed" : strerror(errno)); in clusterReadHandler()
2061 link->rcvbuf = sdscatlen(link->rcvbuf,buf,nread); in clusterReadHandler()
2063 rcvbuflen += nread; in clusterReadHandler()
|
| H A D | scripting.c | 2235 int nread = read(ldb.fd,buf,sizeof(buf)); in ldbRepl() local
2236 if (nread <= 0) { in ldbRepl()
2243 ldb.cbuf = sdscatlen(ldb.cbuf,buf,nread); in ldbRepl()
|
| /redis-3.2.3/deps/linenoise/ |
| H A D | linenoise.c | 352 int nread, nwritten; in completeLine() local
376 nread = read(ls->ifd,&c,1); in completeLine()
377 if (nread <= 0) { in completeLine()
797 int nread; in linenoiseEdit() local
800 nread = read(l.ifd,&c,1); in linenoiseEdit()
801 if (nread <= 0) return l.len; in linenoiseEdit()
964 int nread; in linenoisePrintKeyCodes() local
966 nread = read(STDIN_FILENO,&c,1); in linenoisePrintKeyCodes()
967 if (nread <= 0) continue; in linenoisePrintKeyCodes()
|
| /redis-3.2.3/deps/hiredis/ |
| H A D | hiredis.c | 1136 int nread; in redisBufferRead() local
1142 nread = read(c->fd,buf,sizeof(buf)); in redisBufferRead()
1143 if (nread == -1) { in redisBufferRead()
1150 } else if (nread == 0) { in redisBufferRead()
1154 if (redisReaderFeed(c->reader,buf,nread) != REDIS_OK) { in redisBufferRead()
|
| /redis-3.2.3/deps/jemalloc/src/ |
| H A D | prof.c | 1396 ssize_t nread; in prof_dump_maps() local
1403 nread = 0; in prof_dump_maps()
1405 prof_dump_buf_end += nread; in prof_dump_maps()
1414 nread = read(mfd, &prof_dump_buf[prof_dump_buf_end], in prof_dump_maps()
1416 } while (nread > 0); in prof_dump_maps()
|
| H A D | ctl.c | 1754 unsigned nread, i; in arenas_initialized_ctl() local
1760 nread = (*oldlenp < ctl_stats.narenas * sizeof(bool)) in arenas_initialized_ctl()
1764 nread = ctl_stats.narenas; in arenas_initialized_ctl()
1767 for (i = 0; i < nread; i++) in arenas_initialized_ctl()
|
| /redis-3.2.3/tests/support/ |
| H A D | redis.tcl | 273 set nread [string length $data]
|