--- libaitsess/src/aitsess.c 2011/04/30 22:02:59 1.2.2.1 +++ libaitsess/src/aitsess.c 2011/05/10 21:06:13 1.2.2.2 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: aitsess.c,v 1.2.2.1 2011/04/30 22:02:59 misho Exp $ +* $Id: aitsess.c,v 1.2.2.2 2011/05/10 21:06:13 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -59,17 +59,20 @@ char sessError[MAX_STR + 1]; // Error maintenance functions ... // sess_GetErrno() Get error code of last operation -inline int sess_GetErrno() +inline int +sess_GetErrno() { return sessErrno; } // sess_GetError() Get error text of last operation -inline const char *sess_GetError() +inline const char * +sess_GetError() { return sessError; } // sessDbg() Debug/Logging operations -static inline int sessDbg(FILE *f, char *fmt, ...) +static inline int +sessDbg(FILE *f, char *fmt, ...) { int ret = 0; va_list lst; @@ -90,7 +93,8 @@ static inline int sessDbg(FILE *f, char *fmt, ...) * @Sess = Session item * return: 0 OK new key created, -1 error: no memory or file not created, 1 OK key finded */ -inline int initSession(const int cnID, const char *csFName, tagSess ** __restrict Sess) +inline int +initSession(const int cnID, const char *csFName, tagSess ** __restrict Sess) { int h, ret = 0; char szStr[MAX_STR + 1]; @@ -146,7 +150,8 @@ inline int initSession(const int cnID, const char *csF * @csFName = Session filename for delete, if NULL nothing delete * @Sess = Session item */ -inline void freeSession(const char *csFName, tagSess ** __restrict Sess) +inline void +freeSession(const char *csFName, tagSess ** __restrict Sess) { (*Sess)->type ^= (*Sess)->type; if (csFName) @@ -165,7 +170,8 @@ inline void freeSession(const char *csFName, tagSess * * @Sess = Session item * return: 0 Ok successful, -1 error: not allocated resources */ -int map_createSession(const char *csFName, const int cnSeed, const u_int cnSize, tagSess ** __restrict Sess) +int +map_createSession(const char *csFName, const int cnSeed, const u_int cnSize, tagSess ** __restrict Sess) { int ret = 0; char szSName[2][FILENAME_MAX + 1]; @@ -240,7 +246,8 @@ int map_createSession(const char *csFName, const int c * @csFName = Session name for delete * @Sess = Session item */ -void map_destroySession(const char *csFName, tagSess ** __restrict Sess) +void +map_destroySession(const char *csFName, tagSess ** __restrict Sess) { int flg = 1; char szSName[2][FILENAME_MAX + 1]; @@ -279,7 +286,8 @@ void map_destroySession(const char *csFName, tagSess * * @Sess = Session item * return: 0 Ok successful, -1 error: not allocated resources */ -int ipc_createSession(const char *csFName, const int cnSeed, const u_int cnSize, tagSess ** __restrict Sess) +int +ipc_createSession(const char *csFName, const int cnSeed, const u_int cnSize, tagSess ** __restrict Sess) { int ret = 0; union semun sems; @@ -330,7 +338,8 @@ int ipc_createSession(const char *csFName, const int c * @csFName = Session name for delete * @Sess = Session item */ -void ipc_destroySession(const char *csFName, tagSess ** __restrict Sess) +void +ipc_destroySession(const char *csFName, tagSess ** __restrict Sess) { int flg = 1; union semun sems; @@ -357,7 +366,8 @@ void ipc_destroySession(const char *csFName, tagSess * * @procMem = Custom start address (optionl) *default must be 0* * return: NULL failed attach, !=NULL begin address of memory */ -inline void *map_attachSession(tagSess * __restrict s, void *procMem) +inline void * +map_attachSession(tagSess * __restrict s, void *procMem) { struct stat sb; @@ -386,7 +396,8 @@ inline void *map_attachSession(tagSess * __restrict s, * map_detachSession() MMAP Detach from shared memory * @s = Session item */ -inline void map_detachSession(tagSess * __restrict s) +inline void +map_detachSession(tagSess * __restrict s) { if (!s) return; @@ -405,7 +416,8 @@ inline void map_detachSession(tagSess * __restrict s) * @procMem = Custom start address (optionl) *default must be 0* * return: NULL failed attach, !=NULL begin address of memory */ -inline void *ipc_attachSession(tagSess * __restrict s, void *procMem) +inline void * +ipc_attachSession(tagSess * __restrict s, void *procMem) { if (!s) return NULL; @@ -423,7 +435,8 @@ inline void *ipc_attachSession(tagSess * __restrict s, * ipc_detachSession() IPC Detach from shared memory * @s = Session item */ -inline void ipc_detachSession(tagSess * __restrict s) +inline void +ipc_detachSession(tagSess * __restrict s) { if (!s) return; @@ -439,7 +452,8 @@ inline void ipc_detachSession(tagSess * __restrict s) * @s = Session item * return: -1 null session item, 0 not attached, 1 attached memory */ -inline int isAttached(tagSess * __restrict s) +inline int +isAttached(tagSess * __restrict s) { if (!s) return -1; @@ -452,7 +466,8 @@ inline int isAttached(tagSess * __restrict s) * map_notSemaphore() MMAP negative block if semaphore isn`t signaled * @s = Session item */ -inline void map_notSemaphore(tagSess * __restrict s) +inline void +map_notSemaphore(tagSess * __restrict s) { int i = -1; @@ -469,7 +484,8 @@ inline void map_notSemaphore(tagSess * __restrict s) * @s = Session item * return: -1 error: can`t return semaphore, 0 = false, 1 = true */ -inline int map_isSemaphored(tagSess * __restrict s) +inline int +map_isSemaphored(tagSess * __restrict s) { int val = -1; @@ -485,7 +501,8 @@ inline int map_isSemaphored(tagSess * __restrict s) * @s = Session item * return: 0 Ok, -1 error: can`t increment */ -inline int map_addSemaphore(tagSess * __restrict s) +inline int +map_addSemaphore(tagSess * __restrict s) { if (!s) return -1; @@ -498,7 +515,8 @@ inline int map_addSemaphore(tagSess * __restrict s) * @s = Session item * return: 0 Ok, -1 error: can`t decrement */ -inline int map_decSemaphore(tagSess * __restrict s) +inline int +map_decSemaphore(tagSess * __restrict s) { if (!s) return -1; @@ -510,7 +528,8 @@ inline int map_decSemaphore(tagSess * __restrict s) * ipc_notSemaphore() IPC negative block if semaphore isn`t signaled * @s = Session item */ -inline void ipc_notSemaphore(tagSess * __restrict s) +inline void +ipc_notSemaphore(tagSess * __restrict s) { struct sembuf sb = { 0, 0, 0 }; @@ -523,7 +542,8 @@ inline void ipc_notSemaphore(tagSess * __restrict s) * @s = Session item * return: -1 error: can`t return semaphore, 0 = false, 1 = true */ -inline int ipc_isSemaphored(tagSess * __restrict s) +inline int +ipc_isSemaphored(tagSess * __restrict s) { struct sembuf sb = { 0, 0, IPC_NOWAIT }; @@ -538,7 +558,8 @@ inline int ipc_isSemaphored(tagSess * __restrict s) * @s = Session item * return: 0 Ok, -1 error: can`t increment */ -inline int ipc_addSemaphore(tagSess * __restrict s) +inline int +ipc_addSemaphore(tagSess * __restrict s) { struct sembuf sb = { 0, 1, 0 }; @@ -553,7 +574,8 @@ inline int ipc_addSemaphore(tagSess * __restrict s) * @s = Session item * return: 0 Ok, -1 error: can`t decrement */ -inline int ipc_decSemaphore(tagSess * __restrict s) +inline int +ipc_decSemaphore(tagSess * __restrict s) { struct sembuf sb = { 0, -1, 0 };