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.1.1.1.2.11 and 1.1.1.1.2.19

version 1.1.1.1.2.11, 2010/06/24 15:01:19	version 1.1.1.1.2.19, 2010/07/08 07:32:53
Line 28	Line 28
#define CALL_BLOBSHUTDOWN "rpcBLOBServerShutdown"	#define CALL_BLOBSHUTDOWN "rpcBLOBServerShutdown"
#define CALL_BLOBCLIENTS "rpcBLOBServerClients"	#define CALL_BLOBCLIENTS "rpcBLOBServerClients"
#define CALL_BLOBVARS "rpcBLOBServerVars"	#define CALL_BLOBVARS "rpcBLOBServerVars"
	#define CALL_BLOBSTATE "rpcBLOBServerState"

#define CALL_SRVSHUTDOWN "rpcServerShutdown"	#define CALL_SRVSHUTDOWN "rpcServerShutdown"
#define CALL_SRVCLIENTS "rpcServerClients"	#define CALL_SRVCLIENTS "rpcServerClients"
Line 60 typedef struct {	Line 61 typedef struct {
union {	union {
uint8_t *buffer;	uint8_t *buffer;
int8_t *string;	int8_t *string;
void *blob;	uint32_t blob;
size_t size;	size_t size;
off_t offset;	off_t offset;
time_t datetime;	time_t datetime;
Line 109 typedef struct {	Line 110 typedef struct {
val->val_type = string; val->val_len = strlen(v) + 1; \	val->val_type = string; val->val_len = strlen(v) + 1; \
} } while (0)	} } while (0)
#define RPC_SET_BLOB(vl, v, l) do { rpc_val_t *val = (vl); assert(val); val->val_type = blob; \	#define RPC_SET_BLOB(vl, v, l) do { rpc_val_t *val = (vl); assert(val); val->val_type = blob; \
val->val.blob = (void*) v; val->val_len = l; } while (0)	val->val.blob = v; val->val_len = l; } while (0)
	#define RPC_SET_BLOB2(vl, b) do { rpc_val_t *val = (vl); assert(val); assert(b); val->val_type = blob; \
	val->val.blob = b->blob_var; val->val_len = b->blob_len; } while (0)
#define RPC_SET_SIZE(vl, v) do { rpc_val_t *val = (vl); assert(val); val->val_type = size; val->val.size = v; \	#define RPC_SET_SIZE(vl, v) do { rpc_val_t *val = (vl); assert(val); val->val_type = size; val->val.size = v; \
val->val_len = sizeof(size_t); } while (0)	val->val_len = sizeof(size_t); } while (0)
#define RPC_SET_OFF(vl, v) do { rpc_val_t *val = (vl); assert(val); val->val_type = offset; val->val.offset = v; \	#define RPC_SET_OFF(vl, v) do { rpc_val_t *val = (vl); assert(val); val->val_type = offset; val->val.offset = v; \
Line 150 typedef struct {	Line 153 typedef struct {
} while (0)	} while (0)


