--- libaitrpc/src/srv.c	2013/11/15 09:55:53	1.22
+++ libaitrpc/src/srv.c	2014/01/28 14:05:43	1.23
@@ -3,7 +3,7 @@
 *  by Michael Pounov <misho@openbsd-bg.org>
 *
 * $Author: misho $
-* $Id: srv.c,v 1.22 2013/11/15 09:55:53 misho Exp $
+* $Id: srv.c,v 1.23 2014/01/28 14:05:43 misho Exp $
 *
 **************************************************************************
 The ELWIX and AITNET software is distributed under the following
@@ -12,7 +12,7 @@ terms:
 All of the documentation and software included in the ELWIX and AITNET
 Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org>
 
-Copyright 2004, 2005, 2006, 2007, 2008, 2009, 2010, 2011, 2012, 2013
+Copyright 2004 - 2014
 	by Michael Pounov <misho@elwix.org>.  All rights reserved.
 
 Redistribution and use in source and binary forms, with or without
@@ -66,7 +66,11 @@ static sched_task_func_t cbProto[SOCK_RAW + 1][4] = {
 	{ NULL, NULL, NULL, NULL }				/* SOCK_RAW */
 };
 
+/* Global Signal Argument when kqueue support disabled */
 
+static volatile uintptr_t _glSigArg = 0;
+
+
 void
 rpc_freeCli(rpc_cli_t * __restrict c)
 {
@@ -760,7 +764,8 @@ end:
 static void *
 flushBLOB(sched_task_t *task)
 {
-	rpc_srv_t *srv = TASK_ARG(task);
+	uintptr_t sigArg = atomic_load_acq_ptr(&_glSigArg);
+	rpc_srv_t *srv = sigArg ? (void*) sigArg : TASK_ARG(task);
 	rpc_blob_t *b, *tmp;
 
 	TAILQ_FOREACH_SAFE(b, &srv->srv_blob.blobs, blob_node, tmp) {
@@ -770,7 +775,17 @@ flushBLOB(sched_task_t *task)
 		e_free(b);
 	}
 
-	schedSignalSelf(task);
+	if (!schedSignalSelf(task)) {
+		/* disabled kqueue support in libaitsched */
+		struct sigaction sa;
+
+		memset(&sa, 0, sizeof sa);
+		sigemptyset(&sa.sa_mask);
+		sa.sa_handler = (void (*)(int)) flushBLOB;
+		sa.sa_flags = SA_RESTART | SA_RESETHAND;
+		sigaction(SIGFBLOB, &sa, NULL);
+	}
+
 	return NULL;
 }
 
@@ -984,7 +999,19 @@ rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv)
 		return -1;
 	}
 
-	schedSignal(srv->srv_blob.root, flushBLOB, srv, SIGFBLOB, NULL, 0);
+	if (!schedSignal(srv->srv_blob.root, flushBLOB, srv, SIGFBLOB, NULL, 0)) {
+		/* disabled kqueue support in libaitsched */
+		struct sigaction sa;
+
+		atomic_store_rel_ptr(&_glSigArg, (uintptr_t) srv);
+
+		memset(&sa, 0, sizeof sa);
+		sigemptyset(&sa.sa_mask);
+		sa.sa_handler = (void (*)(int)) flushBLOB;
+		sa.sa_flags = SA_RESTART | SA_RESETHAND;
+		sigaction(SIGFBLOB, &sa, NULL);
+	}
+
 	if (!schedRead(srv->srv_blob.root, acceptBLOBClients, srv, 
 				srv->srv_blob.server.cli_sock, NULL, 0)) {
 		rpc_SetErr(sched_GetErrno(), "%s", sched_GetError());