version 1.8.2.5, 2012/05/16 07:20:43
|
version 1.8.2.9, 2012/05/16 08:10:39
|
Line 180 typedef struct tagRPCFunc {
|
Line 180 typedef struct tagRPCFunc {
|
} rpc_func_t; |
} rpc_func_t; |
|
|
|
|
|
/* BLOB register element */ |
|
typedef struct tagBLOB { |
|
uint32_t blob_var; /* BLOB id */ |
|
|
|
size_t blob_len; /* size of allocated BLOB data */ |
|
void *blob_data; /* mapped BLOB data */ |
|
|
|
TAILQ_ENTRY(tagBLOB) blob_node; |
|
} rpc_blob_t; |
|
|
|
|
typedef struct { |
typedef struct { |
int cli_id; /* slot id */ |
int cli_id; /* slot id */ |
int cli_sock; /* socket fd */ |
int cli_sock; /* socket fd */ |
Line 189 typedef struct {
|
Line 200 typedef struct {
|
void *cli_parent; /* pointer to parent rpc_srv_t for server or to rpc_sess_t for client */ |
void *cli_parent; /* pointer to parent rpc_srv_t for server or to rpc_sess_t for client */ |
} rpc_cli_t; |
} rpc_cli_t; |
|
|
|
|
/* BLOB registration element! */ |
|
typedef struct tagBLOB { |
|
uint32_t blob_var; |
|
|
|
size_t blob_len; // size of allocated BLOB data |
|
void *blob_data; // BLOB data |
|
|
|
struct tagBLOB *blob_next; |
|
} 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_netbuf; /* size of network buffer */ |
int srv_netbuf; /* size of network buffer */ |
Line 213 typedef struct {
|
Line 213 typedef struct {
|
TAILQ_HEAD(, tagRPCFunc) srv_funcs; /* RPC functions list */ |
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 */ |
ait_val_t dir; | ait_val_t dir; /* BLOB states directory */ |
|
|
rpc_cli_t server; // BLOB server socket | rpc_cli_t server; /* BLOB server socket */ |
rpc_cli_t *clients; // connected blob client sockets | array_t *clients; /* connected blob client sockets */ |
|
|
rpc_blob_t *blobs; // registered blob variables list | TAILQ_HEAD(, tagBLOB) blobs; /* registered blob variables list */ |
} srv_blob; |
} srv_blob; |
} rpc_srv_t; |
} rpc_srv_t; |
|
|
Line 268 inline int rpc_addPktSession(rpc_sess_t *p, rpc_sess_t
|
Line 268 inline int rpc_addPktSession(rpc_sess_t *p, rpc_sess_t
|
* return: -1 error or 0 ok |
* return: -1 error or 0 ok |
*/ |
*/ |
int rpc_register_srvServices(rpc_srv_t * __restrict srv); |
int rpc_register_srvServices(rpc_srv_t * __restrict srv); |
|
/* |
|
* rpc_register_blobServices() - Register internal service functions |
|
* |
|
* @srv = RPC server instance |
|
* return: -1 error or 0 ok |
|
*/ |
|
int rpc_register_blobServices(rpc_srv_t * __restrict srv); |
|
|
|
|
/* RPC Server side functions */ |
/* RPC Server side functions */ |
Line 381 int rpc_srv_execCall(rpc_func_t * __restrict call, str
|
Line 388 int rpc_srv_execCall(rpc_func_t * __restrict call, str
|
|
|
|
|
/* |
/* |
* rpc_srv_blobCreate() - Create map blob to memory region and return object | * rpc_srv_blobCreate() - Create and map blob to memory region and return object |
* |
* |
* @srv = RPC Server instance |
* @srv = RPC Server instance |
* @len = BLOB length object |
* @len = BLOB length object |