#define RPC_CALLBACK_CHK_NUM_ARGS(f, n) do { \	#define RPC_CALLBACK_CHK_RETARGS(f, n) do { \
if (f->func_args != n) { \	if (f->func_args != n) { \
rpc_SetErr(22, "Error:: different number of arguments!\n"); \	rpc_SetErr(22, "Error:: different number of arguments!\n"); \
return -1; \	return -1; \
Line 216 struct tagBLOBHdr {	Line 219 struct tagBLOBHdr {
rpc_sess_t hdr_session;	rpc_sess_t hdr_session;
uint8_t hdr_cmd;	uint8_t hdr_cmd;
uint32_t hdr_var;	uint32_t hdr_var;
uint32_t hdr_seq;
uint32_t hdr_len;	uint32_t hdr_len;
	uint32_t hdr_ret;
} __packed;	} __packed;

/* Network RPC client & server elements */	/* Network RPC client & server elements */
Line 346 inline rpc_blob_t rpc_srv_getBLOB(rpc_srv_t __restr	Line 349 inline rpc_blob_t rpc_srv_getBLOB(rpc_srv_t __restr
* @srv = RPC Server instance	* @srv = RPC Server instance
* @csModule = Module name, if NULL self binary	* @csModule = Module name, if NULL self binary
* @csFunc = Function name	* @csFunc = Function name
* @args = Number of function arguments	* @args = Number of return function arguments, use for restriction case!
* return: -1 error or 0 register ok	* return: -1 error or 0 register ok
*/	*/
int rpc_srv_registerCall(rpc_srv_t * __restrict srv, const char csModule, const char csFunc,	int rpc_srv_registerCall(rpc_srv_t * __restrict srv, const char csModule, const char csFunc,
Line 463 inline int rpc_srv_blobFree(rpc_srv_t * __restrict srv	Line 466 inline int rpc_srv_blobFree(rpc_srv_t * __restrict srv
* rpc_srv_registerBLOB() Register new BLOB to server	* rpc_srv_registerBLOB() Register new BLOB to server
* @srv = RPC Server instance	* @srv = RPC Server instance
* @len = BLOB length	* @len = BLOB length
* return: -1 error or 0 register ok	* return: NULL error or new registered BLOB
*/	*/
rpc_blob_t rpc_srv_registerBLOB(rpc_srv_t __restrict srv, size_t len);	rpc_blob_t rpc_srv_registerBLOB(rpc_srv_t __restrict srv, size_t len);
/*	/*
Line 489 int rpc_srv_sendBLOB(rpc_cli_t * __restrict cli, rpc_b	Line 492 int rpc_srv_sendBLOB(rpc_cli_t * __restrict cli, rpc_b
*/	*/
int rpc_srv_recvBLOB(rpc_cli_t * __restrict cli, rpc_blob_t * __restrict blob);	int rpc_srv_recvBLOB(rpc_cli_t * __restrict cli, rpc_blob_t * __restrict blob);

	/*
	* rpc_cli_sendBLOB() Send BLOB to server
	* @cli = Client instance
	* @var = BLOB variable
	* @data = BLOB data
	* return: -1 error, 0 ok, 1 remote error
	*/
	int rpc_cli_sendBLOB(rpc_cli_t * __restrict cli, rpc_val_t * __restrict var, void * __restrict data);
	/*
	* rpc_cli_recvBLOB() Receive BLOB from server
	* @cli = Client instance
	* @var = BLOB variable
	* @data = BLOB data, must be free after use!
	* return: -1 error, 0 ok, 1 remote error
	*/
	int rpc_cli_recvBLOB(rpc_cli_t * __restrict cli, rpc_val_t * __restrict var, void ** data);


/* RPC Client side functions */	/* RPC Client side functions */

/*	/*
Line 529 int rpc_cli_execCall(rpc_cli_t cli, const char csMod	Line 549 int rpc_cli_execCall(rpc_cli_t cli, const char csMod
* return: none	* return: none
*/	*/
inline void rpc_cli_freeVals(int args, rpc_val_t *vals);	inline void rpc_cli_freeVals(int args, rpc_val_t *vals);


	/*
	* rpc_cli_openBLOBClient() Connect to BLOB Server
	* @rpccli = RPC Client session
	* @Port = Port for bind server, if Port == 0 default port is selected
	* return: NULL == error or !=NULL connection to BLOB server established
	*/
	rpc_cli_t rpc_cli_openBLOBClient(rpc_cli_t __restrict rpccli, u_short Port);
	/*
	* rpc_cli_closeBLOBClient() Close connection to BLOB server and free resources
	* @cli = BLOB Client session
	* return: none
	*/
	void rpc_cli_closeBLOBClient(rpc_cli_t * __restrict cli);


#endif	#endif

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

Removed from v.1.1.1.1.2.11
changed lines
	Added in v.1.1.1.1.2.19