libaitrpc/src/srv.c - diff

Return to srv.c CVS log

Up to [ELWIX - Embedded LightWeight unIX -] / libaitrpc / src

version 1.27.2.1, 2015/07/02 23:06:09	version 1.27.2.2, 2015/07/02 23:21:06
Line 1167 end:	Line 1167 end:
static void *	static void *
flushBLOB(sched_task_t *task)	flushBLOB(sched_task_t *task)
{	{
	#ifndef atomic_load_acq_ptr
uintptr_t sigArg = atomic_load_acq_ptr(&_glSigArg);	uintptr_t sigArg = atomic_load_acq_ptr(&_glSigArg);
	#else
	uintptr_t sigArg = ((volatile uintptr_t) &_glSigArg);
	#endif
rpc_srv_t srv = sigArg ? (void) sigArg : TASK_ARG(task);	rpc_srv_t srv = sigArg ? (void) sigArg : TASK_ARG(task);
rpc_blob_t b, tmp;	rpc_blob_t b, tmp;

Line 1409 rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv)	Line 1413 rpc_srv_loopBLOBServer(rpc_srv_t * __restrict srv)
/* disabled kqueue support in libaitsched */	/* disabled kqueue support in libaitsched */
struct sigaction sa;	struct sigaction sa;

	#ifndef atomic_store_rel_ptr
atomic_store_rel_ptr(&_glSigArg, (uintptr_t) srv);	atomic_store_rel_ptr(&_glSigArg, (uintptr_t) srv);
	#else
	((volatile uintptr_t) &_glSigArg) = (uintptr_t) srv;
	#endif

memset(&sa, 0, sizeof sa);	memset(&sa, 0, sizeof sa);
sigemptyset(&sa.sa_mask);	sigemptyset(&sa.sa_mask);