|
|
@ -1476,10 +1476,12 @@ static void *proxy_send(void *arg) |
|
|
|
free(jobid); |
|
|
|
free(jobid); |
|
|
|
json_decref(msg->json_msg); |
|
|
|
json_decref(msg->json_msg); |
|
|
|
free(msg); |
|
|
|
free(msg); |
|
|
|
if (!ret && subproxy && cs->fd > 0) { |
|
|
|
if (!ret && subproxy) { |
|
|
|
LOGWARNING("Proxy %d:%s failed to send msg in proxy_send, dropping to reconnect", |
|
|
|
if (cs->fd > 0) { |
|
|
|
proxy->id, proxy->si->url); |
|
|
|
LOGWARNING("Proxy %d:%s failed to send msg in proxy_send, dropping to reconnect", |
|
|
|
Close(cs->fd); |
|
|
|
proxy->id, proxy->si->url); |
|
|
|
|
|
|
|
Close(cs->fd); |
|
|
|
|
|
|
|
} |
|
|
|
if (!parent_proxy(subproxy) && !subproxy->disabled) |
|
|
|
if (!parent_proxy(subproxy) && !subproxy->disabled) |
|
|
|
disable_subproxy(gdata, proxy, subproxy); |
|
|
|
disable_subproxy(gdata, proxy, subproxy); |
|
|
|
} |
|
|
|
} |
|
|
|