|
|
@ -1908,12 +1908,13 @@ static void *passthrough_recv(void *arg) |
|
|
|
int ret; |
|
|
|
int ret; |
|
|
|
|
|
|
|
|
|
|
|
while (!proxy_alive(ckp, proxi, cs, true)) { |
|
|
|
while (!proxy_alive(ckp, proxi, cs, true)) { |
|
|
|
if (alive) { |
|
|
|
|
|
|
|
alive = false; |
|
|
|
alive = false; |
|
|
|
reconnect_generator(ckp); |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
sleep(5); |
|
|
|
sleep(5); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
if (!alive) { |
|
|
|
|
|
|
|
reconnect_generator(ckp); |
|
|
|
|
|
|
|
alive = true; |
|
|
|
|
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/* Make sure we receive a line within 90 seconds */ |
|
|
|
/* Make sure we receive a line within 90 seconds */ |
|
|
|
ret = read_socket_line(cs, &timeout); |
|
|
|
ret = read_socket_line(cs, &timeout); |
|
|
|