version 1.26.4.3, 2016/08/02 12:00:39
|
version 1.27.2.1, 2019/08/15 14:59:18
|
Line 12 terms:
|
Line 12 terms:
|
All of the documentation and software included in the ELWIX and AITNET |
All of the documentation and software included in the ELWIX and AITNET |
Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> |
Releases is copyrighted by ELWIX - Sofia/Bulgaria <info@elwix.org> |
|
|
Copyright 2004 - 2016 | Copyright 2004 - 2019 |
by Michael Pounov <misho@elwix.org>. All rights reserved. |
by Michael Pounov <misho@elwix.org>. All rights reserved. |
|
|
Redistribution and use in source and binary forms, with or without |
Redistribution and use in source and binary forms, with or without |
Line 71 rpc_cli_openBLOBClient(rpc_cli_t * __restrict rpccli,
|
Line 71 rpc_cli_openBLOBClient(rpc_cli_t * __restrict rpccli,
|
} else |
} else |
memcpy(cli, rpccli, sizeof(rpc_cli_t)); |
memcpy(cli, rpccli, sizeof(rpc_cli_t)); |
|
|
memcpy(&cli->cli_sa, &rpccli->cli_sa, sizeof(sockaddr_t)); | memcpy(&cli->cli_sa, &rpccli->cli_sa, sizeof cli->cli_sa); |
switch (cli->cli_sa.sa.sa_family) { |
switch (cli->cli_sa.sa.sa_family) { |
case AF_INET: |
case AF_INET: |
cli->cli_sa.sin.sin_port = |
cli->cli_sa.sin.sin_port = |
Line 111 rpc_cli_openBLOBClient(rpc_cli_t * __restrict rpccli,
|
Line 111 rpc_cli_openBLOBClient(rpc_cli_t * __restrict rpccli,
|
e_free(cli); |
e_free(cli); |
return NULL; |
return NULL; |
} |
} |
if (connect(cli->cli_sock, &cli->cli_sa.sa, sizeof cli->cli_sa.sa) == -1) { | if (connect(cli->cli_sock, &cli->cli_sa.sa, e_addrlen(&cli->cli_sa)) == -1) { |
LOGERR; |
LOGERR; |
close(cli->cli_sock); |
close(cli->cli_sock); |
e_free(cli); |
e_free(cli); |
Line 405 rpc_pkt_Receive(int sock, int type, sockaddr_t * __res
|
Line 405 rpc_pkt_Receive(int sock, int type, sockaddr_t * __res
|
if (seq != ntohl(rpc->call_seq)) |
if (seq != ntohl(rpc->call_seq)) |
continue; |
continue; |
} |
} |
} while (ret < 1); | } while (ret < 0); |
|
|
return ret; |
return ret; |
} |
} |
Line 605 rpc_cli_execCall(rpc_cli_t *cli, int noreply, u_short
|
Line 605 rpc_cli_execCall(rpc_cli_t *cli, int noreply, u_short
|
if ((wlen = rpc_pkt_Receive(cli->cli_sock, cli->cli_id, &cli->cli_sa, |
if ((wlen = rpc_pkt_Receive(cli->cli_sock, cli->cli_id, &cli->cli_sa, |
&cli->cli_buf, seq)) == -1) |
&cli->cli_buf, seq)) == -1) |
return -1; |
return -1; |
if (!wlen) /* closed rpc connection */ | if (!wlen) { /* closed rpc connection */ |
return 1; | rpc_SetErr(ECONNRESET, "Closed connection"); |
| return -1; |
| } |
|
|
if ((wlen = rpc_pkt_Replay(&cli->cli_buf, cli->cli_parent, tag, |
if ((wlen = rpc_pkt_Replay(&cli->cli_buf, cli->cli_parent, tag, |
out_vars, type)) == -1) |
out_vars, type)) == -1) |
return -1; |
return -1; |
|
|
return 0; | return wlen; |
} |
} |
|
|
/* |
/* |