libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

version 1.21.2.3, 2013/11/15 00:21:46	version 1.21.2.5, 2013/11/15 09:05:19
Line 448 txUDPPacket(sched_task_t *task)	Line 448 txUDPPacket(sched_task_t *task)
rpc_func_t *f = NULL;	rpc_func_t *f = NULL;
u_char *buf = AIT_GET_BUF(&c->cli_buf);	u_char *buf = AIT_GET_BUF(&c->cli_buf);
struct tagRPCCall rpc = (struct tagRPCCall) buf;	struct tagRPCCall rpc = (struct tagRPCCall) buf;
int ret, wlen = sizeof(struct tagRPCCall);	int ret, estlen, wlen = sizeof(struct tagRPCCall);
struct timespec ts = { DEF_RPC_TIMEOUT, 0 };	struct timespec ts = { DEF_RPC_TIMEOUT, 0 };
struct pollfd pfd;	struct pollfd pfd;

Line 464 txUDPPacket(sched_task_t *task)	Line 464 txUDPPacket(sched_task_t *task)
rpc->call_rep.ret = RPC_ERROR(-1);	rpc->call_rep.ret = RPC_ERROR(-1);
rpc->call_rep.eno = RPC_ERROR(rpc_Errno);	rpc->call_rep.eno = RPC_ERROR(rpc_Errno);
} else {	} else {
	/* calc estimated length */
	estlen = ait_resideVars(RPC_RETVARS(c)) + wlen;
	if (estlen > AIT_LEN(&c->cli_buf))
	AIT_RE_BUF(&c->cli_buf, estlen);
	buf = AIT_GET_BUF(&c->cli_buf);
	rpc = (struct tagRPCCall*) buf;

rpc->call_argc = htons(array_Size(RPC_RETVARS(c)));	rpc->call_argc = htons(array_Size(RPC_RETVARS(c)));
/* Go Encapsulate variables */	/* Go Encapsulate variables */
ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen,	ret = ait_vars2buffer(buf + wlen, AIT_LEN(&c->cli_buf) - wlen,