--- libaitrpc/inc/aitrpc.h 2013/07/16 12:35:25 1.15.2.5 +++ libaitrpc/inc/aitrpc.h 2013/08/23 13:13:06 1.18.2.1 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: aitrpc.h,v 1.15.2.5 2013/07/16 12:35:25 misho Exp $ +* $Id: aitrpc.h,v 1.18.2.1 2013/08/23 13:13:06 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -62,7 +62,7 @@ SUCH DAMAGE. #include -#define RPC_VERSION 6 +#define RPC_VERSION 7 #define RPC_DEFPORT 2611 /* RPC call request flags */ @@ -85,6 +85,8 @@ SUCH DAMAGE. #define CALL_BLOBCLIENTS 65528 #define CALL_BLOBVARS 65527 +/* RPC signals */ +#define SIGFBLOB 54 /* RPC types */ @@ -125,8 +127,7 @@ typedef struct { struct tagRPCCall { rpc_sess_t call_session; - uint16_t call_seq; - uint16_t call_len; + uint32_t call_len; uint16_t call_crc; union { @@ -254,7 +255,37 @@ typedef int (*rpc_callback_t)(rpc_cli_t *, struct tagR int rpc_GetErrno(); // rpc_GetError() Get error text of last operation const char *rpc_GetError(); +// rpc_SetErr() Set error to variables for internal use!!! +void rpc_SetErr(int eno, char *estr, ...); + + +/* + * rpc_Read() - RPC read operation + * + * @sock = socket + * @type = type of socket + * @flags = receive flags + * @sa = check client address, if you use udp protocol + * @buf = buffer + * @blen = buffer length + * return: -1 error or >-1 readed bytes into buffer + */ +ssize_t rpc_Read(int sock, int type, int flags, sockaddr_t * __restrict sa, + unsigned char * __restrict buf, size_t blen); +/* + * rpc_Write() - RPC write operation + * + * @sock = socket + * @type = type of socket + * @flags = send flags + * @sa = send to client address, if you use udp protocol + * @buf = buffer + * @blen = buffer length + * return: -1 error or >-1 written bytes into buffer + */ +ssize_t rpc_Write(int sock, int type, int flags, sockaddr_t * __restrict sa, + unsigned char * __restrict buf, size_t blen); /* * rpc_chkPktSession() - Check RPC session