org.eclipse.jetty.client

Class AbstractHttpClientTransport.ClientSelectorManager

java.lang.Object

org.eclipse.jetty.util.component.AbstractLifeCycle

org.eclipse.jetty.io.SelectorManager

org.eclipse.jetty.client.AbstractHttpClientTransport.ClientSelectorManager

All Implemented Interfaces:

Dumpable, LifeCycle

Enclosing class:

AbstractHttpClientTransport

protected class AbstractHttpClientTransport.ClientSelectorManager
extends SelectorManager

Nested Class Summary

Nested classes/interfaces inherited from class org.eclipse.jetty.io.SelectorManager

SelectorManager.ManagedSelector, SelectorManager.SelectableEndPoint

Nested classes/interfaces inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

AbstractLifeCycle.AbstractLifeCycleListener

Nested classes/interfaces inherited from interface org.eclipse.jetty.util.component.LifeCycle

LifeCycle.Listener

Field Summary

Fields inherited from class org.eclipse.jetty.io.SelectorManager

DEFAULT_CONNECT_TIMEOUT, LOG, SUBMIT_KEY_UPDATES

Fields inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

FAILED, RUNNING, STARTED, STARTING, STOPPED, STOPPING

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AbstractHttpClientTransport.ClientSelectorManager(HttpClient client, int selectors)

Method Summary

Methods

Modifier and Type	Method and Description
protected void	connectionFailed(SocketChannel channel, Throwable x, Object attachment) Callback method invoked when a non-blocking connect cannot be completed.
Connection	newConnection(SocketChannel channel, EndPoint endPoint, Object attachment) Factory method to create Connection.
protected EndPoint	newEndPoint(SocketChannel channel, SelectorManager.ManagedSelector selector, SelectionKey key) Factory method to create EndPoint.

Methods inherited from class org.eclipse.jetty.io.SelectorManager

accept, accept, accepted, acceptor, connect, connectionClosed, connectionOpened, doStart, doStop, dump, dump, endPointClosed, endPointOpened, execute, finishConnect, getConnectTimeout, getExecutor, getScheduler, getSelectorCount, getSelectorPriorityDelta, newSelector, setConnectTimeout, setSelectorPriorityDelta

Methods inherited from class org.eclipse.jetty.util.component.AbstractLifeCycle

addLifeCycleListener, getState, getState, getStopTimeout, isFailed, isRunning, isStarted, isStarting, isStopped, isStopping, removeLifeCycleListener, setStopTimeout, start, stop

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

AbstractHttpClientTransport.ClientSelectorManager

protected AbstractHttpClientTransport.ClientSelectorManager(HttpClient client,
                                                 int selectors)

Method Detail

newEndPoint

protected EndPoint newEndPoint(SocketChannel channel,
                   SelectorManager.ManagedSelector selector,
                   SelectionKey key)

Description copied from class: SelectorManager

Factory method to create EndPoint.

This method is invoked as a result of the registration of a channel via SelectorManager.connect(SocketChannel, Object) or SelectorManager.accept(SocketChannel).

Specified by:

newEndPoint in class SelectorManager

Parameters:

channel - the channel associated to the endpoint

selector - the selector the channel is registered to

key - the selection key

Returns:

a new endpoint

See Also:

SelectorManager.newConnection(SocketChannel, EndPoint, Object)

newConnection

public Connection newConnection(SocketChannel channel,
                       EndPoint endPoint,
                       Object attachment)
                         throws IOException

Description copied from class: SelectorManager

Factory method to create Connection.

Specified by:

newConnection in class SelectorManager

Parameters:

channel - the channel associated to the connection

endPoint - the endpoint

attachment - the attachment

Returns:

a new connection

Throws:

IOException

See Also:

SelectorManager.newEndPoint(SocketChannel, ManagedSelector, SelectionKey)

connectionFailed

protected void connectionFailed(SocketChannel channel,
                    Throwable x,
                    Object attachment)

Description copied from class: SelectorManager

Callback method invoked when a non-blocking connect cannot be completed.

By default it just logs with level warning.

Overrides:

connectionFailed in class SelectorManager

Parameters:

channel - the channel that attempted the connect

x - the exception that caused the connect to fail

attachment - the attachment object associated at registration