--- libaitrpc/inc/aitrpc.h 2012/03/12 12:33:32 1.5.2.1 +++ libaitrpc/inc/aitrpc.h 2012/03/12 14:53:07 1.5.2.2 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: aitrpc.h,v 1.5.2.1 2012/03/12 12:33:32 misho Exp $ +* $Id: aitrpc.h,v 1.5.2.2 2012/03/12 14:53:07 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -58,6 +58,7 @@ SUCH DAMAGE. #endif #include #include +#include #define RPC_VERSION 3 @@ -183,21 +184,21 @@ typedef struct tagBLOB { } rpc_blob_t; typedef struct { - rpc_sess_t srv_session; // RPC session registration info - int srv_numcli; // maximum concurent client connections - int srv_netbuf; // size of network buffer size + rpc_sess_t srv_session; // RPC session registration info + int srv_numcli; // maximum concurent client connections + int srv_netbuf; // size of network buffer size - rpc_cli_t srv_server; // RPC server socket - rpc_cli_t *srv_clients; // connected rpc client sockets + rpc_cli_t srv_server; // RPC server socket + 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; - cmd_type_t srv_kill; + pthread_mutex_t srv_mtx; + cmd_type_t srv_kill; struct { 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 *clients; // connected blob client sockets @@ -205,7 +206,9 @@ typedef struct { rpc_blob_t *blobs; // registered blob variables list pthread_mutex_t mtx; - } srv_blob; + } srv_blob; + + sched_root_task_t *srv_sched; } rpc_srv_t;