--- libaitrpc/inc/aitrpc.h 2011/09/07 07:24:21 1.4 +++ libaitrpc/inc/aitrpc.h 2011/10/31 14:45:26 1.4.2.3 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: aitrpc.h,v 1.4 2011/09/07 07:24:21 misho Exp $ +* $Id: aitrpc.h,v 1.4.2.3 2011/10/31 14:45:26 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -59,7 +59,7 @@ SUCH DAMAGE. #include -#define RPC_VERSION 1 +#define RPC_VERSION 2 #define RPC_DEFPORT 2611 @@ -116,8 +116,8 @@ typedef struct { typedef struct tagRPCFunc { uint16_t func_tag; uint32_t func_hash; - int8_t func_file[MAXPATHLEN]; - int8_t func_name[UCHAR_MAX + 1]; + char func_file[MAXPATHLEN]; + char func_name[UCHAR_MAX + 1]; array_t *func_vars; @@ -159,7 +159,7 @@ struct tagBLOBHdr { /* Network RPC client & server elements */ typedef struct { - struct sockaddr cli_sa; // host info + io_sockaddr_t cli_sa; // host info int cli_sock; // socket fd pthread_t cli_tid; // TID of thread @@ -225,6 +225,22 @@ inline int rpc_GetErrno(); inline const char *rpc_GetError(); +/* + * rpc_chkPktSession() Check session in RPC packet + * @p = packet session + * @s = active session + * return: -1 error or 0 ok + */ +inline int rpc_chkPktSession(rpc_sess_t *p, rpc_sess_t *s); +/* + * rpc_addPktSession() Add session into RPC packet + * @p = packet session + * @s = active session + * return: -1 error or 0 ok + */ +inline int rpc_addPktSession(rpc_sess_t *p, rpc_sess_t *s); + + /* RPC Server side functions */ /* @@ -242,10 +258,10 @@ rpc_srv_t *rpc_srv_initServer(u_int regProgID, u_int r int netBuf, u_short family, const char *csHost, u_short Port); /* * rpc_srv_endServer() Destroy RPC server, close all opened sockets and free resources - * @srv = RPC Server instance + * @psrv = RPC Server instance * return: none */ -void rpc_srv_endServer(rpc_srv_t * __restrict srv); +void rpc_srv_endServer(rpc_srv_t ** __restrict psrv); /* * rpc_srv_loopServer() Execute Main server loop and wait for clients requests * @srv = RPC Server instance