|
|
@ -2169,7 +2169,7 @@ int generator(proc_instance_t *pi) |
|
|
|
ckp->data = gdata; |
|
|
|
ckp->data = gdata; |
|
|
|
gdata->ckp = ckp; |
|
|
|
gdata->ckp = ckp; |
|
|
|
if (ckp->proxy) { |
|
|
|
if (ckp->proxy) { |
|
|
|
char *buf; |
|
|
|
char *buf = NULL; |
|
|
|
|
|
|
|
|
|
|
|
/* Wait for the stratifier to be ready for us */ |
|
|
|
/* Wait for the stratifier to be ready for us */ |
|
|
|
do { |
|
|
|
do { |
|
|
@ -2179,6 +2179,7 @@ int generator(proc_instance_t *pi) |
|
|
|
} |
|
|
|
} |
|
|
|
buf = send_recv_proc(ckp->stratifier, "ping"); |
|
|
|
buf = send_recv_proc(ckp->stratifier, "ping"); |
|
|
|
} while (!buf); |
|
|
|
} while (!buf); |
|
|
|
|
|
|
|
dealloc(buf); |
|
|
|
ret = proxy_mode(ckp, pi); |
|
|
|
ret = proxy_mode(ckp, pi); |
|
|
|
} else { |
|
|
|
} else { |
|
|
|
gdata->srvchk = create_ckmsgq(ckp, "srvchk", &server_watchdog); |
|
|
|
gdata->srvchk = create_ckmsgq(ckp, "srvchk", &server_watchdog); |
|
|
|