--- libaitrpc/inc/aitrpc.h 2012/11/13 09:22:10 1.11 +++ libaitrpc/inc/aitrpc.h 2012/11/19 12:43:21 1.11.2.2 @@ -3,7 +3,7 @@ * by Michael Pounov * * $Author: misho $ -* $Id: aitrpc.h,v 1.11 2012/11/13 09:22:10 misho Exp $ +* $Id: aitrpc.h,v 1.11.2.2 2012/11/19 12:43:21 misho Exp $ * ************************************************************************** The ELWIX and AITNET software is distributed under the following @@ -205,6 +205,7 @@ typedef struct { typedef struct { rpc_sess_t srv_session; /* RPC session registration info */ int srv_netbuf; /* size of network buffer */ + int srv_proto; /* Server protocol */ pthread_t srv_tid; /* RPC exec pthread */ sched_root_task_t *srv_root; /* RPC server scheduler */ @@ -301,11 +302,12 @@ int rpc_register_blobServices(rpc_srv_t * __restrict s * @netBuf = Network buffer length (min:512 bytes), if =0 == BUFSIZ (also meaning max RPC packet) * @csHost = Host name or address for bind server, if NULL any address * @Port = Port for bind server, if Port == 0 default port is selected + * @proto = Protocol, if == 0 choose SOCK_STREAM * return: NULL == error or !=NULL bind and created RPC server instance */ rpc_srv_t *rpc_srv_initServer(unsigned int regProgID, unsigned char regProcID, int concurentClients, int netBuf, - const char *csHost, unsigned short Port); + const char *csHost, unsigned short Port, int proto); /* * rpc_srv_endServer() - Destroy RPC server, close all opened sockets and free resources * @@ -524,10 +526,11 @@ inline int rpc_cli_getBLOB(rpc_cli_t * __restrict cli, * @netBuf = Network buffer length (min:512 bytes), if =0 == BUFSIZ (also meaning max RPC packet) * @csHost = Host name or IP address for bind server * @Port = Port for bind server, if Port == 0 default port is selected + * @proto = Protocol, if == 0 choose SOCK_STREAM * return: NULL == error or !=NULL connection to RPC server established */ rpc_cli_t *rpc_cli_openClient(unsigned int ProgID, unsigned char ProcID, int netBuf, - const char *csHost, unsigned short Port); + const char *csHost, unsigned short Port, int proto); /* * rpc_cli_closeClient() - Close connection to RPC server and free resources *