libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

Diff for /libaitrpc/src/srv.c between versions 1.7.2.2 and 1.7.2.3

version 1.7.2.2, 2012/03/28 13:37:13	version 1.7.2.3, 2012/03/29 00:40:59
Line 83 txPacket(sched_task_t *task)	Line 83 txPacket(sched_task_t *task)
}	}
}	}

	rpc->call_len = htons(wlen);

/* calculate CRC */	/* calculate CRC */
rpc->call_crc ^= rpc->call_crc;	rpc->call_crc ^= rpc->call_crc;
rpc->call_crc = htons(crcFletcher16((u_short*) buf, io_align(wlen, 1) / 2));	rpc->call_crc = htons(crcFletcher16((u_short*) buf, io_align(wlen, 1) / 2));
Line 107 execCall(sched_task_t *task)	Line 109 execCall(sched_task_t *task)
rpc_srv_t *s = c->cli_parent;	rpc_srv_t *s = c->cli_parent;
rpc_func_t *f = NULL;	rpc_func_t *f = NULL;
array_t *arr = NULL;	array_t *arr = NULL;
u_char *buf = TASK_DATA(task);	u_char *buf = TASK_DATA(task) + TASK_VAL(task);
struct tagRPCCall rpc = (struct tagRPCCall) buf;	struct tagRPCCall rpc = (struct tagRPCCall) buf;
int argc = ntohs(rpc->call_argc);	int argc = ntohs(rpc->call_argc);

