--- libaitsess/inc/aitsess.h	2011/04/30 22:02:59	1.2.2.1
+++ libaitsess/inc/aitsess.h	2011/09/07 15:52:35	1.3.2.1
@@ -3,7 +3,7 @@
 *  by Michael Pounov <misho@openbsd-bg.org>
 *
 * $Author: misho $
-* $Id: aitsess.h,v 1.2.2.1 2011/04/30 22:02:59 misho Exp $
+* $Id: aitsess.h,v 1.3.2.1 2011/09/07 15:52:35 misho Exp $
 *
 **************************************************************************
 The ELWIX and AITNET software is distributed under the following
@@ -47,9 +47,12 @@ SUCH DAMAGE.
 #define __AITSESS_H
 
 
+#include <assert.h>
 #include <semaphore.h>
 #include <sys/types.h>
+#include <aitio.h>
 
+#define SHARED_UNKNOWN	0
 #define SHARED_IPC	1
 #define SHARED_MAP	2
 
@@ -67,6 +70,7 @@ SUCH DAMAGE.
 typedef struct _tagSess {
 	key_t	key;
 	u_char	type;
+	u_char	zcopy;
 	off_t	eom;
 	void	*addr;
 	off_t	offset;
@@ -86,17 +90,20 @@ typedef struct _tagSess {
 inline int sess_GetErrno();
 // sess_GetError() Get error text of last operation
 inline const char *sess_GetError();
+// sess_SetErr() Set error to variables for internal use!!!
+inline void sess_SetErr(int eno, char *estr, ...);
 // -------------------------------------------------------
 
 
 /*
  * initSession() Initializing session structure, if session file not exists creating with specified tech
- * @cnID = Technology using in session. SHARED_IPC IPC tech; SHARED_MAP BSD MemoryMap tech
+ * @pnID = Technology using in session. 
+ 	SHARED_IPC IPC tech; SHARED_MAP BSD MemoryMap tech or if =NULL SHARED_IPC
  * @csFName = Session filename for build key and identified
- * @Sess = Session item
+ * @Sess = Session item, if =NULL allocate memory for session after use must be free!
  * 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(int *pnID, const char *csFName, tagSess ** __restrict Sess);
 /*
  * freeSession() Free allocated memory for session item and delete session file if present name
  * @csFName = Session filename for delete, if NULL nothing delete
@@ -224,7 +231,7 @@ inline int ipc_decSemaphore(tagSess * __restrict s);
 //  Lazy macros for lazy programmers :-) by Michael Pounov; Optimizing work with sessions!
 //
 
-#define DESTROY_SESSION(fname, s)	do { \
+#define DESTROY_SESSION(fname, s)	do { assert((s)); assert((*s)); \
 						switch (((*s))->type) { \
 							case SHARED_IPC: \
 									 ipc_destroySession((fname), (s)); \
@@ -235,7 +242,7 @@ inline int ipc_decSemaphore(tagSess * __restrict s);
 						} \
 					} while(0)
 
-#define ATTACH_MEMORY(s)		do { \
+#define ATTACH_MEMORY(s)		do { assert((s)); \
 						switch ((s)->type) { \
 							case SHARED_IPC: \
 									 ipc_attachSession((s), 0); \
@@ -246,7 +253,7 @@ inline int ipc_decSemaphore(tagSess * __restrict s);
 						} \
 					} while(0)
 
-#define DETACH_MEMORY(s)		do { \
+#define DETACH_MEMORY(s)		do { assert((s)); \
 						switch ((s)->type) { \
 							case SHARED_IPC: \
 									 ipc_detachSession((s)); \
@@ -257,7 +264,7 @@ inline int ipc_decSemaphore(tagSess * __restrict s);
 						} \
 					} while(0)
 
-#define NOT_SEMAPHORE(s)	do { \
+#define NOT_SEMAPHORE(s)	do { assert((s)); \
 					switch ((s)->type) { \
 						case SHARED_IPC: \
 								 ipc_notSemaphore((s)); \
@@ -268,7 +275,7 @@ inline int ipc_decSemaphore(tagSess * __restrict s);
 					} \
 				} while(0)
 
-#define IS_SEMAPHORED(s, ret)	do { \
+#define IS_SEMAPHORED(s, ret)	do { assert((s)); \
 					switch ((s)->type) { \
 						case SHARED_IPC: \
 								 (ret) = ipc_isSemaphored((s)); \
@@ -281,7 +288,7 @@ inline int ipc_decSemaphore(tagSess * __restrict s);
 					} \
 				} while(0)
 
-#define ADD_SEMAPHORE(s, ret)	do { \
+#define ADD_SEMAPHORE(s, ret)	do { assert((s)); \
 					switch ((s)->type) { \
 						case SHARED_IPC: \
 								 (ret) = ipc_addSemaphore((s)); \
@@ -294,7 +301,7 @@ inline int ipc_decSemaphore(tagSess * __restrict s);
 					} \
 				} while(0)
 
-#define DEC_SEMAPHORE(s, ret)	do { \
+#define DEC_SEMAPHORE(s, ret)	do { assert((s)); \
 					switch ((s)->type) { \
 						case SHARED_IPC: \
 								 (ret) = ipc_decSemaphore((s)); \
@@ -348,6 +355,29 @@ int sess_DelValue(tagSess * __restrict s, const char *
  	>0 set position, if add item merged with IS_ADD and if define item merged with IS_DEF
 */
 int sess_SetValue(tagSess * __restrict s, const char *csAttr, const char *psVal);
+
+/*
+ * sess_prepareSession() Attach to shared memory and de-marshaling data
+ * @s = Session
+ * @useDirect = Use direct shared memory if !=0 or snapshot of data to array
+ * return: NULL error or no data, !=NULL array with variables, 
+ *		after use must free resources with sess_doneSession()
+ */
+array_t *sess_prepareSession(tagSess * __restrict s, unsigned char useDirect);
+/*
+ * sess_doneSession() Free resources allocated with sess_prepareSession()
+ * @s = Session
+ * @arr = Array with variables for free
+ * return: none
+ */
+void sess_doneSession(tagSess * __restrict s, array_t ** __restrict arr);
+/*
+ * sess_commitSession() Commit data to shared memory
+ * @s = Session
+ * @arr = Array with variables for save
+ * return -1 error or !=-1 size of stored variables into shared memory
+ */
+int sess_commitSession(tagSess * __restrict s, array_t * __restrict arr);
 
 
 #endif