version 1.7.2.3, 2012/05/14 08:36:58
|
version 1.8.2.4, 2012/05/15 22:47:10
|
Line 57 SUCH DAMAGE.
|
Line 57 SUCH DAMAGE.
|
#include <sys/limits.h> |
#include <sys/limits.h> |
#endif |
#endif |
#include <sys/socket.h> |
#include <sys/socket.h> |
|
#include <sys/queue.h> |
#include <aitio.h> |
#include <aitio.h> |
#include <aitsched.h> |
#include <aitsched.h> |
|
|
|
|
#define RPC_VERSION 3 | #define RPC_VERSION 4 |
#define RPC_DEFPORT 2611 |
#define RPC_DEFPORT 2611 |
|
|
/* RPC call request flags */ |
/* RPC call request flags */ |
Line 113 typedef enum {
|
Line 114 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; | uint8_t sess_process; |
} __packed rpc_sess_t; | } __packed rpc_sess_t; /* size == 6 bytes */ |
|
|
|
|
/* Server managment RPC functions ... */ |
/* Server managment RPC functions ... */ |
|
|
/* RPC function registration element! */ |
|
typedef struct tagRPCFunc { |
|
uint16_t func_tag; |
|
uint32_t func_hash; |
|
ait_val_t func_file; |
|
ait_val_t func_name; |
|
|
|
array_t *func_vars; |
|
|
|
void *func_parent; |
|
struct tagRPCFunc *func_next; |
|
} rpc_func_t; |
|
|
|
|
|
/* Network RPC packet - Client request */ |
/* Network RPC packet - Client request */ |
|
|
struct tagRPCCall { |
struct tagRPCCall { |
rpc_sess_t call_session; |
rpc_sess_t call_session; |
|
|
|
uint16_t call_seq; |
uint16_t call_len; |
uint16_t call_len; |
|
uint16_t call_crc; |
|
|
uint16_t call_tag; |
|
uint32_t call_hash; |
|
uint16_t call_argc; |
|
|
|
union { |
union { |
struct { |
struct { |
uint64_t flags; |
uint64_t flags; |
Line 156 struct tagRPCCall {
|
Line 140 struct tagRPCCall {
|
} call_rep; |
} call_rep; |
}; |
}; |
|
|
uint16_t call_crc; | uint16_t call_tag; |
} __packed; | uint16_t call_argc; |
| ait_val_t call_argv[0]; |
| } __packed; /* size == 24 bytes */ |
|
|
/* Network BLOB packet - Header */ |
/* Network BLOB packet - Header */ |
|
|
Line 173 struct tagBLOBHdr {
|
Line 159 struct tagBLOBHdr {
|
|
|
/* Network RPC client & server elements */ |
/* Network RPC client & server elements */ |
|
|
typedef struct { | /* RPC function registration element! */ |
io_sockaddr_t cli_sa; // host info | typedef struct tagRPCFunc { |
int cli_sock; // socket fd | ait_val_t func_name; |
pthread_t cli_tid; // TID of thread | |
|
|
cmd_type_t cli_kill; | array_t *func_vars; |
|
|
void *cli_parent; // pointer to parent rpc_srv_t for server or to rpc_sess_t for client | void *func_parent; |
int cli_netbuf; // size of network buffer size | TAILQ_ENTRY(tagRPCFunc) func_node; |
| } rpc_func_t; |
| |
| |
| typedef struct { |
| int cli_id; /* slot id */ |
| int cli_sock; /* socket fd */ |
| io_sockaddr_t cli_sa; /* host address */ |
| ait_val_t cli_buf; /* network buffer */ |
| |
| void *cli_parent; /* pointer to parent rpc_srv_t for server or to rpc_sess_t for client */ |
} rpc_cli_t; |
} rpc_cli_t; |
|
|
|
|
Line 196 typedef struct tagBLOB {
|
Line 191 typedef struct tagBLOB {
|
} rpc_blob_t; |
} rpc_blob_t; |
|
|
typedef struct { |
typedef struct { |
rpc_sess_t srv_session; // RPC session registration info | rpc_sess_t srv_session; /* RPC session registration info */ |
int srv_numcli; // maximum concurent client connections | int srv_netbuf; /* size of network buffer */ |
int srv_netbuf; // size of network buffer size | |
|
|
rpc_cli_t srv_server; // RPC server socket | sched_root_task_t *srv_root; /* RPC server scheduler */ |
rpc_cli_t *srv_clients; // connected rpc client sockets | intptr_t srv_kill; /* Scheduler condition variable */ |
|
|
rpc_func_t *srv_funcs; // registered functions list | rpc_cli_t srv_server; /* RPC server socket */ |
| array_t *srv_clients; /* connected rpc client sockets */ |
|
|
cmd_type_t srv_kill; | TAILQ_HEAD(, tagRPCFunc) srv_funcs; /* RPC functions list */ |
|
|
struct { |
struct { |
cmd_type_t state; // BLOB server state: ==0 disable | !=0 enable |
cmd_type_t state; // BLOB server state: ==0 disable | !=0 enable |
Line 215 typedef struct {
|
Line 210 typedef struct {
|
rpc_cli_t *clients; // connected blob client sockets |
rpc_cli_t *clients; // connected blob client sockets |
|
|
rpc_blob_t *blobs; // registered blob variables list |
rpc_blob_t *blobs; // registered blob variables list |
} srv_blob; | } srv_blob; |
} rpc_srv_t; |
} rpc_srv_t; |
|
|
|
|
Line 241 inline const char *rpc_GetError();
|
Line 236 inline const char *rpc_GetError();
|
|
|
|
|
/* |
/* |
* rpc_chkPktSession() - Check session in RPC packet | * rpc_chkPktSession() - Check RPC session |
* |
* |
* @p = packet session |
* @p = packet session |
* @s = active session |
* @s = active session |
* return: -1 error or 0 ok | * return: -1, 1, 2, 3 are errors or 0 ok |
*/ |
*/ |
inline int rpc_chkPktSession(rpc_sess_t *p, rpc_sess_t *s); |
inline int rpc_chkPktSession(rpc_sess_t *p, rpc_sess_t *s); |
/* |
/* |
* rpc_addPktSession() - Add session into RPC packet | * rpc_addPktSession() - Prepare session into network format |
* |
* |
* @p = packet session |
* @p = packet session |
* @s = active session | * @s = host session |
* return: -1 error or 0 ok |
* return: -1 error or 0 ok |
*/ |
*/ |
inline int rpc_addPktSession(rpc_sess_t *p, rpc_sess_t *s); |
inline int rpc_addPktSession(rpc_sess_t *p, rpc_sess_t *s); |
|
/* |
|
* rpc_register_srvServices() - Register internal service functions |
|
* |
|
* @srv = RPC server instance |
|
* return: -1 error or 0 ok |
|
*/ |
|
int rpc_register_srvServices(rpc_srv_t * __restrict srv); |
|
|
|
|
/* RPC Server side functions */ |
/* RPC Server side functions */ |
Line 267 inline int rpc_addPktSession(rpc_sess_t *p, rpc_sess_t
|
Line 269 inline int rpc_addPktSession(rpc_sess_t *p, rpc_sess_t
|
* @regProcID = ProcessID for authentication & recognition |
* @regProcID = ProcessID for authentication & recognition |
* @concurentClients = Concurent clients at same time to this server |
* @concurentClients = Concurent clients at same time to this server |
* @netBuf = Network buffer length, if =0 == BUFSIZ (also meaning max RPC packet) |
* @netBuf = Network buffer length, if =0 == BUFSIZ (also meaning max RPC packet) |
* @family = Family type, AF_INET, AF_INET6 or AF_LOCAL |
|
* @csHost = Host name or address for bind server, if NULL any address |
* @csHost = Host name or address for bind server, if NULL any address |
* @Port = Port for bind server, if Port == 0 default port is selected |
* @Port = Port for bind server, if Port == 0 default port is selected |
* return: NULL == error or !=NULL bind and created RPC server instance |
* return: NULL == error or !=NULL bind and created RPC server instance |
*/ |
*/ |
rpc_srv_t *rpc_srv_initServer(u_int regProgID, u_int regProcID, int concurentClients, | rpc_srv_t *rpc_srv_initServer(unsigned int regProgID, unsigned char regProcID, |
int netBuf, u_short family, const char *csHost, u_short Port); | int concurentClients, int netBuf, |
| const char *csHost, unsigned 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 |
* |
* |
Line 333 int rpc_srv_loopBLOB(rpc_srv_t * __restrict srv);
|
Line 335 int rpc_srv_loopBLOB(rpc_srv_t * __restrict srv);
|
* rpc_srv_registerCall() - Register call to RPC server |
* rpc_srv_registerCall() - Register call to RPC server |
* |
* |
* @srv = RPC Server instance |
* @srv = RPC Server instance |
* @csModule = Module name, if NULL self binary | * @tag = Function tag |
* @csFunc = Function name | * @funcaddr = Function address |
* @args = Number of return function arguments, use for restriction case! | * @args = Number of return function arguments |
* return: -1 error or 0 register ok | * return: -1 error, 0 already registered tag or 1 register ok |
*/ |
*/ |
int rpc_srv_registerCall(rpc_srv_t * __restrict srv, const char *csModule, const char *csFunc, | int rpc_srv_registerCall(rpc_srv_t * __restrict srv, unsigned short tag, |
unsigned short args); | void *funcaddr, unsigned short args); |
/* |
/* |
* rpc_srv_unregisterCall() - Unregister call from RPC server |
* rpc_srv_unregisterCall() - Unregister call from RPC server |
* |
* |
* @srv = RPC Server instance |
* @srv = RPC Server instance |
* @csModule = Module name, if NULL self binary | * @tag = Function tag |
* @csFunc = Function name | |
* return: -1 error, 0 not found call, 1 unregister ok |
* return: -1 error, 0 not found call, 1 unregister ok |
*/ |
*/ |
int rpc_srv_unregisterCall(rpc_srv_t * __restrict srv, const char *csModule, const char *csFunc); | int rpc_srv_unregisterCall(rpc_srv_t * __restrict srv, unsigned short tag); |
/* |
/* |
* rpc_srv_getFunc() - Get registered call from RPC server by Name | * rpc_srv_getCall() - Get registered call from RPC server |
* |
* |
* @srv = RPC Server instance |
* @srv = RPC Server instance |
* @csModule = Module name, if NULL self binary |
|
* @csFunc = Function name |
|
* return: NULL not found call, !=NULL return call |
|
*/ |
|
rpc_func_t *rpc_srv_getFunc(rpc_srv_t * __restrict srv, const char *csModule, const char *csFunc); |
|
/* |
|
* rpc_srv_getCall() - Get registered call from RPC server |
|
* |
|
* @srv = RPC Server instance |
|
* @tag = tag for function |
* @tag = tag for function |
* @hash = hash for function |
|
* return: NULL not found call, !=NULL return call |
* return: NULL not found call, !=NULL return call |
*/ |
*/ |
inline rpc_func_t *rpc_srv_getCall(rpc_srv_t * __restrict srv, uint16_t tag, uint32_t hash); | inline rpc_func_t *rpc_srv_getCall(rpc_srv_t * __restrict srv, uint16_t tag); |
/* |
/* |
* rpc_srv_execCall() - Execute registered call from RPC server |
* rpc_srv_execCall() - Execute registered call from RPC server |
* |
* |
Line 380 int rpc_srv_execCall(rpc_func_t * __restrict call, str
|
Line 371 int rpc_srv_execCall(rpc_func_t * __restrict call, str
|
|
|
|
|
/* |
/* |
* rpc_srv_getVars() - Get variables array for RPC call |
|
* |
|
* @call = RPC function call |
|
* @vars = Returned variables array, may be NULL |
|
* return: -1 error, !=-1 Number of returned variables |
|
*/ |
|
inline int rpc_srv_getVars(rpc_func_t * __restrict call, array_t ** __restrict vars); |
|
|
|
|
|
/* |
|
* rpc_srv_blobCreate() - Create map blob to memory region and return object |
* rpc_srv_blobCreate() - Create map blob to memory region and return object |
* |
* |
* @srv = RPC Server instance |
* @srv = RPC Server instance |
Line 501 int rpc_cli_delBLOB(rpc_cli_t * __restrict cli, ait_va
|
Line 482 int rpc_cli_delBLOB(rpc_cli_t * __restrict cli, ait_va
|
*/ |
*/ |
inline int rpc_cli_getBLOB(rpc_cli_t * __restrict cli, ait_val_t * __restrict var, |
inline int rpc_cli_getBLOB(rpc_cli_t * __restrict cli, ait_val_t * __restrict var, |
void ** __restrict data); |
void ** __restrict data); |
|
|
|
|
/* |
|
* rpc_calcHashes() - Calculate hashes for RPC call |
|
* |
|
* @func = function |
|
* @csModule = Module name, if NULL self binary |
|
* @csFunc = Function name |
|
* return: -1 error or 0 ok |
|
*/ |
|
int rpc_calcHashes(rpc_func_t * __restrict func, const char *csModule, const char *csFunc); |
|
|
|
|
|
/* RPC Client side functions */ |
/* RPC Client side functions */ |