--- libaitrpc/src/srv.c	2010/06/24 15:01:19	1.1.1.1.2.11
+++ libaitrpc/src/srv.c	2010/06/24 15:23:38	1.1.1.1.2.12
@@ -3,7 +3,7 @@
 *  by Michael Pounov <misho@openbsd-bg.org>
 *
 * $Author: misho $
-* $Id: srv.c,v 1.1.1.1.2.11 2010/06/24 15:01:19 misho Exp $
+* $Id: srv.c,v 1.1.1.1.2.12 2010/06/24 15:23:38 misho Exp $
 *
 *************************************************************************/
 #include "global.h"
@@ -14,13 +14,13 @@ rpc_srv_dispatchCall(void *arg)
 {
 	rpc_cli_t *c = arg;
 	rpc_srv_t *s;
-	rpc_val_t *vals, *v = NULL;
+	rpc_val_t *vals = NULL, *v = NULL;
 	rpc_func_t *f;
 	struct tagRPCCall *rpc;
 	struct tagRPCRet rrpc;
 	fd_set fds;
 	u_char buf[BUFSIZ], *data;
-	int ret, argc, Limit = 0;
+	int ret, argc = 0, Limit = 0;
 	register int i;
 
 	if (!arg) {
@@ -57,7 +57,7 @@ rpc_srv_dispatchCall(void *arg)
 		if (memcmp(&rpc->call_session, &s->srv_session, sizeof rpc->call_session)) {
 			rpc_SetErr(EINVAL, "Error:: get invalid RPC session ...\n");
 			ret = -5;
-			break;
+			goto makeReply;
 		}
 		// RPC is OK! Go decapsulate variables ...
 		if (rpc->call_argc) {
@@ -74,6 +74,12 @@ rpc_srv_dispatchCall(void *arg)
 						v[i].val.string = (int8_t*) data;
 						data += v[i].val_len + 1;
 						break;
+					case blob:
+						if (s->srv_blob.state == disable) {
+							rpc_SetErr(ENOTSUP, "Error:: BLOB server is disabled\n");
+							ret = -5;
+							goto makeReply;
+						}
 					default:
 						break;
 				}
@@ -91,6 +97,7 @@ rpc_srv_dispatchCall(void *arg)
 			else
 				argc = rpc_srv_getValsCall(f, &vals);
 
+makeReply:
 		memcpy(&rrpc.ret_session, &rpc->call_session, sizeof rrpc.ret_session);
 		rrpc.ret_tag = rpc->call_tag;
 		rrpc.ret_hash = rpc->call_hash;
@@ -131,6 +138,13 @@ rpc_srv_dispatchCall(void *arg)
 						data += vals[i].val_len + 1;
 						Limit += vals[i].val_len + 1;
 						break;
+					case blob:
+						if (s->srv_blob.state == disable) {
+							rpc_SetErr(ENOTSUP, "Error:: BLOB server is disabled\n");
+							rrpc.ret_retcode = ret = -5;
+							rrpc.ret_argc = 0;
+							break;
+						}
 					default:
 						break;
 				}
@@ -178,6 +192,12 @@ rpc_srv_dispatchVars(void *arg)
 
 	cx = -1;
 	do {
+		// check for disable service at this moment?
+		if (s->srv_blob.state == disable) {
+			ret = 0;
+			break;
+		}
+
 		FD_ZERO(&fds);
 		FD_SET(c->cli_sock, &fds);
 		ret = select(c->cli_sock + 1, &fds, NULL, NULL, NULL);
@@ -206,7 +226,7 @@ rpc_srv_dispatchVars(void *arg)
 				blob->hdr_seq != cx) {
 			rpc_SetErr(EINVAL, "Error:: get invalid BLOB session in seq=%d...\n", blob->hdr_seq);
 			ret = -5;
-			break;
+			goto makeReply;
 		}
 		// Go to proceed packet ...
 		switch (blob->hdr_cmd) {
@@ -245,6 +265,7 @@ rpc_srv_dispatchVars(void *arg)
 				ret = -7;
 		}
 
+makeReply:
 		// Replay to client!
 		blob->hdr_cmd = ret < 0 ? error : ok;
 		blob->hdr_seq = ret;
@@ -404,7 +425,7 @@ rpc_srv_execBLOBServer(rpc_srv_t * __restrict srv)
 	int ret;
 	struct timeval tv = { DEF_RPC_TIMEOUT, 0 };
 
-	if (!srv || !srv->srv_blob.state) {
+	if (!srv || srv->srv_blob.state == disable) {
 		rpc_SetErr(EINVAL, "Error:: Invalid parameter can`t start BLOB server ...\n");
 		return -1;
 	}