Merge remote-tracking branch 'origin/jetty-9.3.x' into jetty-9.4.x
This commit is contained in:
commit
71c78db60e
|
@ -203,10 +203,10 @@ public class ManagedSelector extends ContainerLifeCycle implements Dumpable
|
|||
{
|
||||
EndPoint endPoint = _selectorManager.newEndPoint(channel, this, selectionKey);
|
||||
endPoint.onOpen();
|
||||
_selectorManager.endPointOpened(endPoint);
|
||||
Connection connection = _selectorManager.newConnection(channel, endPoint, selectionKey.attachment());
|
||||
endPoint.setConnection(connection);
|
||||
selectionKey.attach(endPoint);
|
||||
_selectorManager.endPointOpened(endPoint);
|
||||
_selectorManager.connectionOpened(connection);
|
||||
if (LOG.isDebugEnabled())
|
||||
LOG.debug("Created {}", endPoint);
|
||||
|
|
|
@ -203,11 +203,12 @@ public class LocalConnector extends AbstractConnector
|
|||
if (LOG.isDebugEnabled())
|
||||
LOG.debug("accepting {}", acceptorID);
|
||||
LocalEndPoint endPoint = _connects.take();
|
||||
endPoint.onOpen();
|
||||
onEndPointOpened(endPoint);
|
||||
|
||||
Connection connection = getDefaultConnectionFactory().newConnection(this, endPoint);
|
||||
endPoint.setConnection(connection);
|
||||
|
||||
endPoint.onOpen();
|
||||
onEndPointOpened(endPoint);
|
||||
|
||||
connection.onOpen();
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue