libaitrpc/src/cli.c - diff

Return to cli.c CVS log

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

Diff for /libaitrpc/src/cli.c between versions 1.4.2.5 and 1.5.2.1

version 1.4.2.5, 2011/09/01 14:55:42	version 1.5.2.1, 2011/09/07 08:56:32
Line 105 rpc_cli_openBLOBClient(rpc_cli_t * __restrict rpccli,	Line 105 rpc_cli_openBLOBClient(rpc_cli_t * __restrict rpccli,
if (setsockopt(cli->cli_sock, SOL_SOCKET, SO_SNDBUF, &n, sizeof n) == -1) {	if (setsockopt(cli->cli_sock, SOL_SOCKET, SO_SNDBUF, &n, sizeof n) == -1) {
LOGERR;	LOGERR;
close(cli->cli_sock);	close(cli->cli_sock);
free(cli->cli_parent);
free(cli);	free(cli);
return NULL;	return NULL;
}	}
if (setsockopt(cli->cli_sock, SOL_SOCKET, SO_RCVBUF, &n, sizeof n) == -1) {	if (setsockopt(cli->cli_sock, SOL_SOCKET, SO_RCVBUF, &n, sizeof n) == -1) {
LOGERR;	LOGERR;
close(cli->cli_sock);	close(cli->cli_sock);
free(cli->cli_parent);
free(cli);	free(cli);
return NULL;	return NULL;
}	}
if (connect(cli->cli_sock, &cli->cli_sa, sizeof cli->cli_sa) == -1) {	if (connect(cli->cli_sock, &cli->cli_sa, sizeof cli->cli_sa) == -1) {
LOGERR;	LOGERR;
	close(cli->cli_sock);
free(cli);	free(cli);
return NULL;	return NULL;
}	}
Line 339 rpc_cli_execCall(rpc_cli_t cli, const char csModule,	Line 338 rpc_cli_execCall(rpc_cli_t cli, const char csModule,

/* prepare RPC call */	/* prepare RPC call */
rpc = (struct tagRPCCall*) buf;	rpc = (struct tagRPCCall*) buf;
memcpy(&rpc->call_session, cli->cli_parent, sizeof rpc->call_session);	rpc_addPktSession(&rpc->call_session, cli->cli_parent);
rpc->call_argc = in_vars ? io_arraySize(in_vars) : 0;	rpc->call_argc = in_vars ? io_arraySize(in_vars) : 0;
rpc->call_tag = crcFletcher16((u_short*) str, sizeof str / 2);	rpc->call_tag = crcFletcher16((u_short*) str, sizeof str / 2);
rpc->call_hash = hash_fnv((char*) str, sizeof str);	rpc->call_hash = hash_fnv((char*) str, sizeof str);
Line 397 rpc_cli_execCall(rpc_cli_t cli, const char csModule,	Line 396 rpc_cli_execCall(rpc_cli_t cli, const char csModule,
} else	} else
rrpc = (struct tagRPCRet*) buf;	rrpc = (struct tagRPCRet*) buf;
/* check RPC packet session info */	/* check RPC packet session info */
if (memcmp(&rrpc->ret_session, cli->cli_parent, sizeof rrpc->ret_session)) {	if (rpc_chkPktSession(&rrpc->ret_session, cli->cli_parent)) {
rpc_SetErr(ERPCMISMATCH, "Error:: get invalid RPC session ...\n");	rpc_SetErr(ERPCMISMATCH, "Error:: get invalid RPC session ...\n");
free(buf);	free(buf);
return -5;	return -5;

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

Removed from v.1.4.2.5
changed lines
	Added in v.1.5.2.1