--- libaitrpc/inc/aitrpc.h	2010/06/23 07:50:01	1.1.1.1.2.4
+++ libaitrpc/inc/aitrpc.h	2010/06/23 15:07:15	1.1.1.1.2.6
@@ -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.6 2010/06/23 15:07:15 misho Exp $
 *
 *************************************************************************/
 #ifndef __AITRPC_H
@@ -27,6 +27,10 @@
 
 /* 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 +48,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 +217,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 +237,41 @@ 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 {
+	rpc_cli_t	*blob_cli;	// from RPC client
+
+	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;
 
 
@@ -269,6 +314,34 @@ void rpc_srv_endServer(rpc_srv_t * __restrict srv);
  * return: -1 error or 0 ok, infinite loop ...
  */
 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