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.16.2.6 and 1.17.6.2

version 1.16.2.6, 2013/07/16 12:35:25	version 1.17.6.2, 2013/08/22 12:22:25
Line 172 txPacket(sched_task_t *task)	Line 172 txPacket(sched_task_t *task)
f = rpc_srv_getCall(s, ntohs(rpc->call_tag));	f = rpc_srv_getCall(s, ntohs(rpc->call_tag));
if (!f) {	if (!f) {
rpc_SetErr(EPROGUNAVAIL, "Function not found at RPC server");	rpc_SetErr(EPROGUNAVAIL, "Function not found at RPC server");

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);
Line 191 txPacket(sched_task_t *task)	Line 192 txPacket(sched_task_t *task)
}	}
}	}

rpc->call_len = htons(wlen);	rpc->call_len = htonl(wlen);

#if 0	#if 0
/* calculate CRC */	/* calculate CRC */
Line 217 execCall(sched_task_t *task)	Line 218 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 = AIT_GET_BUF(&c->cli_buf) + TASK_VAL(task);	u_char *buf = AIT_GET_BUF(&c->cli_buf);
struct tagRPCCall rpc = (struct tagRPCCall) buf;	struct tagRPCCall rpc = (struct tagRPCCall) buf;
int argc = ntohs(rpc->call_argc);	int argc = ntohs(rpc->call_argc);

/* Go decapsulate variables ... */	/* Go decapsulate variables ... */
if (argc) {	if (argc) {
arr = ait_buffer2vars(buf + sizeof(struct tagRPCCall),	arr = ait_buffer2vars(buf + sizeof(struct tagRPCCall),
AIT_LEN(&c->cli_buf) - TASK_VAL(task) - sizeof(struct tagRPCCall),	AIT_LEN(&c->cli_buf) - sizeof(struct tagRPCCall), argc, 42);
argc, 42);
if (!arr) {	if (!arr) {
rpc_SetErr(ERPCMISMATCH, "#%d - %s", elwix_GetErrno(), elwix_GetError());	rpc_SetErr(ERPCMISMATCH, "#%d - %s", elwix_GetErrno(), elwix_GetError());

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);
Line 238 execCall(sched_task_t *task)	Line 239 execCall(sched_task_t *task)

if (!(f = rpc_srv_getCall(s, ntohs(rpc->call_tag)))) {	if (!(f = rpc_srv_getCall(s, ntohs(rpc->call_tag)))) {
rpc_SetErr(EPROGUNAVAIL, "Function not found at RPC server");	rpc_SetErr(EPROGUNAVAIL, "Function not found at RPC server");

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);
Line 303 rxPacket(sched_task_t *task)	Line 305 rxPacket(sched_task_t *task)
} else	} else
rpc = (struct tagRPCCall*) (buf + off);	rpc = (struct tagRPCCall*) (buf + off);

len = ntohs(rpc->call_len);	len = ntohl(rpc->call_len);
rlen -= len;	rlen -= len;

/* check RPC packet lengths */	/* check RPC packet lengths */
Line 331 rxPacket(sched_task_t *task)	Line 333 rxPacket(sched_task_t *task)
/* check RPC packet session info */	/* check RPC packet session info */
if (rpc_chkPktSession(&rpc->call_session, &s->srv_session)) {	if (rpc_chkPktSession(&rpc->call_session, &s->srv_session)) {
rpc_SetErr(ERPCMISMATCH, "Get invalid RPC session");	rpc_SetErr(ERPCMISMATCH, "Get invalid RPC session");

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(errno);	rpc->call_rep.eno = RPC_ERROR(errno);
} else {	} else {
/* execute RPC call */	/* execute RPC call */
schedEvent(TASK_ROOT(task), execCall, TASK_ARG(task), off, NULL, 0);	schedEvent(TASK_ROOT(task), execCall, TASK_ARG(task),
	(int) noreply, rpc, len);
}	}

/* send RPC reply */	/* send RPC reply */
Line 422 txUDPPacket(sched_task_t *task)	Line 426 txUDPPacket(sched_task_t *task)
}	}
}	}

rpc->call_len = htons(wlen);	rpc->call_len = htonl(wlen);

/* calculate CRC */	/* calculate CRC */
rpc->call_crc ^= rpc->call_crc;	rpc->call_crc ^= rpc->call_crc;
Line 480 rxUDPPacket(sched_task_t *task)	Line 484 rxUDPPacket(sched_task_t *task)
} else	} else
rpc = (struct tagRPCCall*) (AIT_GET_BUF(&c->cli_buf) + off);	rpc = (struct tagRPCCall*) (AIT_GET_BUF(&c->cli_buf) + off);

len = ntohs(rpc->call_len);	len = ntohl(rpc->call_len);
rlen -= len;	rlen -= len;

/* check RPC packet lengths */	/* check RPC packet lengths */
Line 506 rxUDPPacket(sched_task_t *task)	Line 510 rxUDPPacket(sched_task_t *task)
/* check RPC packet session info */	/* check RPC packet session info */
if (rpc_chkPktSession(&rpc->call_session, &srv->srv_session)) {	if (rpc_chkPktSession(&rpc->call_session, &srv->srv_session)) {
rpc_SetErr(ERPCMISMATCH, "Get invalid RPC session");	rpc_SetErr(ERPCMISMATCH, "Get invalid RPC session");

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(errno);	rpc->call_rep.eno = RPC_ERROR(errno);
} else {	} else {
/* execute RPC call */	/* execute RPC call */
schedEvent(TASK_ROOT(task), execCall, c, off, NULL, 0);	schedEvent(TASK_ROOT(task), execCall, c,
	(int) noreply, rpc, len);
}	}

/* send RPC reply */	/* send RPC reply */
Line 665 flushBLOB(sched_task_t *task)	Line 671 flushBLOB(sched_task_t *task)
{	{
rpc_srv_t *srv = TASK_ARG(task);	rpc_srv_t *srv = TASK_ARG(task);
rpc_blob_t b, tmp;	rpc_blob_t b, tmp;

printf("!signal 99\n");

TAILQ_FOREACH_SAFE(b, &srv->srv_blob.blobs, blob_node, tmp) {	TAILQ_FOREACH_SAFE(b, &srv->srv_blob.blobs, blob_node, tmp) {
TAILQ_REMOVE(&srv->srv_blob.blobs, b, blob_node);	TAILQ_REMOVE(&srv->srv_blob.blobs, b, blob_node);

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

Removed from v.1.16.2.6
changed lines
	Added in v.1.17.6.2