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.5 and 1.1.1.1.2.6

version 1.1.1.1.2.5, 2010/06/23 15:07:15	version 1.1.1.1.2.6, 2010/06/23 16:23:31
Line 185 rpc_srv_dispatchVars(void *arg)	Line 185 rpc_srv_dispatchVars(void *arg)
rpc_blob_t *b;	rpc_blob_t *b;
int cx, ret;	int cx, ret;
fd_set fds;	fd_set fds;
u_char buf[BLOBSIZ];	u_char buf[sizeof(struct tagBLOBHdr)];
struct tagBLOBHdr *blob;	struct tagBLOBHdr *blob;

if (!arg) {	if (!arg) {
Line 204 rpc_srv_dispatchVars(void *arg)	Line 204 rpc_srv_dispatchVars(void *arg)
if (ret == -1) {	if (ret == -1) {
ret = -2;	ret = -2;
}	}
memset(buf, 0, BLOBSIZ);	memset(buf, 0, sizeof buf);
if ((ret = recv(c->cli_sock, buf, BLOBSIZ, 0)) == -1) {	if ((ret = recv(c->cli_sock, buf, sizeof buf, 0)) == -1) {
LOGERR;	LOGERR;
ret = -3;	ret = -3;
break;	break;
Line 235 rpc_srv_dispatchVars(void *arg)	Line 235 rpc_srv_dispatchVars(void *arg)
}	}
switch (blob->hdr_cmd) {	switch (blob->hdr_cmd) {
case get:	case get:
ret = rpc_srv_sendBLOB(c, b);	if (rpc_srv_blobMap(s, b) != -1) {
	ret = rpc_srv_sendBLOB(c, b);
	rpc_srv_blobUnmap(b);
	} else
	ret = -7;
break;	break;
case set:	case set:
ret = rpc_srv_recvBLOB(c, b);	ret = rpc_srv_recvBLOB(c, b);
	if (ret == -1)
	ret = -7;
break;	break;
case unset:	case unset:
ret = rpc_srv_freeBLOB(b);	ret = rpc_srv_deleteBLOB(c, b);
	if (ret == -1)
	ret = -7;
break;	break;
default:	default:
rpc_SetErr(EINVAL, "Error:: unsupported BLOB command (%d)...\n",	rpc_SetErr(EINVAL, "Error:: unsupported BLOB command (%d)...\n",
blob->hdr_cmd);	blob->hdr_cmd);
ret -7;	ret -7;
}	}

	// Replay to client!
} while (ret > -1);	} while (ret > -1);

shutdown(c->cli_sock, SHUT_RDWR);	shutdown(c->cli_sock, SHUT_RDWR);

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

Removed from v.1.1.1.1.2.5
changed lines
	Added in v.1.1.1.1.2.6