libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

version 1.17.4.5, 2013/08/21 12:59:12	version 1.17.4.7, 2013/08/21 13:02:33
Line 494 rxUDPPacket(sched_task_t *task)	Line 494 rxUDPPacket(sched_task_t *task)
socklen_t salen;	socklen_t salen;
struct timespec ts = { DEF_RPC_TIMEOUT, 0 };	struct timespec ts = { DEF_RPC_TIMEOUT, 0 };

memset(buf, 0, AIT_LEN(bufz));
memset(&rpcbuf, 0, sizeof rpcbuf);	memset(&rpcbuf, 0, sizeof rpcbuf);

/* receive connect packet */	/* receive connect packet */
Line 609 static void *	Line 608 static void *
txBLOB(sched_task_t *task)	txBLOB(sched_task_t *task)
{	{
rpc_cli_t *c = TASK_ARG(task);	rpc_cli_t *c = TASK_ARG(task);
u_char *buf = AIT_GET_BUF(&c->cli_buf);	u_char buf = AIT_GET_BUF(array(c->cli_buf, 0, ait_val_t));
int wlen = sizeof(struct tagBLOBHdr);	int wlen = sizeof(struct tagBLOBHdr);

/* send reply */	/* send reply */
Line 701 rxBLOB(sched_task_t *task)	Line 700 rxBLOB(sched_task_t *task)
}	}

end:	end:
memcpy(AIT_ADDR(&c->cli_buf), &blob, sizeof blob);	memcpy(AIT_ADDR(array(c->cli_buf, 0, ait_val_t*)), &blob, sizeof blob);
schedWrite(TASK_ROOT(task), txBLOB, TASK_ARG(task), TASK_FD(task), NULL, 0);	schedWrite(TASK_ROOT(task), txBLOB, TASK_ARG(task), TASK_FD(task), NULL, 0);
schedReadSelf(task);	schedReadSelf(task);
return NULL;	return NULL;