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; |
|
|
|
|