Revert "Always enqueue isc__nm_tcp_resumeread()"
The commit itself is harmless, but at the same time it is also useless,
so we are reverting it.
This reverts commit 11c869a3d5.
This commit is contained in:
+2
-13
@@ -816,7 +816,6 @@ isc__nm_tcp_resumeread(isc_nmhandle_t *handle) {
|
||||
|
||||
isc__netievent_tcpstartread_t *ievent = NULL;
|
||||
isc_nmsocket_t *sock = handle->sock;
|
||||
isc__networker_t *worker = &sock->mgr->workers[sock->tid];
|
||||
|
||||
REQUIRE(sock->tid == isc_nm_tid());
|
||||
|
||||
@@ -838,18 +837,8 @@ isc__nm_tcp_resumeread(isc_nmhandle_t *handle) {
|
||||
|
||||
ievent = isc__nm_get_netievent_tcpstartread(sock->mgr, sock);
|
||||
|
||||
if (worker->recvbuf_inuse) {
|
||||
/*
|
||||
* If we happen to call the resumeread from inside the receive
|
||||
* callback, the worker->recvbuf might still be in use, so we
|
||||
* need to force enqueue the next read event.
|
||||
*/
|
||||
isc__nm_enqueue_ievent(worker, (isc__netievent_t *)ievent);
|
||||
|
||||
} else {
|
||||
isc__nm_maybe_enqueue_ievent(worker,
|
||||
(isc__netievent_t *)ievent);
|
||||
}
|
||||
isc__nm_maybe_enqueue_ievent(&sock->mgr->workers[sock->tid],
|
||||
(isc__netievent_t *)ievent);
|
||||
}
|
||||
|
||||
void
|
||||
|
||||
Reference in New Issue
Block a user