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.1.1.1.2.7 and 1.1.1.1.2.8

version 1.1.1.1.2.7, 2010/06/23 16:44:24	version 1.1.1.1.2.8, 2010/06/23 17:29:07
Line 196 rpc_srv_dispatchVars(void *arg)	Line 196 rpc_srv_dispatchVars(void *arg)

cx = -1;	cx = -1;
do {	do {
cx++;

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);
if (ret == -1) {	if (ret == -1) {
ret = -2;	ret = -2;
}	} else
	cx++;
memset(buf, 0, sizeof buf);	memset(buf, 0, sizeof buf);
if ((ret = recv(c->cli_sock, buf, sizeof buf, 0)) == -1) {	if ((ret = recv(c->cli_sock, buf, sizeof buf, 0)) == -1) {
LOGERR;	LOGERR;
Line 227 rpc_srv_dispatchVars(void *arg)	Line 226 rpc_srv_dispatchVars(void *arg)
ret = -5;	ret = -5;
break;	break;
}	}
// Go to decapsulate packet ...	// get requested BLOB object
if (!(b = rpc_srv_getBLOB(s, blob->hdr_var))) {	if (!(b = rpc_srv_getBLOB(s, blob->hdr_var)))
rpc_SetErr(EINVAL, "Error:: var (%x) not found into BLOB server ...\n", blob->hdr_var);	if (blob->hdr_cmd != set) {
ret = -6;	rpc_SetErr(EINVAL, "Error:: var (%x) not found into BLOB server ...\n", blob->hdr_var);
break;	ret = -6;
}	break;
	}
	// Go to proceed packet ...
switch (blob->hdr_cmd) {	switch (blob->hdr_cmd) {
case get:	case get:
if (rpc_srv_blobMap(s, b) != -1) {	if (rpc_srv_blobMap(s, b) != -1) {
Line 242 rpc_srv_dispatchVars(void *arg)	Line 243 rpc_srv_dispatchVars(void *arg)
ret = -7;	ret = -7;
break;	break;
case set:	case set:
ret = rpc_srv_recvBLOB(c, b);	if (b) {
	rpc_SetErr(EINVAL, "Error:: Cannot set var into BLOB server, already exists ...\n");
	ret = -6;
	break;
	}

	ret = rpc_srv_recvBLOB(c);
if (ret == -1)	if (ret == -1)
ret = -7;	ret = -7;
break;	break;
case unset:	case unset:
ret = rpc_srv_deleteBLOB(c, b);	ret = rpc_srv_blobFree(s, b);
if (ret == -1)	if (ret == -1)
ret = -7;	ret = -7;
break;	break;

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

Removed from v.1.1.1.1.2.7
changed lines
	Added in v.1.1.1.1.2.8