libaitio/inc/aitio.h - diff

Return to aitio.h CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitio / inc

Diff for /libaitio/inc/aitio.h between versions 1.13 and 1.15

version 1.13, 2011/12/13 02:23:07	version 1.15, 2012/03/15 01:52:22
Line 12 terms:	Line 12 terms:
All of the documentation and software included in the ELWIX and AITNET	All of the documentation and software included in the ELWIX and AITNET
Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org>	Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org>

Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011	Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012
by Michael Pounov <misho@elwix.org>. All rights reserved.	by Michael Pounov <misho@elwix.org>. All rights reserved.

Redistribution and use in source and binary forms, with or without	Redistribution and use in source and binary forms, with or without
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_VOID(_vl) (_vl)->val.ptr
#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.ptr)

	#define AIT_GET_PTR(_vl) (assert((_vl)), assert(AIT_TYPE((_vl)) == ptr), (_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 252 typedef union {	Line 235 typedef union {
} io_sockaddr_t;	} io_sockaddr_t;


	#define io_align(x, a) (((x) + (a)) & ~(a))


// io_GetErrno() Get error code of last operation	// io_GetErrno() Get error code of last operation
inline int io_GetErrno();	inline int io_GetErrno();
// io_GetError() Get error text of last operation	// io_GetError() Get error text of last operation
Line 334 int io_vars2map(unsigned char *buf, int buflen, array_	Line 320 int io_vars2map(unsigned char *buf, int buflen, array_
array_t io_map2vars(unsigned char buf, int buflen, int vnum, int zcpy);	array_t io_map2vars(unsigned char buf, int buflen, int vnum, int zcpy);

/*	/*
	* io_allocVar() Allocate memory for variable
	* return: NULL error or new variable, after use free variable with io_freeVar()
	*/
	inline ait_val_t *io_allocVar(void);
	/*
	* io_freeVar() Free allocated memory for variable
	* @val = Variable
	* return: none
	*/
	inline void io_freeVar(ait_val_t * __restrict val);
	/*
* io_allocVars() Allocate ait_val_t array	* io_allocVars() Allocate ait_val_t array
* @varnum = Number of variables	* @varnum = Number of variables
* return: =NULL error or !=NULL allocated array	* return: =NULL error or !=NULL allocated array
Line 352 inline int io_clrVars(array_t * __restrict vars);	Line 349 inline int io_clrVars(array_t * __restrict vars);
*/	*/
inline void io_freeVars(array_t ** __restrict vars);	inline void io_freeVars(array_t ** __restrict vars);

#define io_elemVars(_vars, _n, _val) ((ait_val_t*) io_arrayElem((_vars), \
(_n), (void**) (_val)))

/*	/*
* ioPromptRead() Read data from input h[0] with prompt to output h[1]	* ioPromptRead() Read data from input h[0] with prompt to output h[1]
Line 410 char ioRegexReplace(const char csRegex, const char *	Line 405 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 461 inline unsigned char io_Ch2Hex(unsigned char psLine,	Line 444 inline unsigned char io_Ch2Hex(unsigned char psLine,
inline char io_Hex2Ch(unsigned char psLine, int lineLen);	inline char io_Hex2Ch(unsigned char psLine, int lineLen);

/*	/*
	* 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_arrayInit() - Create and initialize dynamic array	* io_arrayInit() - Create and initialize dynamic array
* @numItems = Number of Items	* @numItems = Number of Items
* return: NULL error, != NULL allocated memory for array	* return: NULL error, != NULL allocated memory for array
Line 553 int io_arrayVacuum(array_t * __restrict arr, int fromW	Line 550 int io_arrayVacuum(array_t * __restrict arr, int fromW
* @data = Element, if set NULL GET element at position or !=NULL PUT element at position	* @data = Element, if set NULL GET element at position or !=NULL PUT element at position
* return: -1 error or !=-1 return element at position	* return: -1 error or !=-1 return element at position
*/	*/
inline void io_arrayElem(array_t __restrict arr, int n, void **data);	inline void io_arrayElem(array_t __restrict arr, int n, void *data);
/*	/*
* io_arrayPush() - Push element into dynamic array like stack manner, place at first empty position	* io_arrayPush() - Push element into dynamic array like stack manner, place at first empty position
* @arr = Array	* @arr = Array
Line 700 char *io_ExecArgs(const char psProg, const char **ol	Line 697 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 781 inline int io_rwrite(int fd, void * __restrict buf, si	Line 742 inline int io_rwrite(int fd, void * __restrict buf, si
/* Debug helper macros */	/* Debug helper macros */
extern int io_Debug;	extern int io_Debug;

