Lines Matching refs:len
61 static size_t rioBufferWrite(rio *r, const void *buf, size_t len) { in rioBufferWrite() argument
62 r->io.buffer.ptr = sdscatlen(r->io.buffer.ptr,(char*)buf,len); in rioBufferWrite()
63 r->io.buffer.pos += len; in rioBufferWrite()
68 static size_t rioBufferRead(rio *r, void *buf, size_t len) { in rioBufferRead() argument
69 if (sdslen(r->io.buffer.ptr)-r->io.buffer.pos < len) in rioBufferRead()
71 memcpy(buf,r->io.buffer.ptr+r->io.buffer.pos,len); in rioBufferRead()
72 r->io.buffer.pos += len; in rioBufferRead()
109 static size_t rioFileWrite(rio *r, const void *buf, size_t len) { in rioFileWrite() argument
112 retval = fwrite(buf,len,1,r->io.file.fp); in rioFileWrite()
113 r->io.file.buffered += len; in rioFileWrite()
126 static size_t rioFileRead(rio *r, void *buf, size_t len) { in rioFileRead() argument
127 return fread(buf,len,1,r->io.file.fp); in rioFileRead()
169 static size_t rioFdsetWrite(rio *r, const void *buf, size_t len) { in rioFdsetWrite() argument
173 int doflush = (buf == NULL && len == 0); in rioFdsetWrite()
177 if (len) { in rioFdsetWrite()
178 r->io.fdset.buf = sdscatlen(r->io.fdset.buf,buf,len); in rioFdsetWrite()
179 len = 0; /* Prevent entering the while below if we don't flush. */ in rioFdsetWrite()
185 len = sdslen(r->io.fdset.buf); in rioFdsetWrite()
191 while(len) { in rioFdsetWrite()
192 size_t count = len < 1024 ? len : 1024; in rioFdsetWrite()
225 len -= count; in rioFdsetWrite()
234 static size_t rioFdsetRead(rio *r, void *buf, size_t len) { in rioFdsetRead() argument
237 UNUSED(len); in rioFdsetRead()
290 void rioGenericUpdateChecksum(rio *r, const void *buf, size_t len) { in rioGenericUpdateChecksum() argument
291 r->cksum = crc64(r->cksum,buf,len); in rioGenericUpdateChecksum()
326 size_t rioWriteBulkString(rio *r, const char *buf, size_t len) { in rioWriteBulkString() argument
329 if ((nwritten = rioWriteBulkCount(r,'$',len)) == 0) return 0; in rioWriteBulkString()
330 if (len > 0 && rioWrite(r,buf,len) == 0) return 0; in rioWriteBulkString()
332 return nwritten+len+2; in rioWriteBulkString()