gvsafronov/futriix
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

rio.c refactoring before adding a new target.

Browse Source
This commit is contained in:
antirez 2014-10-10 16:33:16 +02:00
parent 16546f5aca
commit 29db3227ab
1 changed files with 24 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

41
src/rio.c
View File

@ -55,6 +55,8 @@
#include "config.h" #include "config.h"
#include "redis.h" #include "redis.h"
/* ------------------------- Buffer I/O implementation ----------------------- */
/* Returns 1 or 0 for success/failure. */ /* Returns 1 or 0 for success/failure. */
static size_t rioBufferWrite(rio *r, const void *buf, size_t len) { static size_t rioBufferWrite(rio *r, const void *buf, size_t len) {
r->io.buffer.ptr = sdscatlen(r->io.buffer.ptr,(char*)buf,len); r->io.buffer.ptr = sdscatlen(r->io.buffer.ptr,(char*)buf,len);
@ -76,6 +78,25 @@ static off_t rioBufferTell(rio *r) {
return r->io.buffer.pos; return r->io.buffer.pos;
} }
static const rio rioBufferIO = {
rioBufferRead,
rioBufferWrite,
rioBufferTell,
NULL, /* update_checksum */
0, /* current checksum */
0, /* bytes read or written */
0, /* read/write chunk size */
{ { NULL, 0 } } /* union for io-specific vars */
};
void rioInitWithBuffer(rio *r, sds s) {
*r = rioBufferIO;
r->io.buffer.ptr = s;
r->io.buffer.pos = 0;
}
/* --------------------- Stdio file pointer implementation ------------------- */
/* Returns 1 or 0 for success/failure. */ /* Returns 1 or 0 for success/failure. */
static size_t rioFileWrite(rio *r, const void *buf, size_t len) { static size_t rioFileWrite(rio *r, const void *buf, size_t len) {
size_t retval; size_t retval;
@ -103,17 +124,6 @@ static off_t rioFileTell(rio *r) {
return ftello(r->io.file.fp); return ftello(r->io.file.fp);
} }
static const rio rioBufferIO = {
rioBufferRead,
rioBufferWrite,
rioBufferTell,
NULL, /* update_checksum */
0, /* current checksum */
0, /* bytes read or written */
0, /* read/write chunk size */
{ { NULL, 0 } } /* union for io-specific vars */
};
static const rio rioFileIO = { static const rio rioFileIO = {
rioFileRead, rioFileRead,
rioFileWrite, rioFileWrite,
@ -132,11 +142,7 @@ void rioInitWithFile(rio *r, FILE *fp) {
r->io.file.autosync = 0; r->io.file.autosync = 0;
} }
void rioInitWithBuffer(rio *r, sds s) { /* ---------------------------- Generic functions ---------------------------- */
*r = rioBufferIO;
r->io.buffer.ptr = s;
r->io.buffer.pos = 0;
}
/* This function can be installed both in memory and file streams when checksum /* This function can be installed both in memory and file streams when checksum
* computation is needed. */ * computation is needed. */
@ -157,7 +163,8 @@ void rioSetAutoSync(rio *r, off_t bytes) {
r->io.file.autosync = bytes; r->io.file.autosync = bytes;
} }
/* ------------------------------ Higher level interface --------------------------- /* --------------------------- Higher level interface --------------------------
*
* The following higher level functions use lower level rio.c functions to help * The following higher level functions use lower level rio.c functions to help
* generating the Redis protocol for the Append Only File. */ * generating the Redis protocol for the Append Only File. */