version 1.13.2.5, 2011/12/14 15:00:24
|
version 1.14.2.3, 2012/03/10 15:02:47
|
Line 78 typedef struct _tagArray {
|
Line 78 typedef struct _tagArray {
|
void **arr_data; |
void **arr_data; |
} array_t; |
} array_t; |
|
|
/* URL staff ... */ |
|
|
|
typedef struct _tagURLItem { |
|
int vallen; |
|
char *value; |
|
} url_Item_t; |
|
|
|
struct tagIOURL { |
|
unsigned char url_line[BUFSIZ]; |
|
|
|
url_Item_t url_tech; |
|
url_Item_t url_user; |
|
url_Item_t url_pass; |
|
url_Item_t url_host; |
|
url_Item_t url_port; |
|
url_Item_t url_path; |
|
url_Item_t url_args; |
|
|
|
char *url_reserved; |
|
}; |
|
|
|
struct tagReqXML { |
|
unsigned char xml_line[BUFSIZ]; |
|
|
|
url_Item_t xml_namespace; |
|
union { |
|
url_Item_t container; |
|
url_Item_t path; |
|
} xml_node; |
|
url_Item_t xml_data; |
|
url_Item_t xml_attribute; |
|
url_Item_t xml_value; |
|
}; |
|
|
|
/* AIT RPC variables and managment */ |
/* AIT RPC variables and managment */ |
|
|
typedef enum { |
typedef enum { |
empty, /* empty -> variable is not set */ | empty, ptr, /* empty -> variable is not set; ptr -> void* */ |
buffer, string, blob, /* buffer -> uint8_t*; string -> int8_t*; blob -> void*(+socket); */ | buffer, string, blob, /* buffer -> uint8_t*; string -> int8_t*; blob -> uint32_t blobID(+socket); */ |
f32, f64, /* float -> f32; double -> f64 */ |
f32, f64, /* float -> f32; double -> f64 */ |
u8, u16, u32, u64, /* unsigned integers ... */ |
u8, u16, u32, u64, /* unsigned integers ... */ |
i8, i16, i32, i64, /* integers ... */ |
i8, i16, i32, i64, /* integers ... */ |
Line 129 typedef struct {
|
Line 95 typedef struct {
|
union { |
union { |
uint64_t net; |
uint64_t net; |
|
|
|
void *ptr; |
uint8_t *buffer; |
uint8_t *buffer; |
int8_t *string; |
int8_t *string; |
uint32_t blob; |
uint32_t blob; |
Line 147 typedef struct {
|
Line 114 typedef struct {
|
|
|
#define AIT_TYPE(_vl) ((ait_type_t) (_vl)->val_type) |
#define AIT_TYPE(_vl) ((ait_type_t) (_vl)->val_type) |
#define AIT_LEN(_vl) (_vl)->val_len |
#define AIT_LEN(_vl) (_vl)->val_len |
|
#define AIT_RAW(_vl) (_vl)->val.net |
#define AIT_BLOB_CHUNKS(_vl, _n) (assert((_vl)), AIT_LEN((_vl)) / _n + (AIT_LEN((_vl)) % _n) ? 1 : 0) |
#define AIT_BLOB_CHUNKS(_vl, _n) (assert((_vl)), AIT_LEN((_vl)) / _n + (AIT_LEN((_vl)) % _n) ? 1 : 0) |
#define AIT_ISEMPTY(_vl) (assert((_vl)), AIT_TYPE((_vl)) == empty) |
#define AIT_ISEMPTY(_vl) (assert((_vl)), AIT_TYPE((_vl)) == empty) |
|
|
|
#define AIT_GET_LIKE(_vl, _type) (assert((_vl)), (_type) (_vl)->val.net) |
|
|
|
#define AIT_GET_PTR(_vl) (assert((_vl)), assert(AIT_TYPE((_vl)) == ptr), (_vl)->val.ptr) |
|
#define AIT_GET_PTR2(_vl) (assert((_vl)), (_vl)->val.ptr) |
#define AIT_GET_BUF(_vl) (assert((_vl)), assert(AIT_TYPE((_vl)) == buffer), (_vl)->val.buffer) |
#define AIT_GET_BUF(_vl) (assert((_vl)), assert(AIT_TYPE((_vl)) == buffer), (_vl)->val.buffer) |
#define AIT_GET_STR(_vl) (assert((_vl)), assert(AIT_TYPE((_vl)) == string), (_vl)->val.string) |
#define AIT_GET_STR(_vl) (assert((_vl)), assert(AIT_TYPE((_vl)) == string), (_vl)->val.string) |
#define AIT_GET_BLOB(_vl) (assert((_vl)), assert(AIT_TYPE((_vl)) == blob), (_vl)->val.blob) |
#define AIT_GET_BLOB(_vl) (assert((_vl)), assert(AIT_TYPE((_vl)) == blob), (_vl)->val.blob) |
Line 164 typedef struct {
|
Line 136 typedef struct {
|
#define AIT_GET_F32(_vl) (assert((_vl)), assert(AIT_TYPE((_vl)) == f32), (_vl)->val.f32) |
#define AIT_GET_F32(_vl) (assert((_vl)), assert(AIT_TYPE((_vl)) == f32), (_vl)->val.f32) |
#define AIT_GET_F64(_vl) (assert((_vl)), assert(AIT_TYPE((_vl)) == f64), (_vl)->val.f64) |
#define AIT_GET_F64(_vl) (assert((_vl)), assert(AIT_TYPE((_vl)) == f64), (_vl)->val.f64) |
|
|
#define AIT_SET_BUF(_vl, _v, _len) do { ait_val_t *__val = (_vl); assert(__val); assert((_v)); \ | #define AIT_SET_PTR(_vl, _p, _len) do { ait_val_t *__val = (_vl); assert(__val); \ |
| __val->val_type = ptr; AIT_LEN(__val) = _len; \ |
| __val->val.ptr = _p; } while (0) |
| #define AIT_SET_BUF(_vl, _v, _len) do { ait_val_t *__val = (_vl); assert(__val); \ |
__val->val.buffer = malloc(_len); \ |
__val->val.buffer = malloc(_len); \ |
if (__val->val.buffer) { \ |
if (__val->val.buffer) { \ |
__val->val_type = buffer; AIT_LEN(__val) = _len; \ |
__val->val_type = buffer; AIT_LEN(__val) = _len; \ |
memcpy(__val->val.buffer, (_v), _len); \ |
memcpy(__val->val.buffer, (_v), _len); \ |
} } while (0) |
} } while (0) |
#define AIT_SET_STR(_vl, _v) do { ait_val_t *__val = (_vl); assert(__val); assert((_v)); \ | #define AIT_SET_STR(_vl, _v) do { ait_val_t *__val = (_vl); assert(__val); \ |
__val->val.string = (int8_t*) strdup((_v)); \ |
__val->val.string = (int8_t*) strdup((_v)); \ |
if (__val->val.string) { \ |
if (__val->val.string) { \ |
__val->val_type = string; \ |
__val->val_type = string; \ |
AIT_LEN(__val) = strlen((_v)) + 1; \ |
AIT_LEN(__val) = strlen((_v)) + 1; \ |
} } while (0) |
} } while (0) |
|
#define AIT_SET_STRCAT(_vl, _v) do { ait_val_t *__val = (_vl); assert(__val); \ |
|
assert(AIT_TYPE(__val) == string); \ |
|
void *__p = realloc(AIT_LEN(__val) + strlen((_v))); \ |
|
if (__p) { \ |
|
__val->val.string = __p; \ |
|
AIT_LEN(__val) += strlen((_v)); \ |
|
strlcat(__val->val.string, (_v), AIT_LEN(__val)); \ |
|
} } while (0) |
#define AIT_SET_BLOB(_vl, _n, _len) do { ait_val_t *__val = (_vl); assert(__val); \ |
#define AIT_SET_BLOB(_vl, _n, _len) do { ait_val_t *__val = (_vl); assert(__val); \ |
__val->val_type = blob; AIT_LEN(__val) = _len; \ |
__val->val_type = blob; AIT_LEN(__val) = _len; \ |
__val->val.blob = _n; } while (0) |
__val->val.blob = _n; } while (0) |
Line 216 typedef struct {
|
Line 199 typedef struct {
|
AIT_LEN(__val) = sizeof(double); } while (0) |
AIT_LEN(__val) = sizeof(double); } while (0) |
|
|
/* if attribute zeroCopy is set not execute free() */ |
/* if attribute zeroCopy is set not execute free() */ |
#define AIT_FREE_VAL(_vl) do { ait_val_t *__val = (_vl); assert(__val); \ | #define AIT_FREE_VAL(_vl) do { ait_val_t *__val = (ait_val_t*) (_vl); assert(__val); \ |
switch (__val->val_type) { \ |
switch (__val->val_type) { \ |
case buffer: \ |
case buffer: \ |
if (__val->val.buffer) { \ |
if (__val->val.buffer) { \ |
Line 419 char *ioRegexReplace(const char *csRegex, const char *
|
Line 402 char *ioRegexReplace(const char *csRegex, const char *
|
char *ioStrAst(const char *csString); |
char *ioStrAst(const char *csString); |
|
|
/* |
/* |
* io_Path2File() Parse and make path/filename pair |
|
* @csArgs = Input argument line |
|
* @psPath = Output Path, if ==NULL path not returned |
|
* @pathLen = Size of path array |
|
* @psFile = Output File |
|
* @fileLen = Size of file array |
|
* return: 0 error format; -1 error:: can`t read; >0 ok, number of readed items |
|
*/ |
|
inline int io_Path2File(const char * __restrict csArgs, char * __restrict psPath, int pathLen, |
|
char * __restrict psFile, int fileLen); |
|
|
|
/* |
|
* io_UnquotStr() Remove quots from input text string |
* io_UnquotStr() Remove quots from input text string |
* @psLine = Text string |
* @psLine = Text string |
* return: 0 nothing to do; 1 successful unquoted string |
* return: 0 nothing to do; 1 successful unquoted string |
Line 709 char **io_ExecArgs(const char *psProg, const char **ol
|
Line 680 char **io_ExecArgs(const char *psProg, const char **ol
|
inline void io_FreeNullTerm(char *** __restrict arr); |
inline void io_FreeNullTerm(char *** __restrict arr); |
|
|
/* |
/* |
* ioURLGet() Parse and get data from input URL |
|
* @csURL = Input URL line |
|
* @url = Output parsed URL |
|
* return: 0 error format not find tech:// and return URL like path; |
|
-1 error:: can`t read; >0 ok, up bits for known elements |
|
*/ |
|
int ioURLGet(const char *csURL, struct tagIOURL *url); |
|
/* |
|
* ioURLGetValue() Get value from parsed URL |
|
* @url = Input parsed URL |
|
* @csAttr = Attribute for search |
|
* @psValue = Return value of attribute, if ==NULL only check for existence of attribute |
|
* @valLen = Size of psValue array |
|
* return: 0 error attribute not find; -1 error:: can`t read; >0 ok, find at position |
|
*/ |
|
int ioURLGetValue(struct tagIOURL *url, const char *csAttr, char * __restrict psValue, int valLen); |
|
/* |
|
* ioURLGetFile() Get file from parsed URL |
|
* @url = Input parsed URL |
|
* @psValue = Return filename, if not specified file in url path, replace with / |
|
* @valLen = Size of psValue array |
|
* return: -1 error:: can`t read; 0 ok |
|
*/ |
|
int ioURLGetFile(struct tagIOURL *url, char * __restrict psValue, int valLen); |
|
|
|
|
|
/* |
|
* ioXMLGet() Parse and get data from input XML request string [ns:]container[|attribute[=value]][?data] |
|
* @csXML = Input XML request line |
|
* @xml = Output parsed XML request |
|
* return: 0 error format incorrect, -1 error:: can`t read; >0 ok readed elements bits |
|
*/ |
|
int ioXMLGet(const char *csXML, struct tagReqXML *xml); |
|
|
|
|
|
/* |
|
* ioMkDir() Function for racursive directory creation and validation |
* ioMkDir() Function for racursive directory creation and validation |
* @csDir = Full directory path |
* @csDir = Full directory path |
* @mode = Mode for directory creation if missing dir |
* @mode = Mode for directory creation if missing dir |
Line 825 extern int io_Debug;
|
Line 760 extern int io_Debug;
|
syslog(LOG_ERR, "Error:%s(%d): #%d - %s\n", \ |
syslog(LOG_ERR, "Error:%s(%d): #%d - %s\n", \ |
__func__, __LINE__, (x), str); \ |
__func__, __LINE__, (x), str); \ |
} while (0) |
} while (0) |
#define ioLOGERR(x) do { \ | #define ioSYSERR(x) do { \ |
if (x > 0 || errno) \ |
if (x > 0 || errno) \ |
syslog(LOG_ERR, "Error(sys):%s(%d): #%d - %s\n", \ |
syslog(LOG_ERR, "Error(sys):%s(%d): #%d - %s\n", \ |
__func__, __LINE__, x > 0 ? x : errno, \ |
__func__, __LINE__, x > 0 ? x : errno, \ |
Line 980 size_t ioSendFile(int s, const char *csFile, size_t se
|
Line 915 size_t ioSendFile(int s, const char *csFile, size_t se
|
* return: 0 error, >0 ok, received bytes |
* return: 0 error, >0 ok, received bytes |
*/ |
*/ |
size_t ioRecvFile(int s, const char *csFile, size_t recvLen, int over, int rcvbuf); |
size_t ioRecvFile(int s, const char *csFile, size_t recvLen, int over, int rcvbuf); |
|
|
|
|
|
/* Buffered file access over memory block */ |
|
|
|
/* |
|
* io_fmemopen() File buffered stream operations over memory block |
|
* |
|
* @base = Base address of memory block, if =NULL Infinit length(auto-grow) |
|
* @basesize = Size of memory block |
|
* return: NULL error or !=NULL Opened file resource |
|
*/ |
|
FILE *io_fmemopen(void ** __restrict base, off_t basesize); |
|
/* |
|
* io_fmapopen() File buffered stream operations over MMAP block |
|
* |
|
* @csFile = Filename for MMAP, if =NULL private MMAP block |
|
* @mode = File open mode |
|
* @perm = If file not exists will be created with this access permissions |
|
* @prot = MMAP protection |
|
* @flags = MMAP mode flags |
|
* @offset = Map from file offset, if csFile==NULL then this is size of MMAP private block |
|
* return: NULL error or !=NULL Opened file resource |
|
*/ |
|
FILE *io_fmapopen(const char *csFile, int mode, int perm, int prot, int flags, off_t offset); |
|
/* |
|
* io_fd2buf() Convert open file handle to buffered file I/O |
|
* |
|
* @fd = File handle |
|
* @mode = Permissions for new buffered file I/O |
|
* return: NULL error or open buffered file |
|
*/ |
|
inline FILE *io_fd2buf(int fd, const char *mode); |
|
/* |
|
* io_dumbFile() Create empry or dumb file with fixed size |
|
* |
|
* @csFile = Filename for create |
|
* @mode = File access permissions |
|
* @size = File size |
|
* return: -1 error or open file handle |
|
*/ |
|
int io_dumbFile(const char *csFile, int mode, off_t size); |
|
|
|
|
#endif |
#endif |