version 1.4, 2011/09/07 07:24:21
|
version 1.4.2.3, 2011/10/31 14:45:26
|
Line 59 SUCH DAMAGE.
|
Line 59 SUCH DAMAGE.
|
#include <aitio.h> |
#include <aitio.h> |
|
|
|
|
#define RPC_VERSION 1 | #define RPC_VERSION 2 |
#define RPC_DEFPORT 2611 |
#define RPC_DEFPORT 2611 |
|
|
|
|
Line 116 typedef struct {
|
Line 116 typedef struct {
|
typedef struct tagRPCFunc { |
typedef struct tagRPCFunc { |
uint16_t func_tag; |
uint16_t func_tag; |
uint32_t func_hash; |
uint32_t func_hash; |
int8_t func_file[MAXPATHLEN]; | char func_file[MAXPATHLEN]; |
int8_t func_name[UCHAR_MAX + 1]; | char func_name[UCHAR_MAX + 1]; |
|
|
array_t *func_vars; |
array_t *func_vars; |
|
|
Line 159 struct tagBLOBHdr {
|
Line 159 struct tagBLOBHdr {
|
/* Network RPC client & server elements */ |
/* Network RPC client & server elements */ |
|
|
typedef struct { |
typedef struct { |
struct sockaddr cli_sa; // host info | io_sockaddr_t cli_sa; // host info |
int cli_sock; // socket fd |
int cli_sock; // socket fd |
pthread_t cli_tid; // TID of thread |
pthread_t cli_tid; // TID of thread |
|
|
Line 225 inline int rpc_GetErrno();
|
Line 225 inline int rpc_GetErrno();
|
inline const char *rpc_GetError(); |
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 */ |
/* RPC Server side functions */ |
|
|
/* |
/* |
Line 242 rpc_srv_t *rpc_srv_initServer(u_int regProgID, u_int r
|
Line 258 rpc_srv_t *rpc_srv_initServer(u_int regProgID, u_int r
|
int netBuf, u_short family, const char *csHost, u_short Port); |
int netBuf, u_short family, const char *csHost, u_short Port); |
/* |
/* |
* rpc_srv_endServer() Destroy RPC server, close all opened sockets and free resources |
* rpc_srv_endServer() Destroy RPC server, close all opened sockets and free resources |
* @srv = RPC Server instance | * @psrv = RPC Server instance |
* return: none |
* 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 |
* rpc_srv_loopServer() Execute Main server loop and wait for clients requests |
* @srv = RPC Server instance |
* @srv = RPC Server instance |