MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-10-31 19:08:59 +01:00
Code Issues Releases Wiki Activity

ircd::net: Minor cleanup.

Browse source
This commit is contained in:
Jason Volk 2018-09-01 22:11:09 -07:00
parent 168b82a972
commit bbc26ebb75
1 changed files with 72 additions and 42 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

70
ircd/net.cc
View file

@ -1145,9 +1145,12 @@ noexcept try
}
catch(const std::exception &e)
{
log.error("acceptor(%p) join: %s",
log::error
{
log, "acceptor(%p) join: %s",
this,
e.what());
e.what()
};
}
bool
@ -1160,9 +1163,12 @@ noexcept try
}
catch(const boost::system::system_error &e)
{
log.error("acceptor(%p) interrupt: %s",
log::error
{
log, "acceptor(%p) interrupt: %s",
this,
string(e));
string(e)
};
return false;
}
@ -1217,12 +1223,15 @@ noexcept try
}};
assert(bool(sock));
log.debug("%s: socket(%p) accepted(%zu) %s %s",
log::debug
{
log, "%s: socket(%p) accepted(%zu) %s %s",
string(*this),
sock.get(),
accepting,
string(remote_ipport(*sock)),
string(ec));
string(ec)
};
if(!check_accept_error(ec, *sock))
return;
@ -1254,26 +1263,35 @@ noexcept try
}
catch(const ctx::interrupted &e)
{
log.debug("%s: acceptor interrupted socket(%p) %s",
log::debug
{
log, "%s: acceptor interrupted socket(%p) %s",
string(*this),
sock.get(),
string(ec));
string(ec)
};
joining.notify_all();
}
catch(const boost::system::system_error &e)
{
log.derror("%s: socket(%p) in accept(): %s",
log::derror
{
log, "%s: socket(%p) in accept(): %s",
string(*this),
sock.get(),
string(e));
string(e)
};
}
catch(const std::exception &e)
{
log.error("%s: socket(%p) in accept(): %s",
log::error
{
log, "%s: socket(%p) in accept(): %s",
string(*this),
sock.get(),
e.what());
e.what()
};
}
/// Error handler for the accept socket callback. This handler determines
@ -1325,12 +1343,15 @@ noexcept try
}};
assert(bool(sock));
log.debug("socket(%p) local[%s] remote[%s] handshook(%zu) %s",
log::debug
{
log, "socket(%p) local[%s] remote[%s] handshook(%zu) %s",
sock.get(),
string(local_ipport(*sock)),
string(remote_ipport(*sock)),
handshaking,
string(ec));
string(ec)
};
check_handshake_error(ec, *sock);
sock->cancel_timeout();
@ -1339,26 +1360,35 @@ noexcept try
}
catch(const ctx::interrupted &e)
{
log.debug("%s: SSL handshake interrupted socket(%p) %s",
log::debug
{
log, "%s: SSL handshake interrupted socket(%p) %s",
string(*this),
sock.get(),
string(ec));
string(ec)
};
joining.notify_all();
}
catch(const boost::system::system_error &e)
{
log.derror("%s: socket(%p) in handshake(): %s",
log::derror
{
log, "%s: socket(%p) in handshake(): %s",
string(*this),
sock.get(),
string(e));
string(e)
};
}
catch(const std::exception &e)
{
log.error("%s: socket(%p) in handshake(): %s",
log::error
{
log, "%s: socket(%p) in handshake(): %s",
string(*this),
sock.get(),
e.what());
e.what()
};
}
/// Error handler for the SSL handshake callback. This handler determines