libaitrpc/src/cli.c - diff

Return to cli.c CVS log

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

version 1.9.2.15, 2012/05/17 22:57:42	version 1.9.2.17, 2012/05/18 15:37:58
Line 315 rpc_cli_execCall(rpc_cli_t *cli, int noreply, u_short	Line 315 rpc_cli_execCall(rpc_cli_t *cli, int noreply, u_short
if (noreply) /* we not want reply */	if (noreply) /* we not want reply */
return 0;	return 0;

	wlen = 0;
/* reply from RPC server */	/* reply from RPC server */
pfd.events = POLLIN \| POLLPRI;	pfd.events = POLLIN \| POLLPRI;
do {	do {
Line 325 rpc_cli_execCall(rpc_cli_t *cli, int noreply, u_short	Line 326 rpc_cli_execCall(rpc_cli_t *cli, int noreply, u_short
continue;	continue;
else	else
LOGERR;	LOGERR;
} else	} else {
rpc_SetErr(ETIMEDOUT, "Timeout, no answer from RPC server");	if (wlen++ < 7)
	continue;
	else
	rpc_SetErr(ETIMEDOUT, "Timeout, no answer from RPC server");
	}
return -1;	return -1;
}	}
} while (0);	} while (0);
Line 402 rpc_cli_ping(rpc_cli_t *cli)	Line 407 rpc_cli_ping(rpc_cli_t *cli)
if (rpc_cli_execCall(cli, RPC_REPLY, CALL_SRVPING, NULL, &arr))	if (rpc_cli_execCall(cli, RPC_REPLY, CALL_SRVPING, NULL, &arr))
return -1;	return -1;
else	else
ret = AIT_GET_U16(io_getVars(arr, 0));	ret = AIT_GET_U16(io_array(arr, 0, ait_val_t*));
io_freeVars(&arr);	io_freeVars(&arr);

return ret;	return ret;