Browse Source

Use server_alive to determine if node backup btcd is alive

master
Con Kolivas 10 years ago
parent
commit
fc38e4d672
  1. 37
      src/generator.c

37
src/generator.c

@ -2676,41 +2676,6 @@ static proxy_instance_t *__add_proxy(ckpool_t *ckp, gdata_t *gdata, const int id
return proxy; return proxy;
} }
static bool alive_btcd(server_instance_t *si)
{
connsock_t *cs = &si->cs;
char *userpass = NULL;
gbtbase_t gbt;
if (!extract_sockaddr(si->url, &cs->url, &cs->port)) {
LOGWARNING("Failed to extract address from btcd %s", si->url);
return false;
}
userpass = strdup(si->auth);
realloc_strcat(&userpass, ":");
realloc_strcat(&userpass, si->pass);
cs->auth = http_base64(userpass);
dealloc(userpass);
if (!cs->auth) {
LOGWARNING("Failed to create base64 auth from btcd %s", userpass);
return false;
}
if (cs->fd < 0) {
LOGWARNING("Failed to connect socket to btcd %s:%s !", cs->url, cs->port);
return false;
}
keep_sockalive(cs->fd);
/* Test we can authorise by getting a gbt, but we won't be using it. */
memset(&gbt, 0, sizeof(gbtbase_t));
if (!gen_gbtbase(cs, &gbt)) {
LOGINFO("Failed to get test block template from btcd %s:%s!",
cs->url, cs->port);
return false;
}
clear_gbtbase(&gbt);
return true;
}
static int proxy_mode(ckpool_t *ckp, proc_instance_t *pi) static int proxy_mode(ckpool_t *ckp, proc_instance_t *pi)
{ {
gdata_t *gdata = ckp->data; gdata_t *gdata = ckp->data;
@ -2746,7 +2711,7 @@ static int proxy_mode(ckpool_t *ckp, proc_instance_t *pi)
si->url = ckp->btcdurl[0]; si->url = ckp->btcdurl[0];
si->auth = ckp->btcdauth[0]; si->auth = ckp->btcdauth[0];
si->pass = ckp->btcdpass[0]; si->pass = ckp->btcdpass[0];
if (alive_btcd(si)) { if (server_alive(ckp, si, false)) {
LOGNOTICE("Node backup btcd %s:%s alive", si->cs.url, si->cs.port); LOGNOTICE("Node backup btcd %s:%s alive", si->cs.url, si->cs.port);
} else { } else {
LOGWARNING("Node backup btcd %s:%s failed! Will run as ordinary passthrough", LOGWARNING("Node backup btcd %s:%s failed! Will run as ordinary passthrough",

Loading…
Cancel
Save