Home
last modified time | relevance | path

Searched refs:nwritten (Results 1 – 24 of 24) sorted by relevance

/f-stack/app/redis-5.0.5/src/
H A Dsyncio.c50 ssize_t nwritten, ret = size; in syncWrite() local
61 nwritten = write(fd,ptr,size); in syncWrite()
62 if (nwritten == -1) { in syncWrite()
65 ptr += nwritten; in syncWrite()
66 size -= nwritten; in syncWrite()
H A Drdb.c142 size_t nwritten; in rdbSaveLen() local
148 nwritten = 1; in rdbSaveLen()
154 nwritten = 2; in rdbSaveLen()
170 return nwritten; in rdbSaveLen()
324 nwritten += n; in rdbSaveLzfBlob()
327 nwritten += n; in rdbSaveLzfBlob()
330 nwritten += n; in rdbSaveLzfBlob()
333 nwritten += n; in rdbSaveLzfBlob()
429 nwritten += n; in rdbSaveRawString()
686 nwritten += n; in rdbSaveStreamPEL()
[all …]
H A Drio.c203 size_t nwritten = 0; in rioFdsetWrite() local
204 while(nwritten != count) { in rioFdsetWrite()
205 retval = write(r->io.fdset.fds[j],p+nwritten,count-nwritten); in rioFdsetWrite()
214 nwritten += retval; in rioFdsetWrite()
217 if (nwritten != count) { in rioFdsetWrite()
327 size_t nwritten; in rioWriteBulkString() local
329 if ((nwritten = rioWriteBulkCount(r,'$',len)) == 0) return 0; in rioWriteBulkString()
332 return nwritten+len+2; in rioWriteBulkString()
H A Daof.c98 ssize_t nwritten; in aofChildWriteDiffData() local
116 memmove(block->buf,block->buf+nwritten,block->used-nwritten); in aofChildWriteDiffData()
182 ssize_t nwritten; in aofRewriteBufferWrite() local
190 count += nwritten; in aofRewriteBufferWrite()
303 if (nwritten < 0) { in aofWrite()
310 len -= nwritten; in aofWrite()
311 buf += nwritten; in aofWrite()
312 totwritten += nwritten; in aofWrite()
338 ssize_t nwritten; in flushAppendOnlyFile() local
419 if (nwritten == -1) { in flushAppendOnlyFile()
[all …]
H A Danet.c438 ssize_t nwritten, totlen = 0; in anetWrite() local
440 nwritten = write(fd,buf,count-totlen); in anetWrite()
441 if (nwritten == 0) return totlen; in anetWrite()
442 if (nwritten == -1) return -1; in anetWrite()
443 totlen += nwritten; in anetWrite()
444 buf += nwritten; in anetWrite()
H A Dreplication.c877 ssize_t nwritten, buflen; in sendBulkToSlave() local
883 nwritten = write(fd,slave->replpreamble,sdslen(slave->replpreamble)); in sendBulkToSlave()
884 if (nwritten == -1) { in sendBulkToSlave()
890 server.stat_net_output_bytes += nwritten; in sendBulkToSlave()
891 sdsrange(slave->replpreamble,nwritten,-1); in sendBulkToSlave()
910 if ((nwritten = write(fd,buf,buflen)) == -1) { in sendBulkToSlave()
918 slave->repldboff += nwritten; in sendBulkToSlave()
919 server.stat_net_output_bytes += nwritten; in sendBulkToSlave()
1119 ssize_t nread, readlen, nwritten; in readSyncBulkPayload() local
1220 if ((nwritten = write(server.repl_transfer_fd,buf,nread)) != nread) { in readSyncBulkPayload()
[all …]
H A Dnetworking.c980 ssize_t nwritten = 0, totwritten = 0; in writeToClient() local
986 nwritten = write(fd,c->buf+c->sentlen,c->bufpos-c->sentlen); in writeToClient()
987 if (nwritten <= 0) break; in writeToClient()
988 c->sentlen += nwritten; in writeToClient()
989 totwritten += nwritten; in writeToClient()
1007 nwritten = write(fd, o->buf + c->sentlen, objlen - c->sentlen); in writeToClient()
1008 if (nwritten <= 0) break; in writeToClient()
1009 c->sentlen += nwritten; in writeToClient()
1010 totwritten += nwritten; in writeToClient()
1041 if (nwritten == -1) { in writeToClient()
[all …]
H A Dredis-benchmark.c280 ssize_t nwritten = write(c->context->fd,ptr,sdslen(c->obuf)-c->written); in writeHandler() local
281 if (nwritten == -1) { in writeHandler()
287 c->written += nwritten; in writeHandler()
H A Dcluster.c2122 ssize_t nwritten; in clusterWriteHandler() local
2126 nwritten = write(fd, link->sndbuf, sdslen(link->sndbuf)); in clusterWriteHandler()
2127 if (nwritten <= 0) { in clusterWriteHandler()
2129 (nwritten == -1) ? strerror(errno) : "short write"); in clusterWriteHandler()
2133 sdsrange(link->sndbuf,nwritten,-1); in clusterWriteHandler()
5226 int nwritten = 0; in migrateCommand() local
5230 nwritten = syncWrite(cs->fd,buf+pos,towrite,timeout); in migrateCommand()
5231 if (nwritten != (signed)towrite) { in migrateCommand()
5235 pos += nwritten; in migrateCommand()
H A Dredis-cli.c6017 ssize_t nread, nwritten; in getRDB() local
6024 nwritten = write(fd, buf, nread); in getRDB()
6025 if (nwritten != nread) { in getRDB()
6027 (nwritten == -1) ? strerror(errno) : "short write"); in getRDB()
6125 ssize_t nwritten = write(fd,obuf+obuf_pos,obuf_len); in pipeMode() local
6127 if (nwritten == -1) { in pipeMode()
6133 nwritten = 0; in pipeMode()
6136 obuf_len -= nwritten; in pipeMode()
6137 obuf_pos += nwritten; in pipeMode()
6138 loop_nwritten += nwritten; in pipeMode()
/f-stack/freebsd/contrib/openzfs/module/zfs/
H A Ddbuf_stats.c70 size_t nwritten; in __dbuf_stats_hash_table_data() local
77 nwritten = snprintf(buf, size, in __dbuf_stats_hash_table_data()
121 if (nwritten >= size) in __dbuf_stats_hash_table_data()
124 return (nwritten + 1); in __dbuf_stats_hash_table_data()
H A Ddataset_kstats.c175 int64_t nwritten) in dataset_kstats_update_write_kstats() argument
177 ASSERT3S(nwritten, >=, 0); in dataset_kstats_update_write_kstats()
183 aggsum_add(&dk->dk_aggsums.das_nwritten, nwritten); in dataset_kstats_update_write_kstats()
H A Dspa_stats.c197 uint64_t nwritten; /* number of bytes written */ member
252 (u_longlong_t)sth->nread, (u_longlong_t)sth->nwritten, in spa_txg_history_show()
372 uint64_t nwritten, uint64_t reads, uint64_t writes, uint64_t ndirty) in spa_txg_history_set_io() argument
386 sth->nwritten = nwritten; in spa_txg_history_set_io()
H A Dzfs_vnops.c685 const int64_t nwritten = start_resid - uio->uio_resid; in zfs_write() local
686 dataset_kstats_update_write_kstats(&zfsvfs->z_kstat, nwritten); in zfs_write()
687 task_io_account_write(nwritten); in zfs_write()
H A Dvdev_queue.c616 ksio->nwritten += zio->io_size; in vdev_queue_pending_remove()
/f-stack/app/redis-5.0.5/deps/hiredis/
H A Dhiredis.c832 int nwritten; in redisBufferWrite() local
839 nwritten = write(c->fd,c->obuf,sdslen(c->obuf)); in redisBufferWrite()
840 if (nwritten == -1) { in redisBufferWrite()
847 } else if (nwritten > 0) { in redisBufferWrite()
848 if (nwritten == (signed)sdslen(c->obuf)) { in redisBufferWrite()
852 sdsrange(c->obuf,nwritten,-1); in redisBufferWrite()
/f-stack/freebsd/contrib/openzfs/include/os/linux/spl/sys/
H A Dkstat.h166 u_longlong_t nwritten; /* number of bytes written */ member
/f-stack/freebsd/contrib/openzfs/include/os/freebsd/spl/sys/
H A Dkstat.h170 u_longlong_t nwritten; /* number of bytes written */ member
/f-stack/freebsd/contrib/openzfs/lib/libspl/include/sys/
H A Dkstat.h592 u_longlong_t nwritten; /* number of bytes written */ member
/f-stack/app/redis-5.0.5/deps/linenoise/
H A Dlinenoise.c352 int nread, nwritten; in completeLine() local
395 nwritten = snprintf(ls->buf,ls->buflen,"%s",lc.cvec[i]); in completeLine()
396 ls->len = ls->pos = nwritten; in completeLine()
/f-stack/freebsd/contrib/openzfs/module/os/linux/zfs/
H A Dzvol_os.c152 int64_t nwritten = start_resid - uio.uio_resid; in zvol_write() local
153 dataset_kstats_update_write_kstats(&zv->zv_kstat, nwritten); in zvol_write()
154 task_io_account_write(nwritten); in zvol_write()
/f-stack/freebsd/contrib/openzfs/module/os/freebsd/spl/
H A Dspl_kstat.c155 kip->nread, kip->nwritten, in kstat_sysctl_io()
/f-stack/freebsd/contrib/openzfs/module/os/linux/spl/
H A Dspl-kstat.c267 kip->nread, kip->nwritten, in kstat_seq_show_io()
/f-stack/freebsd/kern/
H A Dvfs_bio.c3184 int nwritten; in vfs_bio_awrite() local
3220 nwritten = cluster_wbuild(vp, size, lblkno - j, ncl, in vfs_bio_awrite()
3222 return (nwritten); in vfs_bio_awrite()
3232 nwritten = bp->b_bufsize; in vfs_bio_awrite()
3235 return (nwritten); in vfs_bio_awrite()