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.17.4.7 and 1.17.4.8

version 1.17.4.7, 2013/08/21 13:02:33	version 1.17.4.8, 2013/08/21 15:28:16
Line 67 static sched_task_func_t cbProto[SOCK_RAW + 1][4] = {	Line 67 static sched_task_func_t cbProto[SOCK_RAW + 1][4] = {
};	};


static inline u_char *	ait_val_t *
getBuffer(rpc_cli_t * __restrict c)	rpc_getBufVar(rpc_cli_t * __restrict c)
{	{
	return array(c->cli_buf, RPC_ISNEXTBUF(c), ait_val_t*);
	}

	u_char *
	rpc_getBuffer(rpc_cli_t * __restrict c)
	{
u_char *b = NULL;	u_char *b = NULL;

assert(c);	assert(c);
Line 83 getBuffer(rpc_cli_t * __restrict c)	Line 89 getBuffer(rpc_cli_t * __restrict c)
return b;	return b;
}	}

static inline struct tagRPCCall *	struct tagRPCCall *
getHeader(rpc_cli_t * __restrict c)	rpc_getHeader(rpc_cli_t * __restrict c)
{	{
assert(c);	assert(c);

Line 255 execCall(sched_task_t *task)	Line 261 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 = getBuffer(c);	u_char *buf = rpc_getBuffer(c);
struct tagRPCCall *rpc = getHeader(c);	struct tagRPCCall *rpc = rpc_getHeader(c);
int argc = ntohs(rpc->call_argc);	int argc = ntohs(rpc->call_argc);

/* Go decapsulate variables ... */	/* Go decapsulate variables ... */
Line 530 rxUDPPacket(sched_task_t *task)	Line 536 rxUDPPacket(sched_task_t *task)
RPC_SET_NEXTBUF(c);	RPC_SET_NEXTBUF(c);
}	}

rpc = getHeader(c);	rpc = rpc_getHeader(c);
memcpy(rpc, &rpcbuf, sizeof(struct tagRPCCall));	memcpy(rpc, &rpcbuf, sizeof(struct tagRPCCall));
memcpy(getBuffer(c), buf, len);	memcpy(rpc_getBuffer(c), buf, len);

c->cli_sock = TASK_FD(task);	c->cli_sock = TASK_FD(task);
memcpy(&c->cli_sa, sa, sizeof c->cli_sa);	memcpy(&c->cli_sa, sa, sizeof c->cli_sa);

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

Removed from v.1.17.4.7
changed lines
	Added in v.1.17.4.8