--- libaitrpc/inc/aitrpc.h	2010/06/23 07:50:01	1.1.1.1.2.4
+++ libaitrpc/inc/aitrpc.h	2010/06/23 11:33:38	1.1.1.1.2.5
@@ -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.5 2010/06/23 11:33:38 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"
@@ -218,15 +222,38 @@ 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
+
+	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
+
+		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 +296,25 @@ 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
+ * return: -1 == error or 0 bind and created BLOB server instance
+ */
+int rpc_srv_initBLOBServer(rpc_srv_t * __restrict srv, u_short Port);
+/*
+ * 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_registerCall() Register call to RPC server