libaitrpc/inc/aitrpc.h - diff

Return to aitrpc.h CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitrpc / inc

Diff for /libaitrpc/inc/aitrpc.h between versions 1.24 and 1.25.2.1

version 1.24, 2014/04/27 16:26:45	version 1.25.2.1, 2015/01/15 20:27:49
Line 65 SUCH DAMAGE.	Line 65 SUCH DAMAGE.
#define RPC_VERSION 7	#define RPC_VERSION 7
#define RPC_DEFPORT 2611	#define RPC_DEFPORT 2611

	/* Additional ELWIX RPC supporting protocols */
	#ifndef SOCK_STREAM
	#define SOCK_STREAM 1 /* stream socket */
	#endif
	#ifndef SOCK_DGRAM
	#define SOCK_DGRAM 2 /* datagram socket */
	#endif
	#ifndef SOCK_RAW
	#define SOCK_RAW 3 /* raw-protocol interface */
	#endif
	#define SOCK_BPF 4 /* ethernet interface */
	#define SOCK_PIPE 5 /* bi-directional pipe interface */

/* RPC call request flags */	/* RPC call request flags */

#define RPC_REPLY 0x0	#define RPC_REPLY 0x0
Line 360 void rpc_srv_endServer(rpc_srv_t ** __restrict psrv);	Line 373 void rpc_srv_endServer(rpc_srv_t ** __restrict psrv);
* return: -1 error or 0 ok, infinite loop ...	* return: -1 error or 0 ok, infinite loop ...
*/	*/
int rpc_srv_loopServer(rpc_srv_t * __restrict srv);	int rpc_srv_loopServer(rpc_srv_t * __restrict srv);
#define rpc_srv_execServer(_srv, _sync) do { assert((_srv)); \	#define rpc_srv_execServer(_srv, _sync) \
if (!(_srv)->srv_kill) { \	do { assert((_srv)); \
pthread_create(&(_srv)->srv_tid, NULL, (void()(void*)) \	if (!(_srv)->srv_kill) { \
rpc_srv_loopServer, (_srv)); \	pthread_create(&(_srv)->srv_tid, NULL, (void()(void*)) \
if ((_sync)) \	rpc_srv_loopServer, (_srv)); \
pthread_join((_srv)->srv_tid, (void**) (_sync)); \	if ((_sync)) \
else \	pthread_join((_srv)->srv_tid, (void**) (_sync)); \
pthread_detach((_srv)->srv_tid); \	else \
} } while (0)	pthread_detach((_srv)->srv_tid); \
#define rpc_srv_killServer(_srv) (assert((_srv)), (_srv)->srv_blob.kill = 1, (_srv)->srv_kill = 1)	} } while (0)
	#define rpc_srv_killServer(_srv) \
	(assert((_srv)), (_srv)->srv_blob.kill = 1, (_srv)->srv_kill = 1)

/*	/*
* rpc_srv_initBLOBServer() - Init & create BLOB Server	* rpc_srv_initBLOBServer() - Init & create BLOB Server
Line 394 void rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)	Line 409 void rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv)
* return: -1 error or 0 ok, infinite loop ...	* return: -1 error or 0 ok, infinite loop ...
*/	*/
int rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv);	int rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv);
#define rpc_srv_execBLOBServer(_srv) do { assert((_srv)); \	#define rpc_srv_execBLOBServer(_srv) \
if (!(_srv)->srv_kill && !(_srv)->srv_blob.kill) { \	do { assert((_srv)); \
pthread_create(&(_srv)->srv_blob.tid, NULL, \	if (!(_srv)->srv_kill && !(_srv)->srv_blob.kill) { \
(void()(void*)) \	pthread_create(&(_srv)->srv_blob.tid, NULL, \
rpc_srv_loopBLOBServer, (_srv)); \	(void()(void*)) rpc_srv_loopBLOBServer, (_srv)); \
pthread_detach((_srv)->srv_blob.tid); \	pthread_detach((_srv)->srv_blob.tid); \
} \	} \
} while (0)	} while (0)

/*	/*
	* rpc_srv_initServer2() - Init & create layer2 RPC Server
	*
	* @InstID = Instance for authentication & recognition
	* @concurentClients = Concurent clients at same time to this server
	* @netBuf = Network buffer length (min:512 bytes), if =0 == BUFSIZ (also meaning max RPC packet)
	* @csIface = Interface name for bind server, if NULL first interface on host
	* return: NULL == error or !=NULL bind and created RPC server instance
	*/
	rpc_srv_t *rpc_srv_initServer2(u_char InstID, int concurentClients, int netBuf,
	const char *csIface);

	/*
* rpc_srv_registerCall() - Register call to RPC server	* rpc_srv_registerCall() - Register call to RPC server
*	*
* @srv = RPC Server instance	* @srv = RPC Server instance
Line 627 int rpc_pkt_Request(ait_val_t * __restrict pkt, rpc_se	Line 654 int rpc_pkt_Request(ait_val_t * __restrict pkt, rpc_se
* rpc_pkt_Replay() - Decode RPC Replay packet	* rpc_pkt_Replay() - Decode RPC Replay packet
*	*
* @pkt = Packet buffer	* @pkt = Packet buffer
* @sess = RPC session info	* @sess = RPC session info, if =NULL don't check session
* @tag = Function tag	* @tag = Function tag
* @vars = Function argument array of values, may be NULL	* @vars = Function argument array of values, may be NULL
* @nocrc = Without CRC calculation	* @nocrc = Without CRC calculation
Line 678 rpc_cli_t rpc_cli_openBLOBClient(rpc_cli_t __restri	Line 705 rpc_cli_t rpc_cli_openBLOBClient(rpc_cli_t __restri
* return: none	* return: none
*/	*/
void rpc_cli_closeBLOBClient(rpc_cli_t ** __restrict cli);	void rpc_cli_closeBLOBClient(rpc_cli_t ** __restrict cli);


	/*
	* rpc_cli_openClient2() - Connect to layer2 RPC Server
	*
	* @InstID = InstID for RPC session request
	* @netBuf = Network buffer length (min:512 bytes), if =0 == BUFSIZ (also meaning max RPC packet)
	* @csIface = Interface name for bind client, if NULL first interface on host
	* @csHost = Host ethernet address
	* return: NULL == error or !=NULL connection to RPC server established
	*/
	rpc_cli_t *rpc_cli_openClient2(u_char InstID, int netBuf,
	const char csIface, const char csHost);
	/*
	* rpc_cli_closeClient2() - Close layer2 connection to RPC server and free resources
	*
	* @cli = RPC Client session
	* return: none
	*/
	void rpc_cli_closeClient2(rpc_cli_t ** __restrict cli);


#endif	#endif

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>

Removed from v.1.24
changed lines
	Added in v.1.25.2.1