#define io_initDebug(x) io_Debug = (x);	#define io_enableDEBUG int io_Debug
#define io_addDebug io_Debug++	#define io_initDebug(x) (io_Debug = (x))
	#define io_incDebug (io_Debug++)
	#define io_decDebug (io_Debug--)

	/* Debug macros */
	#define ioVERBOSE(x) if ((x) <= io_Debug)
	#define ioTRACE(x) if ((x) <= io_Debug) \
	syslog(LOG_DEBUG, "I'm in %s(%d)", __func__, __LINE__)
#define ioDEBUG(x, fmt, ...) do { \	#define ioDEBUG(x, fmt, ...) do { \
assert((fmt)); \	assert((fmt)); \
char str[STRSIZ] = { 0 }; \	char str[STRSIZ] = { 0 }; \
snprintf(str, sizeof str, (fmt), ##__VA_ARGS__); \	snprintf(str, sizeof str, (fmt), ##__VA_ARGS__); \
if ((x) <= io_Debug) \	if ((x) <= io_Debug) \
syslog(LOG_DEBUG, "ioDebug(%d):%s(%d): %s\n", \	syslog(LOG_DEBUG, "Debug(%d):%s(%d): %s\n", \
(x), __func__, __LINE__, str); \	(x), __func__, __LINE__, str); \
} while (0)	} while (0)

	/* Logger macro */
	#define ioLOGGER(x, fmt, ...) do { \
	assert((fmt)); \
	char str[STRSIZ] = { 0 }; \
	snprintf(str, sizeof str, (fmt), ##__VA_ARGS__); \
	syslog((x), "Logger:%s(%d): %s\n", \
	__func__, __LINE__, str); \
	} while (0)

	/* Error state macros */
#define ioERROR(x, fmt, ...) do { \	#define ioERROR(x, fmt, ...) do { \
assert((fmt)); \	assert((fmt)); \
char str[STRSIZ] = { 0 }; \	char str[STRSIZ] = { 0 }; \
snprintf(str, sizeof str, (fmt), ##__VA_ARGS__); \	snprintf(str, sizeof str, (fmt), ##__VA_ARGS__); \
syslog(LOG_ERR, "ioError():%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 io_sysERROR(x) do { \	#define ioSYSERR(x) do { \
if (x > 0 \|\| errno) \	if (x > 0 \|\| errno) \
syslog(LOG_ERR, "ioError(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, \
strerror(x > 0 ? x : errno)); \	strerror(x > 0 ? x : errno)); \
} while (0)	} while (0)
#define io_aitERROR(ait) do { \	#define ioLIBERR(ait) do { \
if (ait##_GetErrno()) \	if (ait##_GetErrno()) \
syslog(LOG_ERR, "ioError(ait):%s(%d): #%d - %s\n", \	syslog(LOG_ERR, "Error(lib):%s(%d): #%d - %s\n", \
__func__, __LINE__, ait##_GetErrno(), \	__func__, __LINE__, ait##_GetErrno(), \
ait##_GetError()); \	ait##_GetError()); \
} while (0)	} while (0)
Line 954 size_t ioSendFile(int s, const char *csFile, size_t se	Line 932 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

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>

Removed from v.1.13
changed lines
	Added in v.1.15