aboutsummaryrefslogtreecommitdiff
path: root/include/salticidae/network.h
diff options
context:
space:
mode:
Diffstat (limited to 'include/salticidae/network.h')
-rw-r--r--include/salticidae/network.h31
1 files changed, 22 insertions, 9 deletions
diff --git a/include/salticidae/network.h b/include/salticidae/network.h
index 46112d2..c581aa4 100644
--- a/include/salticidae/network.h
+++ b/include/salticidae/network.h
@@ -473,6 +473,7 @@ class PeerNetwork: public MsgNetwork<OpcodeType> {
std::string id_hex;
const char *tty_primary_color;
const char *tty_secondary_color;
+ const char *tty_tertiary_color;
const char *tty_reset_color;
struct MsgPing {
@@ -576,11 +577,13 @@ class PeerNetwork: public MsgNetwork<OpcodeType> {
allow_unknown_peer(config._allow_unknown_peer),
tty_primary_color(""),
tty_secondary_color(""),
+ tty_tertiary_color(""),
tty_reset_color("") {
if (logger.is_tty())
{
tty_primary_color = TTY_COLOR_BLUE;
tty_secondary_color = TTY_COLOR_CYAN;
+ tty_tertiary_color = TTY_COLOR_YELLOW;
tty_reset_color = TTY_COLOR_RESET;
}
this->reg_handler(generic_bind(&PeerNetwork::ping_handler, this, _1, _2));
@@ -792,6 +795,16 @@ void PeerNetwork<O, _, __>::on_teardown(const ConnPool::conn_t &_conn) {
p->outbound_conn = nullptr;
p->ev_ping_timer.del();
p->nonce = 0;
+ SALTICIDAE_LOG_INFO("%sended %s%s%s <-/-> %s%s%s (via %s)%s",
+ tty_tertiary_color,
+ tty_secondary_color,
+ id_hex.c_str(),
+ tty_tertiary_color,
+ tty_secondary_color,
+ p->id_hex.c_str(),
+ tty_tertiary_color,
+ std::string(*(p->conn)).c_str(),
+ tty_reset_color);
this->user_tcall->async_call([this, conn](ThreadCall::Handle &) {
if (peer_cb) peer_cb(conn, false);
});
@@ -862,7 +875,7 @@ void PeerNetwork<O, _, __>::finish_handshake(Peer *p) {
if (peer_cb) peer_cb(conn, true);
});
pending_peers.erase(p->conn->get_addr());
- SALTICIDAE_LOG_INFO("%sestablished %s%s%s <-> %s%s%s (via %s)%s",
+ SALTICIDAE_LOG_INFO("%sestablished %s%s%s <---> %s%s%s (via %s)%s",
tty_primary_color,
tty_secondary_color,
id_hex.c_str(),
@@ -933,14 +946,14 @@ void PeerNetwork<O, _, __>::ping_handler(MsgPing &&msg, const conn_t &conn) {
auto &p = pit->second;
if (p->state != Peer::State::DISCONNECTED ||
(!p->addr.is_null() && p->addr != msg.claimed_addr)) return;
- SALTICIDAE_LOG_INFO("%s%s%s: inbound handshake from %s%s%s",
+ SALTICIDAE_LOG_DEBUG("%s%s%s: inbound handshake from %s%s%s",
tty_secondary_color, id_hex.c_str(), tty_reset_color,
tty_secondary_color, p->id_hex.c_str(), tty_reset_color);
send_msg(MsgPong(listen_addr, p->get_nonce()), conn);
auto &old_conn = p->inbound_conn;
if (old_conn && old_conn != conn)
{
- SALTICIDAE_LOG_INFO("%s%s%s: terminating stale handshake connection %s",
+ SALTICIDAE_LOG_DEBUG("%s%s%s: terminating stale handshake connection %s",
tty_secondary_color, id_hex.c_str(), tty_reset_color,
std::string(*old_conn).c_str());
assert(old_conn->peer == nullptr);
@@ -949,7 +962,7 @@ void PeerNetwork<O, _, __>::ping_handler(MsgPing &&msg, const conn_t &conn) {
old_conn = conn;
if (msg.nonce < p->get_nonce() || p->addr.is_null())
{
- SALTICIDAE_LOG_INFO("%s%s%s: choses connection %s",
+ SALTICIDAE_LOG_DEBUG("%s%s%s: choses connection %s",
tty_secondary_color, id_hex.c_str(), tty_reset_color,
std::string(*conn).c_str());
p->chosen_conn = conn;
@@ -957,7 +970,7 @@ void PeerNetwork<O, _, __>::ping_handler(MsgPing &&msg, const conn_t &conn) {
}
else
{
- SALTICIDAE_LOG_INFO("%s%s%s: terminates one side (%04x >= %04x)",
+ SALTICIDAE_LOG_DEBUG("%s%s%s: terminates one side (%04x >= %04x)",
tty_secondary_color, id_hex.c_str(), tty_reset_color,
msg.nonce, p->get_nonce());
this->disp_terminate(conn);
@@ -1003,13 +1016,13 @@ void PeerNetwork<O, _, __>::pong_handler(MsgPong &&msg, const conn_t &conn) {
assert(!p->addr.is_null() && p->addr == conn->get_addr());
if (p->state != Peer::State::DISCONNECTED ||
p->addr != msg.claimed_addr) return;
- SALTICIDAE_LOG_INFO("%s%s%s: outbound handshake to %s%s%s",
+ SALTICIDAE_LOG_DEBUG("%s%s%s: outbound handshake to %s%s%s",
tty_secondary_color, id_hex.c_str(), tty_reset_color,
tty_secondary_color, p->id_hex.c_str(), tty_reset_color);
auto &old_conn = p->outbound_conn;
if (old_conn && old_conn != conn)
{
- SALTICIDAE_LOG_INFO("%s%s%s: terminating stale handshake connection %s",
+ SALTICIDAE_LOG_DEBUG("%s%s%s: terminating stale handshake connection %s",
tty_secondary_color, id_hex.c_str(), tty_reset_color,
std::string(*old_conn).c_str());
assert(old_conn->peer == nullptr);
@@ -1018,7 +1031,7 @@ void PeerNetwork<O, _, __>::pong_handler(MsgPong &&msg, const conn_t &conn) {
old_conn = conn;
if (p->get_nonce() < msg.nonce)
{
- SALTICIDAE_LOG_INFO("%s%s%s: choses connection %s",
+ SALTICIDAE_LOG_DEBUG("%s%s%s: choses connection %s",
tty_secondary_color, id_hex.c_str(), tty_reset_color,
std::string(*conn).c_str());
p->chosen_conn = conn;
@@ -1027,7 +1040,7 @@ void PeerNetwork<O, _, __>::pong_handler(MsgPong &&msg, const conn_t &conn) {
}
else
{
- SALTICIDAE_LOG_INFO("%s%s%s: terminates one side (%04x >= %04x)",
+ SALTICIDAE_LOG_DEBUG("%s%s%s: terminates one side (%04x >= %04x)",
tty_secondary_color, id_hex.c_str(), tty_reset_color,
p->get_nonce(), msg.nonce);
this->disp_terminate(conn);