Skip to content

Commit

Permalink
director: Cleanup - move code to a new director_log_connect()
Browse files Browse the repository at this point in the history
Also adds a missing ')' to the log line.
  • Loading branch information
sirainen committed Oct 5, 2017
1 parent aae6b3c commit d4e911d
Showing 1 changed file with 20 additions and 16 deletions.
36 changes: 20 additions & 16 deletions src/director/director.c
Expand Up @@ -128,6 +128,24 @@ director_has_outgoing_connection(struct director *dir,
return FALSE;
}

static void
director_log_connect(struct director *dir, struct director_host *host)
{
string_t *str = t_str_new(128);

if (host->last_network_failure > 0) {
str_printfa(str, ", last network failure %ds ago",
(int)(ioloop_time - host->last_network_failure));
}
if (host->last_protocol_failure > 0) {
str_printfa(str, ", last protocol failure %ds ago",
(int)(ioloop_time - host->last_protocol_failure));
}
dir_debug("Connecting to %s:%u (as %s%s)",
net_ip2addr(&host->ip), host->port,
net_ip2addr(&dir->self_ip), str_c(str));
}

int director_connect_host(struct director *dir, struct director_host *host)
{
in_port_t port;
Expand All @@ -136,22 +154,8 @@ int director_connect_host(struct director *dir, struct director_host *host)
if (director_has_outgoing_connection(dir, host))
return 0;

if (director_debug) {
string_t *str = t_str_new(128);

str_printfa(str, "Connecting to %s:%u (as %s",
net_ip2addr(&host->ip), host->port,
net_ip2addr(&dir->self_ip));
if (host->last_network_failure > 0) {
str_printfa(str, ", last network failure %ds ago",
(int)(ioloop_time - host->last_network_failure));
}
if (host->last_protocol_failure > 0) {
str_printfa(str, ", last protocol failure %ds ago",
(int)(ioloop_time - host->last_protocol_failure));
}
dir_debug("%s", str_c(str));
}
if (director_debug)
director_log_connect(dir, host);
port = dir->test_port != 0 ? dir->test_port : host->port;
fd = net_connect_ip(&host->ip, port, &dir->self_ip);
if (fd == -1) {
Expand Down

0 comments on commit d4e911d

Please sign in to comment.