|
|
@ -246,6 +246,7 @@ static int gen_loop(proc_instance_t *pi) |
|
|
|
char hash[68]; |
|
|
|
char hash[68]; |
|
|
|
|
|
|
|
|
|
|
|
reconnect: |
|
|
|
reconnect: |
|
|
|
|
|
|
|
Close(sockd); |
|
|
|
if (si) { |
|
|
|
if (si) { |
|
|
|
kill_server(si); |
|
|
|
kill_server(si); |
|
|
|
reconnecting = true; |
|
|
|
reconnecting = true; |
|
|
@ -262,6 +263,7 @@ reconnect: |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
retry: |
|
|
|
retry: |
|
|
|
|
|
|
|
Close(sockd); |
|
|
|
ckmsgq_add(srvchk, si); |
|
|
|
ckmsgq_add(srvchk, si); |
|
|
|
|
|
|
|
|
|
|
|
do { |
|
|
|
do { |
|
|
@ -289,7 +291,6 @@ retry: |
|
|
|
buf = recv_unix_msg(sockd); |
|
|
|
buf = recv_unix_msg(sockd); |
|
|
|
if (!buf) { |
|
|
|
if (!buf) { |
|
|
|
LOGWARNING("Failed to get message in gen_loop"); |
|
|
|
LOGWARNING("Failed to get message in gen_loop"); |
|
|
|
Close(sockd); |
|
|
|
|
|
|
|
goto retry; |
|
|
|
goto retry; |
|
|
|
} |
|
|
|
} |
|
|
|
LOGDEBUG("Generator received request: %s", buf); |
|
|
|
LOGDEBUG("Generator received request: %s", buf); |
|
|
@ -369,7 +370,6 @@ retry: |
|
|
|
LOGDEBUG("Generator received ping request"); |
|
|
|
LOGDEBUG("Generator received ping request"); |
|
|
|
send_unix_msg(sockd, "pong"); |
|
|
|
send_unix_msg(sockd, "pong"); |
|
|
|
} |
|
|
|
} |
|
|
|
Close(sockd); |
|
|
|
|
|
|
|
goto retry; |
|
|
|
goto retry; |
|
|
|
|
|
|
|
|
|
|
|
out: |
|
|
|
out: |
|
|
|