libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

version 1.26.2.9, 2015/06/29 22:39:33	version 1.26.2.10, 2015/06/30 14:11:55
Line 313 rxPacket(sched_task_t *task)	Line 313 rxPacket(sched_task_t *task)
u_short crc;	u_short crc;
#endif	#endif
u_char *buf = AIT_GET_BUF(&c->cli_buf);	u_char *buf = AIT_GET_BUF(&c->cli_buf);
	u_char b[sizeof(struct tagRPCCall)];
struct tagRPCCall rpc = (struct tagRPCCall) buf;	struct tagRPCCall rpc = (struct tagRPCCall) buf;
#ifdef TCP_SESSION_TIMEOUT	#ifdef TCP_SESSION_TIMEOUT
struct timespec ts = { DEF_RPC_TIMEOUT, 0 };	struct timespec ts = { DEF_RPC_TIMEOUT, 0 };
Line 322 rxPacket(sched_task_t *task)	Line 323 rxPacket(sched_task_t *task)
TASK_ARG(task), ts, TASK_ARG(task), 0);	TASK_ARG(task), ts, TASK_ARG(task), 0);
#endif	#endif

	/* prepare rx */
	len = recv(TASK_FD(task), b, sizeof b, MSG_PEEK);
	if (len == sizeof b)
	rlen = ntohl(((struct tagRPCCall*) b)->call_len);

rlen = recv(TASK_FD(task), buf, rlen, 0);	rlen = recv(TASK_FD(task), buf, rlen, 0);
if (rlen == -1) {	if (rlen == -1) {
/* close connection */	/* close connection */
Line 613 txRAWPacket(sched_task_t *task)	Line 619 txRAWPacket(sched_task_t *task)
RPC_RETVARS(c));	RPC_RETVARS(c));
if (ret == -1) {	if (ret == -1) {
rpc_SetErr(EBADRPC, "Prepare RPC packet failed");	rpc_SetErr(EBADRPC, "Prepare RPC packet failed");

rpc->call_argc ^= rpc->call_argc;	rpc->call_argc ^= rpc->call_argc;
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);