Line 116 execCall(sched_task_t *task)	Line 118 execCall(sched_task_t *task)
/* Go decapsulate variables ... */	/* Go decapsulate variables ... */
if (argc) {	if (argc) {
arr = io_buffer2vars(buf + sizeof(struct tagRPCCall),	arr = io_buffer2vars(buf + sizeof(struct tagRPCCall),
TASK_DATLEN(task) - sizeof(struct tagRPCCall), argc, 1);	TASK_DATLEN(task) - TASK_VAL(task) - sizeof(struct tagRPCCall),
	argc, 1);
if (!arr) {	if (!arr) {
rpc_SetErr(ERPCMISMATCH, "#%d - %s", io_GetErrno(), io_GetError());	rpc_SetErr(ERPCMISMATCH, "#%d - %s", io_GetErrno(), io_GetError());
rpc->call_argc ^= rpc->call_argc;	rpc->call_argc ^= rpc->call_argc;
Line 163 rxPacket(sched_task_t *task)	Line 166 rxPacket(sched_task_t *task)
rpc_cli_t *c = TASK_ARG(task);	rpc_cli_t *c = TASK_ARG(task);
rpc_srv_t *s = c->cli_parent;	rpc_srv_t *s = c->cli_parent;
u_char *buf = TASK_DATA(task);	u_char *buf = TASK_DATA(task);
int rlen;	int rlen, noreply;
u_short crc;	u_short crc, off = 0;
struct tagRPCCall *rpc;	struct tagRPCCall *rpc;
struct timespec ts;	struct timespec ts;

Line 182 rxPacket(sched_task_t *task)	Line 185 rxPacket(sched_task_t *task)
} else	} else
ioDEBUG(RPC_DEBUG_LEVEL, "Readed %d bytes", rlen);	ioDEBUG(RPC_DEBUG_LEVEL, "Readed %d bytes", rlen);

if (rlen < sizeof(struct tagRPCCall)) {	do {
rpc_SetErr(ERPCMISMATCH, "Too short RPC packet");	if (rlen < sizeof(struct tagRPCCall)) {
	rpc_SetErr(ERPCMISMATCH, "Too short RPC packet");

schedRead(TASK_ROOT(task), rxPacket, TASK_ARG(task), TASK_FD(task),	schedRead(TASK_ROOT(task), rxPacket, TASK_ARG(task), TASK_FD(task),
TASK_DATA(task), TASK_DATLEN(task));	TASK_DATA(task), TASK_DATLEN(task));
return NULL;	return NULL;
} else	} else
rpc = (struct tagRPCCall*) buf;	rpc = (struct tagRPCCall*) (buf + off);

/* check integrity of packet */	rlen -= ntohs(rpc->call_len);
crc = ntohs(rpc->call_crc);
rpc->call_crc ^= rpc->call_crc;
if (crc != crcFletcher16((u_short*) buf, io_align(rlen, 1) / 2)) {
rpc_SetErr(ERPCMISMATCH, "Bad CRC RPC packet");

schedRead(TASK_ROOT(task), rxPacket, TASK_ARG(task), TASK_FD(task),	/* check integrity of packet */
TASK_DATA(task), TASK_DATLEN(task));	crc = ntohs(rpc->call_crc);
return NULL;	rpc->call_crc ^= rpc->call_crc;
}	if (crc != crcFletcher16((u_short*) (buf + off),
	io_align(ntohs(rpc->call_len), 1) / 2)) {
	rpc_SetErr(ERPCMISMATCH, "Bad CRC RPC packet");

/* check RPC packet session info */	off += ntohs(rpc->call_len);
if (rpc_chkPktSession(&rpc->call_session, &s->srv_session)) {	if (rlen < 1)
rpc_SetErr(ERPCMISMATCH, "Get invalid RPC session");	break;
rpc->call_argc ^= rpc->call_argc;	else
rpc->call_rep.ret = RPC_ERROR(-1);	continue;
rpc->call_rep.eno = RPC_ERROR(errno);	}
goto end;
} else {
/* change socket timeout from last packet */
ts.tv_sec = rpc->call_session.sess_timeout;
ts.tv_nsec = 0;
schedPolling(TASK_ROOT(task), &ts, NULL);
}

/* execute RPC call */	noreply = rpc->call_req.flags & RPC_NOREPLY;
schedEvent(TASK_ROOT(task), execCall, TASK_ARG(task), 0,
TASK_DATA(task), TASK_DATLEN(task));

end:	/* check RPC packet session info */
/* send RPC reply */	if (rpc_chkPktSession(&rpc->call_session, &s->srv_session)) {
if (!(rpc->call_req.flags & RPC_NOREPLY))	rpc_SetErr(ERPCMISMATCH, "Get invalid RPC session");
schedWrite(TASK_ROOT(task), txPacket, TASK_ARG(task), TASK_FD(task),	rpc->call_argc ^= rpc->call_argc;
TASK_DATA(task), TASK_DATLEN(task));	rpc->call_rep.ret = RPC_ERROR(-1);
	rpc->call_rep.eno = RPC_ERROR(errno);
	} else {
	/* change socket timeout from last packet */
	ts.tv_sec = rpc->call_session.sess_timeout;
	ts.tv_nsec = 0;
	schedPolling(TASK_ROOT(task), &ts, NULL);

	/* execute RPC call */
	schedEvent(TASK_ROOT(task), execCall, TASK_ARG(task), off,
	TASK_DATA(task), TASK_DATLEN(task));
	}

	/* send RPC reply */
	if (!noreply)
	schedWrite(TASK_ROOT(task), txPacket, TASK_ARG(task), TASK_FD(task),
	buf + off, TASK_DATLEN(task) - off);

	off += ntohs(rpc->call_len);
	} while (rlen > 0);

/* lets get next packet */	/* lets get next packet */
schedRead(TASK_ROOT(task), rxPacket, TASK_ARG(task), TASK_FD(task),	schedRead(TASK_ROOT(task), rxPacket, TASK_ARG(task), TASK_FD(task),
TASK_DATA(task), TASK_DATLEN(task));	TASK_DATA(task), TASK_DATLEN(task));

FreeBSD-CVSweb <freebsd-cvsweb@FreeBSD.org>

Removed from v.1.7.2.2
changed lines
	Added in v.1.7.2.3