diff options
Diffstat (limited to 'read.h')
-rw-r--r-- | read.h | 104 |
1 files changed, 52 insertions, 52 deletions
@@ -12,69 +12,69 @@ */ -#ifndef __HIREDIS_READ_H -#define __HIREDIS_READ_H +#ifndef __HIREDICT_READ_H +#define __HIREDICT_READ_H #include <stdio.h> /* for size_t */ -#define REDIS_ERR -1 -#define REDIS_OK 0 +#define REDICT_ERR -1 +#define REDICT_OK 0 /* When an error occurs, the err flag in a context is set to hold the type of - * error that occurred. REDIS_ERR_IO means there was an I/O error and you + * error that occurred. REDICT_ERR_IO means there was an I/O error and you * should use the "errno" variable to find out what is wrong. * For other values, the "errstr" field will hold a description. */ -#define REDIS_ERR_IO 1 /* Error in read or write */ -#define REDIS_ERR_EOF 3 /* End of file */ -#define REDIS_ERR_PROTOCOL 4 /* Protocol error */ -#define REDIS_ERR_OOM 5 /* Out of memory */ -#define REDIS_ERR_TIMEOUT 6 /* Timed out */ -#define REDIS_ERR_OTHER 2 /* Everything else... */ - -#define REDIS_REPLY_STRING 1 -#define REDIS_REPLY_ARRAY 2 -#define REDIS_REPLY_INTEGER 3 -#define REDIS_REPLY_NIL 4 -#define REDIS_REPLY_STATUS 5 -#define REDIS_REPLY_ERROR 6 -#define REDIS_REPLY_DOUBLE 7 -#define REDIS_REPLY_BOOL 8 -#define REDIS_REPLY_MAP 9 -#define REDIS_REPLY_SET 10 -#define REDIS_REPLY_ATTR 11 -#define REDIS_REPLY_PUSH 12 -#define REDIS_REPLY_BIGNUM 13 -#define REDIS_REPLY_VERB 14 +#define REDICT_ERR_IO 1 /* Error in read or write */ +#define REDICT_ERR_EOF 3 /* End of file */ +#define REDICT_ERR_PROTOCOL 4 /* Protocol error */ +#define REDICT_ERR_OOM 5 /* Out of memory */ +#define REDICT_ERR_TIMEOUT 6 /* Timed out */ +#define REDICT_ERR_OTHER 2 /* Everything else... */ + +#define REDICT_REPLY_STRING 1 +#define REDICT_REPLY_ARRAY 2 +#define REDICT_REPLY_INTEGER 3 +#define REDICT_REPLY_NIL 4 +#define REDICT_REPLY_STATUS 5 +#define REDICT_REPLY_ERROR 6 +#define REDICT_REPLY_DOUBLE 7 +#define REDICT_REPLY_BOOL 8 +#define REDICT_REPLY_MAP 9 +#define REDICT_REPLY_SET 10 +#define REDICT_REPLY_ATTR 11 +#define REDICT_REPLY_PUSH 12 +#define REDICT_REPLY_BIGNUM 13 +#define REDICT_REPLY_VERB 14 /* Default max unused reader buffer. */ -#define REDIS_READER_MAX_BUF (1024*16) +#define REDICT_READER_MAX_BUF (1024*16) /* Default multi-bulk element limit */ -#define REDIS_READER_MAX_ARRAY_ELEMENTS ((1LL<<32) - 1) +#define REDICT_READER_MAX_ARRAY_ELEMENTS ((1LL<<32) - 1) #ifdef __cplusplus extern "C" { #endif -typedef struct redisReadTask { +typedef struct redictReadTask { int type; long long elements; /* number of elements in multibulk container */ int idx; /* index in parent (array) object */ void *obj; /* holds user-generated value for a read task */ - struct redisReadTask *parent; /* parent task */ + struct redictReadTask *parent; /* parent task */ void *privdata; /* user-settable arbitrary field */ -} redisReadTask; - -typedef struct redisReplyObjectFunctions { - void *(*createString)(const redisReadTask*, char*, size_t); - void *(*createArray)(const redisReadTask*, size_t); - void *(*createInteger)(const redisReadTask*, long long); - void *(*createDouble)(const redisReadTask*, double, char*, size_t); - void *(*createNil)(const redisReadTask*); - void *(*createBool)(const redisReadTask*, int); +} redictReadTask; + +typedef struct redictReplyObjectFunctions { + void *(*createString)(const redictReadTask*, char*, size_t); + void *(*createArray)(const redictReadTask*, size_t); + void *(*createInteger)(const redictReadTask*, long long); + void *(*createDouble)(const redictReadTask*, double, char*, size_t); + void *(*createNil)(const redictReadTask*); + void *(*createBool)(const redictReadTask*, int); void (*freeObject)(void*); -} redisReplyObjectFunctions; +} redictReplyObjectFunctions; -typedef struct redisReader { +typedef struct redictReader { int err; /* Error flags, 0 when there is no error */ char errstr[128]; /* String representation of error when applicable */ @@ -84,25 +84,25 @@ typedef struct redisReader { size_t maxbuf; /* Max length of unused buffer */ long long maxelements; /* Max multi-bulk elements */ - redisReadTask **task; + redictReadTask **task; int tasks; int ridx; /* Index of current read task */ void *reply; /* Temporary reply pointer */ - redisReplyObjectFunctions *fn; + redictReplyObjectFunctions *fn; void *privdata; -} redisReader; +} redictReader; /* Public API for the protocol parser. */ -redisReader *redisReaderCreateWithFunctions(redisReplyObjectFunctions *fn); -void redisReaderFree(redisReader *r); -int redisReaderFeed(redisReader *r, const char *buf, size_t len); -int redisReaderGetReply(redisReader *r, void **reply); - -#define redisReaderSetPrivdata(_r, _p) (int)(((redisReader*)(_r))->privdata = (_p)) -#define redisReaderGetObject(_r) (((redisReader*)(_r))->reply) -#define redisReaderGetError(_r) (((redisReader*)(_r))->errstr) +redictReader *redictReaderCreateWithFunctions(redictReplyObjectFunctions *fn); +void redictReaderFree(redictReader *r); +int redictReaderFeed(redictReader *r, const char *buf, size_t len); +int redictReaderGetReply(redictReader *r, void **reply); + +#define redictReaderSetPrivdata(_r, _p) (int)(((redictReader*)(_r))->privdata = (_p)) +#define redictReaderGetObject(_r) (((redictReader*)(_r))->reply) +#define redictReaderGetError(_r) (((redictReader*)(_r))->errstr) #ifdef __cplusplus } |