--- libaitio/inc/aitio.h 2012/08/01 00:37:07 1.23 +++ libaitio/inc/aitio.h 2012/08/29 13:30:28 1.24.2.4 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: aitio.h,v 1.23 2012/08/01 00:37:07 misho Exp $ +* $Id: aitio.h,v 1.24.2.4 2012/08/29 13:30:28 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -50,12 +50,14 @@ SUCH DAMAGE. #define COMPAT_43TTY #include +#include #include #include #include #include #include #include +#include #include #include #include @@ -168,6 +170,8 @@ typedef struct { #define AIT_GET_DATA(_vl) (assert(AIT_TYPE((_vl)) == data), (_vl)->val_data) #define AIT_GET_BUF(_vl) (assert(AIT_TYPE((_vl)) == buffer), (_vl)->val.buffer) #define AIT_GET_STR(_vl) (assert(AIT_TYPE((_vl)) == string), (char*) (_vl)->val.string) +#define AIT_GET_STRZ(_vl) (assert(AIT_TYPE((_vl)) == string), (_vl)->val.string ? \ + (char*) (_vl)->val.string : "") #define AIT_GET_BLOB(_vl) (assert(AIT_TYPE((_vl)) == blob), (_vl)->val.blob) #define AIT_GET_U8(_vl) (assert(AIT_TYPE((_vl)) == u8), (_vl)->val.u8) #define AIT_GET_U16(_vl) (assert(AIT_TYPE((_vl)) == u16), (_vl)->val.u16) @@ -214,7 +218,7 @@ typedef struct { } } while (0) #define AIT_SET_STR(_vl, _v) do { ait_val_t *__val = (_vl); const char *__s = (_v); assert(__val); \ __val->val_type = string; \ - if (__s && *__s) { \ + if (__s) { \ __val->val.string = (int8_t*) io_strdup(__s); \ AIT_LEN(__val) = strlen((const char*) \ __val->val.string) + 1; \ @@ -310,16 +314,16 @@ typedef struct { __val->val_type = f64; __val->val.f64 = _n; \ AIT_LEN(__val) = sizeof(double); } while (0) -#define AIT_COPY_VAL(_vl, _v) do { ait_val_t *__val = (_vl); assert(__val); assert((_v)); \ - memcpy(__val, (_v), sizeof(ait_val_t)); \ - switch (AIT_TYPE(__val)) { \ +#define AIT_COPY_VAL(_vl, _v) do { assert((_vl)); assert((_v)); \ + memcpy((_vl), (_v), sizeof(ait_val_t)); \ + switch (AIT_TYPE((_vl))) { \ case buffer: \ - AIT_SET_BUF(__val, \ + AIT_SET_BUF((_vl), \ AIT_GET_BUF((_v)), \ AIT_LEN((_v))); \ break; \ case string: \ - AIT_SET_STR(__val, \ + AIT_SET_STR((_vl), \ AIT_GET_STR((_v))); \ break; \ default: \ @@ -337,6 +341,11 @@ typedef struct { AIT_INIT_VAL((_vl)); \ (_vl)->val_type = _t; \ } while (0) +#define AIT_SET_LIKE(_vl, _t, _l, _v) do { assert((_vl)); \ + AIT_INIT_VAL2((_vl), _t); \ + AIT_LEN((_vl)) = _l; AIT_IN((_vl)) = 1; \ + AIT_RAW((_vl)) = (uint64_t) (_v); \ + } while (0) /* if attribute zeroCopy is set not execute io_free() */ #define AIT_FREE_VAL(_vl) do { ait_val_t *__val = (_vl); assert(__val); \ switch (AIT_TYPE(__val)) { \ @@ -538,6 +547,13 @@ inline void io_freeVar(ait_val_t ** __restrict val); */ ait_val_t *io_makeVar(ait_type_t type, ...); /* + * io_hashVar() - Generate hash key for variable + * + * @v = variable + * return: hash key + */ +unsigned short io_hashVar(ait_val_t * __restrict v); +/* * io_allocVars() - Allocate ait_val_t array * * @varnum = Number of variables @@ -592,6 +608,21 @@ inline void io_sortVarsByVal(array_t * __restrict vars * return: NULL error or not found, !=NULL valid element */ ait_val_t *io_findKeyVars(array_t * __restrict vars, u_short key); +/* + * io_findKeyHash() - Find variable by hash string from array + * + * @vars = Variables + * @key = Search string + * return: NULL error or not found, !=NULL valid element + */ +inline ait_val_t *io_findKeyHash(array_t * __restrict vars, const char * __restrict key); +/* + * io_hashKeyVars() - Generate hash keys for variables + * + * @vars = Variables + * return -1 error or 0 ok + */ +inline int io_hashKeyVars(array_t * __restrict vars); /* @@ -1016,7 +1047,44 @@ int ioMkDir(const char *csDir, int mode); int ioWatchDirLoop(const char *csDir, int (*callback)(const char *csName, int nOp)); +#ifdef AIO_OPS /* + * io_aiobulk() - AIO bulk R/W function + * + * @mode = Bulk wait mode + * @acbs = List of aiocb structures + * @nacb = Number of aiocb in list + * @sig = Event for completed operations, may be =NULL + * return: -1 error or 0 ok + */ +inline int io_aiobulk(int mode, struct aiocb ** __restrict acbs, int nacb, + struct sigevent *sig); +#endif +/* + * io_rreadv() - Raw VFS bulk read function + * + * @fd = File handle + * @bufs = Read buffers + * @nbufs = Number of read buffers + * @offset = Read from position, if -1 read nbytes from current position + * @update = Update file handle position !0 + * return: -1 error or !=-1 readed bytes + */ +int io_rreadv(int fd, struct iovec * __restrict bufs, int nbufs, off_t offset, + int update); +/* + * io_rwritev() - Raw VFS bulk write function + * + * @fd = File handle + * @bufs = Write buffers + * @nbufs = Number of write buffers + * @offset = Write to position, if -1 write nbytes to current position + * @update = Update file handle position !0 + * return: -1 error or !=-1 written bytes + */ +int io_rwritev(int fd, struct iovec * __restrict bufs, int nbufs, off_t offset, + int update); +/* * io_rread() - Raw VFS read function * * @fd = File handle @@ -1026,7 +1094,8 @@ int ioWatchDirLoop(const char *csDir, int (*callback)( * @update = Update file handle position !0 * return: -1 error or !=-1 readed bytes */ -inline int io_rread(int fd, void * __restrict buf, size_t nbytes, off_t offset, int update); +inline int io_rread(int fd, void * __restrict buf, size_t nbytes, off_t offset, + int update); /* * io_rwrite() - Raw VFS write function * @@ -1035,9 +1104,10 @@ inline int io_rread(int fd, void * __restrict buf, siz * @nbytes = Write bytes from buffer * @offset = Write at position, if -1 write nbytes from current position * @update = Update file handle position !0 - * return: -1 error or !=-1 writed bytes + * return: -1 error or !=-1 written bytes */ -inline int io_rwrite(int fd, void * __restrict buf, size_t nbytes, off_t offset, int update); +inline int io_rwrite(int fd, void * __restrict buf, size_t nbytes, off_t offset, + int update); /* Disk I/O helper macros */ #define io_read(f, b, n) io_rread(f, b, n, -1, 1)