[BACK]Return to aitrpc.h CVS log [TXT] [DIR] Up to [ELWIX - Embedded LightWeight unIX -] / libaitrpc / inc

Diff for /libaitrpc/inc/aitrpc.h between versions 1.4.2.5 and 1.5.2.1

version 1.4.2.5, 2011/11/03 13:51:19 version 1.5.2.1, 2012/03/12 12:33:32
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, 2011Copyright 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 50  SUCH DAMAGE. Line 50  SUCH DAMAGE.
 #include <assert.h>  #include <assert.h>
 #include <stdlib.h>  #include <stdlib.h>
 #include <string.h>  #include <string.h>
   #include <errno.h>
 #include <sys/types.h>  #include <sys/types.h>
 #include <sys/param.h>  #include <sys/param.h>
 #if !defined(__NetBSD__)  #if !defined(__NetBSD__)
Line 59  SUCH DAMAGE. Line 60  SUCH DAMAGE.
 #include <aitio.h>  #include <aitio.h>
   
   
#define RPC_VERSION             2#define RPC_VERSION             3
 #define RPC_DEFPORT             2611  #define RPC_DEFPORT             2611
   
   
Line 88  typedef enum { Line 89  typedef enum {
 #define RPC_CALLBACK_CHECK_INPUT(_f)    do { \  #define RPC_CALLBACK_CHECK_INPUT(_f)    do { \
                                                 assert((_f)); \                                                  assert((_f)); \
                                                 if (!(_f)) { \                                                  if (!(_f)) { \
                                                        rpc_SetErr(22, "Error:: invalid callback parameters ...\n"); \                                                        rpc_SetErr(EINVAL, \
                                                                         "Invalid callback parameters ..."); \
                                                         return -1; \                                                          return -1; \
                                                 } \                                                  } \
                                         } while (0)                                          } while (0)
 #define RPC_CALLBACK_CHK_ARGS(_f, _n)   do { \  #define RPC_CALLBACK_CHK_ARGS(_f, _n)   do { \
                                                 RPC_CALLBACK_CHECK_INPUT((_f)); \                                                  RPC_CALLBACK_CHECK_INPUT((_f)); \
                                                 if ((_f) && io_arraySize((_f)->func_vars) < _n) { \                                                  if ((_f) && io_arraySize((_f)->func_vars) < _n) { \
                                                        rpc_SetErr(22, "Error:: not enough number of arguments!\n"); \                                                        rpc_SetErr(EINVAL, \
                                                                         "Not enough number of arguments!"); \
                                                         return -1; \                                                          return -1; \
                                                 } \                                                  } \
                                         } while (0)                                          } while (0)
Line 105  typedef enum { Line 108  typedef enum {
   
 typedef struct {  typedef struct {
         uint8_t         sess_version;          uint8_t         sess_version;
           uint8_t         sess_timeout;
         uint32_t        sess_program;          uint32_t        sess_program;
         uint32_t        sess_process;          uint32_t        sess_process;
 } __packed rpc_sess_t;  } __packed rpc_sess_t;
Line 112  typedef struct { Line 116  typedef struct {
   
 /* Server managment RPC functions ... */  /* Server managment RPC functions ... */
   
// RPC function registration element!/* RPC function registration element! */
 typedef struct tagRPCFunc {  typedef struct tagRPCFunc {
         uint16_t                func_tag;          uint16_t                func_tag;
         uint32_t                func_hash;          uint32_t                func_hash;
Line 168  typedef struct { Line 172  typedef struct {
 } rpc_cli_t;  } rpc_cli_t;
   
   
// BLOB registration element!/* BLOB registration element! */
 typedef struct tagBLOB {  typedef struct tagBLOB {
         uint32_t        blob_var;          uint32_t        blob_var;
   
Line 352  int rpc_srv_execCall(rpc_func_t * __restrict call, str Line 356  int rpc_srv_execCall(rpc_func_t * __restrict call, str
   
   
 /*  /*
  * rpc_srv_allocVars() Allocate array for call variables  
  * @call = RPC function call  
  * @varnum = Number of variables, if ==0 return already allocated variables number  
  * return: -1 error, !=-1 return varnum value  
  */  
 inline int rpc_srv_allocVars(rpc_func_t * __restrict call, int varnum);  
 /*  
  * rpc_srv_destroyVars() Destroy variables of array & array  
  * @call = RPC function call  
  * return: -1 error, !=-1 Returne remained variables  
  */  
 inline int rpc_srv_destroyVars(rpc_func_t * __restrict call);  
 /*  
  * rpc_srv_freeVars() Clean values from variables of array  
  * @call = RPC function call  
  * return: -1 error, !=-1 Returned number of cleaned variables  
  */  
 inline int rpc_srv_freeVars(rpc_func_t * __restrict call);  
 /*  
  * rpc_srv_copyVars() Copy variables for RPC call to new variable array   * rpc_srv_copyVars() Copy variables for RPC call to new variable array
  * @call = RPC function call   * @call = RPC function call
  * @newvars = New allocated variables array, must be free after use   * @newvars = New allocated variables array, must be free after use
Line 518  void rpc_cli_closeClient(rpc_cli_t * __restrict cli); Line 503  void rpc_cli_closeClient(rpc_cli_t * __restrict cli);
  */   */
 int rpc_cli_execCall(rpc_cli_t *cli, const char *csModule, const char *csFunc,   int rpc_cli_execCall(rpc_cli_t *cli, const char *csModule, const char *csFunc, 
                 array_t * __restrict in_vars, array_t ** __restrict out_vars);                  array_t * __restrict in_vars, array_t ** __restrict out_vars);
 /*  
  * rpc_cli_freeVars() Free ait_val_t array returned from RPC call  
  * @vars = Variable array  
  * return: none  
  */  
 inline void rpc_cli_freeVars(array_t ** __restrict vars);  
 /*  
  * rpc_cli_allocVars() Allocate ait_val_t array for RPC call  
  * @args = Number of arguments  
  * return: =NULL error or !=NULL allocated array  
  */  
 inline array_t *rpc_cli_allocVars(unsigned short args);  
   
   
 /*  /*
Removed from v.1.4.2.5  
changed lines
  Added in v.1.5.2.1

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