static int hb_monitor(hb_ctx_t *ctx, apr_pool_t *p)
{
+ apr_size_t len;
+ apr_socket_t *sock = NULL;
+ char buf[256];
int i, j;
apr_uint32_t ready = 0;
apr_uint32_t busy = 0;
}
}
- char buf[256];
- apr_size_t len =
- apr_snprintf(buf, sizeof(buf), msg_format, MSG_VERSION, ready, busy);
+ len = apr_snprintf(buf, sizeof(buf), msg_format, MSG_VERSION, ready, busy);
- apr_socket_t *sock = NULL;
do {
apr_status_t rv;
rv = apr_socket_create(&sock, ctx->mcast_addr->family,
while (ctx->keep_running) {
int mpm_state = 0;
+ apr_pool_t *tpool;
+
rv = ap_mpm_query(AP_MPMQ_MPM_STATE, &mpm_state);
if (rv != APR_SUCCESS) {
break;
}
- apr_pool_t *tpool;
apr_pool_create(&tpool, pool);
apr_pool_tag(tpool, "heartbeat_worker_temp");
hb_monitor(ctx, tpool);
void *dconf, const char *addr)
{
apr_status_t rv;
+ const char *tmpdir = NULL;
+ char *path;
char *host_str;
char *scope_id;
apr_port_t port = 0;
return "HeartbeatAddress: apr_sockaddr_info_get failed.";
}
- const char *tmpdir = NULL;
rv = apr_temp_dir_get(&tmpdir, p);
if (rv) {
return "HeartbeatAddress: unable to find temp directory.";
}
- char *path = apr_pstrcat(p, tmpdir, "/hb-tmp.XXXXXX", NULL);
+ path = apr_pstrcat(p, tmpdir, "/hb-tmp.XXXXXX", NULL);
rv = apr_file_mktemp(&ctx->lockf, path, 0, p);
static void *hm_worker(apr_thread_t *thd, void *data)
{
+ apr_time_t last;
hm_ctx_t *ctx = (hm_ctx_t *) data;
apr_status_t rv;
}
- apr_time_t last = apr_time_now();
+ last = apr_time_now();
while (ctx->keep_running) {
int n;
apr_pool_t *p;
apr_pollfd_t pfd;
apr_interval_time_t timeout;
+ apr_time_t now;
apr_pool_create(&p, ctx->p);
- apr_time_t now = apr_time_now();
+ now = apr_time_now();
if (apr_time_sec((now - last)) > 5) {
hm_update_stats(ctx, p);