|
|
| version 1.5.2.1, 2012/03/12 12:33:32 | version 1.5.2.2, 2012/03/12 14:53:07 |
|---|---|
| Line 58 SUCH DAMAGE. | Line 58 SUCH DAMAGE. |
| #endif | #endif |
| #include <sys/socket.h> | #include <sys/socket.h> |
| #include <aitio.h> | #include <aitio.h> |
| #include <aitsched.h> | |
| #define RPC_VERSION 3 | #define RPC_VERSION 3 |
| Line 183 typedef struct tagBLOB { | Line 184 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_numcli; // maximum concurent client connections |
| int srv_netbuf; // size of network buffer size | int srv_netbuf; // size of network buffer size |
| rpc_cli_t srv_server; // RPC server socket | rpc_cli_t srv_server; // RPC server socket |
| rpc_cli_t *srv_clients; // connected rpc client sockets | rpc_cli_t *srv_clients; // connected rpc client sockets |
| rpc_func_t *srv_funcs; // registered functions list | rpc_func_t *srv_funcs; // registered functions list |
| pthread_mutex_t srv_mtx; | pthread_mutex_t srv_mtx; |
| cmd_type_t srv_kill; | cmd_type_t srv_kill; |
| struct { | struct { |
| cmd_type_t state; // BLOB server state: ==0 disable | !=0 enable | cmd_type_t state; // BLOB server state: ==0 disable | !=0 enable |
| char dir[UCHAR_MAX + 1]; | char *dir; |
| rpc_cli_t server; // BLOB server socket | rpc_cli_t server; // BLOB server socket |
| rpc_cli_t *clients; // connected blob client sockets | rpc_cli_t *clients; // connected blob client sockets |
| Line 205 typedef struct { | Line 206 typedef struct { |
| rpc_blob_t *blobs; // registered blob variables list | rpc_blob_t *blobs; // registered blob variables list |
| pthread_mutex_t mtx; | pthread_mutex_t mtx; |
| } srv_blob; | } srv_blob; |
| sched_root_task_t *srv_sched; | |
| } rpc_srv_t; | } rpc_srv_t; |