MirrorHub/construct
0
0
Fork 0
mirror of https://github.com/matrix-construct/construct synced 2024-11-26 08:42:34 +01:00
Code Issues Releases Wiki Activity

ircd::server: Reinstall the read handler after discard.

Browse source
This commit is contained in:
Jason Volk 2018-03-17 23:20:15 -07:00
parent f5fa5100de
commit 7f2f855c4e
1 changed files with 7 additions and 3 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

10
ircd/server.cc
View file

@ -1435,7 +1435,11 @@ void
ircd::server::link::handle_readable_success() ircd::server::link::handle_readable_success()
{ {
if(queue.empty()) if(queue.empty())
return discard_read(); {
discard_read();
wait_readable();
return;
}
// Data pointed to by overrun will remain intact between iterations // Data pointed to by overrun will remain intact between iterations
// because this loop isn't executing in any ircd::ctx. // because this loop isn't executing in any ircd::ctx.
@ -1567,8 +1571,8 @@ ircd::server::link::discard_read()
// the pending error like an eof. // the pending error like an eof.
log.warning("Link to %s discarded %zu of %zu unexpected bytes", log.warning("Link to %s discarded %zu of %zu unexpected bytes",
likely(peer)? string(peer->remote) : string(remote_ipport(*socket)), likely(peer)? string(peer->remote) : string(remote_ipport(*socket)),
discard, discarded,
discarded); discard);
// just in case so this doesn't get loopy with discarding zero with // just in case so this doesn't get loopy with discarding zero with
// an empty queue... // an empty queue...