version 1.25.2.2, 2015/06/28 21:52:26
|
version 1.25.2.3, 2015/06/28 22:11:30
|
Line 261 rpc_cli_reconnectClient(rpc_cli_t * __restrict cli)
|
Line 261 rpc_cli_reconnectClient(rpc_cli_t * __restrict cli)
|
else |
else |
netBuf = AIT_LEN(&cli->cli_buf); |
netBuf = AIT_LEN(&cli->cli_buf); |
|
|
|
if (cli->cli_id == SOCK_STREAM) |
|
shutdown(cli->cli_sock, SHUT_RDWR); |
|
if (cli->cli_id == SOCK_DGRAM && cli->cli_sa.sa.sa_family == AF_LOCAL) { |
|
sockaddr_t sa2 = E_SOCKADDR_INIT; |
|
socklen_t salen; |
|
|
|
sa2.sa.sa_len = salen = sizeof sa2; |
|
if (!getsockname(cli->cli_sock, &sa2.sa, &salen)) |
|
unlink(sa2.sun.sun_path); |
|
} |
close(cli->cli_sock); |
close(cli->cli_sock); |
|
|
srandom(time(NULL) ^ getpid()); |
srandom(time(NULL) ^ getpid()); |
Line 307 rpc_cli_closeClient(rpc_cli_t ** __restrict cli)
|
Line 317 rpc_cli_closeClient(rpc_cli_t ** __restrict cli)
|
|
|
if ((*cli)->cli_id == SOCK_STREAM) |
if ((*cli)->cli_id == SOCK_STREAM) |
shutdown((*cli)->cli_sock, SHUT_RDWR); |
shutdown((*cli)->cli_sock, SHUT_RDWR); |
|
if ((*cli)->cli_id == SOCK_DGRAM && (*cli)->cli_sa.sa.sa_family == AF_LOCAL) { |
|
sockaddr_t sa2 = E_SOCKADDR_INIT; |
|
socklen_t salen; |
|
|
|
sa2.sa.sa_len = salen = sizeof sa2; |
|
if (!getsockname((*cli)->cli_sock, &sa2.sa, &salen)) |
|
unlink(sa2.sun.sun_path); |
|
} |
close((*cli)->cli_sock); |
close((*cli)->cli_sock); |
|
|
AIT_FREE_VAL(&(*cli)->cli_buf); |
AIT_FREE_VAL(&(*cli)->cli_buf); |