Lines Matching refs:buf

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()
68 static size_t rioBufferRead(rio *r, void *buf, size_t len) { in rioBufferRead() argument
71 memcpy(buf,r->io.buffer.ptr+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()
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
172 unsigned char *p = (unsigned char*) buf; in rioFdsetWrite()
173 int doflush = (buf == NULL && len == 0); in rioFdsetWrite()
178 r->io.fdset.buf = sdscatlen(r->io.fdset.buf,buf,len); in rioFdsetWrite()
180 if (sdslen(r->io.fdset.buf) > PROTO_IOBUF_LEN) doflush = 1; in rioFdsetWrite()
184 p = (unsigned char*) r->io.fdset.buf; in rioFdsetWrite()
185 len = sdslen(r->io.fdset.buf); in rioFdsetWrite()
229 if (doflush) sdsclear(r->io.fdset.buf); in rioFdsetWrite()
234 static size_t rioFdsetRead(rio *r, void *buf, size_t len) { in rioFdsetRead() argument
236 UNUSED(buf); in rioFdsetRead()
276 r->io.fdset.buf = sdsempty(); in rioInitWithFdset()
283 sdsfree(r->io.fdset.buf); in rioFreeFdset()
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
330 if (len > 0 && rioWrite(r,buf,len) == 0) return 0; in rioWriteBulkString()