--- libaitrpc/inc/aitrpc.h	2010/06/23 07:50:01	1.1.1.1.2.4
+++ libaitrpc/inc/aitrpc.h	2010/06/23 16:23:31	1.1.1.1.2.7
@@ -3,7 +3,7 @@
 *  by Michael Pounov <misho@openbsd-bg.org>
 *
 * $Author: misho $
-* $Id: aitrpc.h,v 1.1.1.1.2.4 2010/06/23 07:50:01 misho Exp $
+* $Id: aitrpc.h,v 1.1.1.1.2.7 2010/06/23 16:23:31 misho Exp $
 *
 *************************************************************************/
 #ifndef __AITRPC_H
@@ -19,14 +19,16 @@
 #include <sys/socket.h>
 
 
-#define STRSIZ			256
-
 #define RPC_VERSION		1
 #define RPC_DEFPORT		2611
 
 
 /* RPC builtin registed calls */
 
+#define CALL_BLOBSHUTDOWN	"rpcBLOBServerShutdown"
+#define CALL_BLOBCLIENTS	"rpcBLOBServerClients"
+#define CALL_BLOBVARS		"rpcBLOBServerVars"
+
 #define CALL_SRVSHUTDOWN	"rpcServerShutdown"
 #define CALL_SRVCLIENTS		"rpcServerClients"
 #define CALL_SRVCALLS		"rpcServerCalls"
@@ -44,6 +46,11 @@ typedef enum {
 	i8, i16, i32, i64		// integers ...
 } rpc_type_t;
 
+typedef enum {
+	disable, enable,
+	get, set, unset
+} cmd_type_t;
+
 /* RPC value */
 
 typedef struct {
@@ -208,6 +215,16 @@ struct tagRPCRet {
 	uint8_t		ret_argc;
 } __packed;
 
+/* Network BLOB packet - Header */
+
+struct tagBLOBHdr {
+	rpc_sess_t	hdr_session;
+	uint8_t		hdr_cmd;
+	uint32_t	hdr_var;
+	uint32_t	hdr_seq;
+	uint32_t	hdr_len;
+} __packed;
+
 /* Network RPC client & server elements */
 
 typedef struct {
@@ -218,15 +235,39 @@ typedef struct {
 	void		*cli_parent;	// pointer to parent rpc_srv_t for server or to rpc_sess_t for client
 } rpc_cli_t;
 
+
+// BLOB registration element!
+typedef struct tagBLOB {
+	uint32_t	blob_var;
+
+	size_t		blob_len;	// size of allocated BLOB data
+	void		*blob_data;	// BLOB data
+
+	struct tagBLOB	*blob_next;
+} rpc_blob_t;
+
 typedef struct {
+	rpc_sess_t	srv_session;	// RPC session registration info
 	int		srv_numcli;	// maximum concurent client connections
-	rpc_cli_t	srv_server;	// server socket
 
-	rpc_sess_t	srv_session;	// RPC session registration info
+	rpc_cli_t	srv_server;	// RPC server socket
+	rpc_cli_t	*srv_clients;	// connected rpc client sockets
 
-	rpc_cli_t	*srv_clients;	// connected client sockets
-
 	rpc_func_t	*srv_funcs;	// registered functions list
+
+	pthread_mutex_t	srv_mtx;
+
+	struct {
+		int		state;		// BLOB server state: ==0 disable | !=0 enable
+		char		dir[UCHAR_MAX + 1];
+
+		rpc_cli_t	server;		// BLOB server socket
+		rpc_cli_t	*clients;	// connected blob client sockets
+
+		rpc_blob_t	*blobs;		// registered blob variables list
+
+		pthread_mutex_t	mtx;
+	} 		srv_blob;
 } rpc_srv_t;
 
 
@@ -271,6 +312,34 @@ void rpc_srv_endServer(rpc_srv_t * __restrict srv);
 int rpc_srv_execServer(rpc_srv_t * __restrict srv);
 
 /*
+ * rpc_srv_initBLOBServer() Init & create BLOB Server
+ * @Port = Port for bind server, if Port == 0 default port is selected
+ * @diskDir = Disk place for BLOB file objects
+ * return: -1 == error or 0 bind and created BLOB server instance
+ */
+int rpc_srv_initBLOBServer(rpc_srv_t * __restrict srv, u_short Port, const char *diskDir);
+/*
+ * rpc_srv_endBLOBServer() Destroy BLOB server, close all opened sockets and free resources
+ * @srv = RPC Server instance
+ * return: none
+ */
+void rpc_srv_endBLOBServer(rpc_srv_t * __restrict srv);
+/*
+ * rpc_srv_execBLOBServer() Execute Main BLOB server loop and wait for clients requests
+ * @srv = RPC Server instance
+ * return: -1 error or 0 ok, infinite loop ...
+ */
+int rpc_srv_execBLOBServer(rpc_srv_t * __restrict srv);
+
+/*
+ * rpc_srv_getBLOB() Get registered BLOB 
+ * @srv = RPC Server instance
+ * @var = hash for variable
+ * return: NULL not found, !=NULL return blob var
+ */
+inline rpc_blob_t *rpc_srv_getBLOB(rpc_srv_t * __restrict srv, uint32_t var);
+
+/*
  * rpc_srv_registerCall() Register call to RPC server
  * @srv = RPC Server instance
  * @csModule = Module name, if NULL self binary
@@ -349,6 +418,28 @@ inline int rpc_srv_delValsCall(rpc_func_t * __restrict
  * return: -1 error, !=-1 Number of returned variables
  */
 inline int rpc_srv_getValsCall(rpc_func_t * __restrict call, rpc_val_t ** __restrict vals);
+
+
+/*
+ * rpc_srv_blobMap() Map blob to memory region 
+ * @srv = RPC Server instance
+ * @blob = Map to this BLOB element
+ * return: -1 error or 0 ok
+ */
+inline int rpc_srv_blobMap(rpc_srv_t * __restrict srv, rpc_blob_t * __restrict blob);
+/*
+ * rpc_srv_blobUnmap() Unmap blob memory region 
+ * @blob = Mapped BLOB element
+ * return: none
+ */
+inline void rpc_srv_blobUnmap(rpc_blob_t * __restrict blob);
+/*
+ * rpc_srv_blobFree() Free blob from disk & memory
+ * @srv = RPC Server instance
+ * @blob = Mapped BLOB element
+ * return: -1 error or 0 ok
+ */
+inline int rpc_srv_blobFree(rpc_srv_t * __restrict srv, rpc_blob_t * __restrict blob);
 
 
 /* RPC Client side functions */