libaitrpc/src/srv.c - diff

Return to srv.c CVS log

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

version 1.2, 2011/05/02 23:12:08	version 1.2.2.1, 2011/07/14 00:38:50
Line 67 rpc_srv_dispatchCall(void *arg)	Line 67 rpc_srv_dispatchCall(void *arg)
s = c->cli_parent;	s = c->cli_parent;

do {	do {
	v = NULL;
FD_ZERO(&fds);	FD_ZERO(&fds);
FD_SET(c->cli_sock, &fds);	FD_SET(c->cli_sock, &fds);
ret = select(c->cli_sock + 1, &fds, NULL, NULL, NULL);	ret = select(c->cli_sock + 1, &fds, NULL, NULL, NULL);
Line 123 rpc_srv_dispatchCall(void *arg)	Line 124 rpc_srv_dispatchCall(void *arg)
data += v[i].val_len;	data += v[i].val_len;
break;	break;
case string:	case string:
if (v[i].val_len + 1 > BUFSIZ - Limit) {	if (v[i].val_len > BUFSIZ - Limit) {
rpc_SetErr(EMSGSIZE, "Error:: Too big RPC packet ...\n");	rpc_SetErr(EMSGSIZE, "Error:: Too big RPC packet ...\n");
ret = -5;	ret = -5;
goto makeReply;	goto makeReply;
Line 131 rpc_srv_dispatchCall(void *arg)	Line 132 rpc_srv_dispatchCall(void *arg)
Limit += v[i].val_len;	Limit += v[i].val_len;

v[i].val.string = (int8_t*) data;	v[i].val.string = (int8_t*) data;
data += v[i].val_len + 1;	data += v[i].val_len;
break;	break;
case blob:	case blob:
if (s->srv_blob.state == disable) {	if (s->srv_blob.state == disable) {