fix(http): move hup check before writable check
This commit is contained in:
@@ -631,10 +631,6 @@ impl<K: Key, T: Transport, H: MessageHandler<T>> Conn<K, T, H> {
|
|||||||
self.0.on_readable(scope);
|
self.0.on_readable(scope);
|
||||||
}
|
}
|
||||||
|
|
||||||
if events.is_writable() {
|
|
||||||
self.0.on_writable(scope);
|
|
||||||
}
|
|
||||||
|
|
||||||
if events.is_hup() {
|
if events.is_hup() {
|
||||||
trace!("Conn::ready got hangup");
|
trace!("Conn::ready got hangup");
|
||||||
let _ = scope.deregister(&self.0.transport);
|
let _ = scope.deregister(&self.0.transport);
|
||||||
@@ -642,6 +638,10 @@ impl<K: Key, T: Transport, H: MessageHandler<T>> Conn<K, T, H> {
|
|||||||
return ReadyResult::Done(None);
|
return ReadyResult::Done(None);
|
||||||
}
|
}
|
||||||
|
|
||||||
|
if events.is_writable() {
|
||||||
|
self.0.on_writable(scope);
|
||||||
|
}
|
||||||
|
|
||||||
let mut events = match self.0.register() {
|
let mut events = match self.0.register() {
|
||||||
Reg::Read => EventSet::readable(),
|
Reg::Read => EventSet::readable(),
|
||||||
Reg::Write => EventSet::writable(),
|
Reg::Write => EventSet::writable(),
|
||||||
|
|||||||
Reference in New Issue
Block a user