Fixes #624 cleanup
This commit is contained in:
parent
126e58c7cc
commit
d4c1bec340
|
@ -377,9 +377,10 @@ public class HttpChannelState
|
||||||
}
|
}
|
||||||
else
|
else
|
||||||
{
|
{
|
||||||
read_interested=_asyncReadUnready;
|
|
||||||
_state=State.ASYNC_WAIT;
|
_state=State.ASYNC_WAIT;
|
||||||
action=Action.WAIT;
|
action=Action.WAIT;
|
||||||
|
if (_asyncReadUnready)
|
||||||
|
_channel.asyncReadFillInterested();
|
||||||
Scheduler scheduler = _channel.getScheduler();
|
Scheduler scheduler = _channel.getScheduler();
|
||||||
if (scheduler!=null && _timeoutMs>0)
|
if (scheduler!=null && _timeoutMs>0)
|
||||||
_event.setTimeoutTask(scheduler.schedule(_event,_timeoutMs,TimeUnit.MILLISECONDS));
|
_event.setTimeoutTask(scheduler.schedule(_event,_timeoutMs,TimeUnit.MILLISECONDS));
|
||||||
|
@ -414,8 +415,6 @@ public class HttpChannelState
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
|
||||||
if (read_interested)
|
|
||||||
_channel.asyncReadFillInterested();
|
|
||||||
return action;
|
return action;
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue