62     r->io.buffer.ptr = sdscatlen(r->io.buffer.ptr,(char*)buf,len);  in rioBufferWrite()
63     r->io.buffer.pos += len;  in rioBufferWrite()
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()
78     return r->io.buffer.pos;  in rioBufferTell()
102     r->io.buffer.ptr = s;  in rioInitWithBuffer()
103     r->io.buffer.pos = 0;  in rioInitWithBuffer()
112     retval = fwrite(buf,len,1,r->io.file.fp);  in rioFileWrite()
113     r->io.file.buffered += len;  in rioFileWrite()
115     if (r->io.file.autosync &&  in rioFileWrite()
116         r->io.file.buffered >= r->io.file.autosync)  in rioFileWrite()
118         fflush(r->io.file.fp);  in rioFileWrite()
119         aof_fsync(fileno(r->io.file.fp));  in rioFileWrite()
120         r->io.file.buffered = 0;  in rioFileWrite()
127     return fread(buf,len,1,r->io.file.fp);  in rioFileRead()
132     return ftello(r->io.file.fp);  in rioFileTell()
138     return (fflush(r->io.file.fp) == 0) ? 1 : 0;  in rioFileFlush()
155     r->io.file.fp = fp;  in rioInitWithFile()
156     r->io.file.buffered = 0;  in rioInitWithFile()
157     r->io.file.autosync = 0;  in rioInitWithFile()
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()
194         for (j = 0; j < r->io.fdset.numfds; j++) {  in rioFdsetWrite()
195             if (r->io.fdset.state[j] != 0) {  in rioFdsetWrite()
205                 retval = write(r->io.fdset.fds[j],p+nwritten,count-nwritten);  in rioFdsetWrite()
219                 r->io.fdset.state[j] = errno;  in rioFdsetWrite()
220                 if (r->io.fdset.state[j] == 0) r->io.fdset.state[j] = EIO;  in rioFdsetWrite()
223         if (broken == r->io.fdset.numfds) return 0; /* All the FDs in error. */  in rioFdsetWrite()
226         r->io.fdset.pos += count;  in rioFdsetWrite()
229     if (doflush) sdsclear(r->io.fdset.buf);  in rioFdsetWrite()
243     return r->io.fdset.pos;  in rioFdsetTell()
270     r->io.fdset.fds = zmalloc(sizeof(int)*numfds);  in rioInitWithFdset()
271     r->io.fdset.state = zmalloc(sizeof(int)*numfds);  in rioInitWithFdset()
272     memcpy(r->io.fdset.fds,fds,sizeof(int)*numfds);  in rioInitWithFdset()
273     for (j = 0; j < numfds; j++) r->io.fdset.state[j] = 0;  in rioInitWithFdset()
274     r->io.fdset.numfds = numfds;  in rioInitWithFdset()
275     r->io.fdset.pos = 0;  in rioInitWithFdset()
276     r->io.fdset.buf = sdsempty();  in rioInitWithFdset()
281     zfree(r->io.fdset.fds);  in rioFreeFdset()
282     zfree(r->io.fdset.state);  in rioFreeFdset()
283     sdsfree(r->io.fdset.buf);  in rioFreeFdset()
304     r->io.file.autosync = bytes;  in rioSetAutoSync()