Skip to content

Commit

Permalink
Merge tag 'v14.3.2' into neo-v0.8.x
Browse files Browse the repository at this point in the history
v14.3.2
  • Loading branch information
nemanja-boric-sociomantic committed Sep 21, 2018
2 parents c9b8520 + 8b19f4c commit 65a187e
Showing 1 changed file with 7 additions and 7 deletions.
14 changes: 7 additions & 7 deletions src/dhtproto/client/legacy/internal/helper/RetryHandshake.d
Original file line number Diff line number Diff line change
Expand Up @@ -32,7 +32,7 @@ class RetryHandshake
/// result in a confusing mess). This is a highly unusual case, though,
/// so is not specifically supported. We can add better support, if it's
/// ever needed.
private Logger log;
private Logger retry_log;

/// Timer to retry the handshake.
protected TimerEvent timer;
Expand Down Expand Up @@ -90,7 +90,7 @@ class RetryHandshake

this.timer = new TimerEvent(&this.tryHandshake);

this.log = Log.lookup("RetryHandshake");
this.retry_log = Log.lookup("RetryHandshake");

this.tryHandshake();
}
Expand All @@ -107,7 +107,7 @@ class RetryHandshake

protected bool tryHandshake ( )
{
this.log.info("Attempting handshake.");
this.retry_log.info("Attempting handshake.");
this.dht.nodeHandshake(&this.result, &this.handshake_notifier);

return false;
Expand All @@ -129,14 +129,14 @@ class RetryHandshake
{
this.error();

this.log.info("Handshake did not succeed for all nodes. Retrying in {}s",
this.retry_log.info("Handshake did not succeed for all nodes. Retrying in {}s",
this.wait_time);
this.epoll.register(this.timer);
this.timer.set(this.wait_time, 0, 0, 0);
}
else
{
this.log.info("Handshake succeeded for all nodes.");
this.retry_log.info("Handshake succeeded for all nodes.");
this.success();

if ( this.handshake_complete_dg !is null )
Expand All @@ -159,7 +159,7 @@ class RetryHandshake

private void handshake_notifier ( DhtClient.RequestNotification info )
{
this.log.trace("Callback: {}", info.message(this.dht.msg_buf));
this.retry_log.trace("Callback: {}", info.message(this.dht.msg_buf));

this.nodeHandshakeCB(info);

Expand All @@ -185,7 +185,7 @@ class RetryHandshake
{
this.established_nodes[node_hash] = true;
this.one_node_handshake_dg(info.nodeitem);
this.log.info("Handshake succeeded on {}:{}.",
this.retry_log.info("Handshake succeeded on {}:{}.",
info.nodeitem.Address, info.nodeitem.Port);
}
}
Expand Down

0 comments on commit 65a187e

Please sign in to comment.