Modifier and Type | Method and Description |
---|---|
Connection |
ALPNClientConnectionFactory.newConnection(EndPoint endPoint,
Map<String,Object> context) |
Constructor and Description |
---|
ALPNClientConnection(EndPoint endPoint,
Executor executor,
ClientConnectionFactory connectionFactory,
SSLEngine sslEngine,
Map<String,Object> context,
String protocol) |
Modifier and Type | Method and Description |
---|---|
protected AbstractConnection |
ALPNServerConnectionFactory.newServerConnection(Connector connector,
EndPoint endPoint,
SSLEngine engine,
List<String> protocols,
String defaultProtocol) |
Constructor and Description |
---|
ALPNServerConnection(Connector connector,
EndPoint endPoint,
SSLEngine engine,
List<String> protocols,
String defaultProtocol) |
Modifier and Type | Method and Description |
---|---|
protected EndPoint |
AbstractHttpClientTransport.ClientSelectorManager.newEndPoint(SocketChannel channel,
SelectorManager.ManagedSelector selector,
SelectionKey key) |
Modifier and Type | Method and Description |
---|---|
Connection |
Socks4Proxy.Socks4ProxyClientConnectionFactory.newConnection(EndPoint endPoint,
Map<String,Object> context) |
Connection |
HttpProxy.HttpProxyClientConnectionFactory.newConnection(EndPoint endPoint,
Map<String,Object> context) |
Connection |
AbstractHttpClientTransport.ClientSelectorManager.newConnection(SocketChannel channel,
EndPoint endPoint,
Object attachment) |
Modifier and Type | Method and Description |
---|---|
Connection |
HttpClientTransportOverHTTP.newConnection(EndPoint endPoint,
Map<String,Object> context) |
Constructor and Description |
---|
HttpConnectionOverHTTP(EndPoint endPoint,
HttpDestination destination) |
Modifier and Type | Method and Description |
---|---|
Connection |
HttpClientTransportOverFCGI.newConnection(EndPoint endPoint,
Map<String,Object> context) |
Constructor and Description |
---|
HttpConnectionOverFCGI(EndPoint endPoint,
HttpDestination destination,
boolean multiplexed) |
Constructor and Description |
---|
Flusher(EndPoint endPoint) |
Modifier and Type | Method and Description |
---|---|
Connection |
ServerFCGIConnectionFactory.newConnection(Connector connector,
EndPoint endPoint) |
Constructor and Description |
---|
HttpChannelOverFCGI(Connector connector,
HttpConfiguration configuration,
EndPoint endPoint,
HttpTransport transport,
HttpInput<ByteBuffer> input) |
ServerFCGIConnection(Connector connector,
EndPoint endPoint,
HttpConfiguration configuration,
boolean sendStatus200) |
Modifier and Type | Interface and Description |
---|---|
static interface |
SelectorManager.SelectableEndPoint
A
SelectorManager.SelectableEndPoint is an EndPoint that wish to be notified of
non-blocking events by the SelectorManager.ManagedSelector . |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEndPoint |
class |
ByteArrayEndPoint
ByteArrayEndPoint.
|
class |
ChannelEndPoint
Channel End Point.
|
class |
NetworkTrafficSelectChannelEndPoint |
class |
SelectChannelEndPoint
An ChannelEndpoint that can be scheduled by
SelectorManager . |
Modifier and Type | Method and Description |
---|---|
EndPoint |
Connection.getEndPoint() |
EndPoint |
AbstractConnection.getEndPoint() |
protected abstract EndPoint |
SelectorManager.newEndPoint(SocketChannel channel,
SelectorManager.ManagedSelector selector,
SelectionKey selectionKey)
Factory method to create
EndPoint . |
Modifier and Type | Method and Description |
---|---|
void |
SelectorManager.ManagedSelector.destroyEndPoint(EndPoint endPoint) |
protected void |
SelectorManager.endPointClosed(EndPoint endpoint)
Callback method invoked when an endpoint is closed.
|
protected void |
SelectorManager.endPointOpened(EndPoint endpoint)
Callback method invoked when an endpoint is opened.
|
Connection |
ClientConnectionFactory.newConnection(EndPoint endPoint,
Map<String,Object> context) |
abstract Connection |
SelectorManager.newConnection(SocketChannel channel,
EndPoint endpoint,
Object attachment)
Factory method to create
Connection . |
Constructor and Description |
---|
AbstractConnection(EndPoint endp,
Executor executor) |
AbstractConnection(EndPoint endp,
Executor executor,
boolean executeOnfillable) |
NegotiatingClientConnection(EndPoint endp,
Executor executor,
SSLEngine sslEngine,
ClientConnectionFactory connectionFactory,
Map<String,Object> context) |
WriteFlusher(EndPoint endPoint) |
Modifier and Type | Class and Description |
---|---|
class |
SslConnection.DecryptedEndPoint |
Modifier and Type | Method and Description |
---|---|
Connection |
SslClientConnectionFactory.newConnection(EndPoint endPoint,
Map<String,Object> context) |
protected SslConnection |
SslClientConnectionFactory.newSslConnection(ByteBufferPool byteBufferPool,
Executor executor,
EndPoint endPoint,
SSLEngine engine) |
Constructor and Description |
---|
SslConnection(ByteBufferPool byteBufferPool,
Executor executor,
EndPoint endPoint,
SSLEngine sslEngine) |
Modifier and Type | Method and Description |
---|---|
Collection<EndPoint> |
MavenServerConnector.getConnectedEndPoints() |
Modifier and Type | Method and Description |
---|---|
protected EndPoint |
ConnectHandler.ConnectManager.newEndPoint(SocketChannel channel,
SelectorManager.ManagedSelector selector,
SelectionKey selectionKey) |
Modifier and Type | Method and Description |
---|---|
Connection |
ConnectHandler.ConnectManager.newConnection(SocketChannel channel,
EndPoint endpoint,
Object attachment) |
protected ConnectHandler.DownstreamConnection |
ConnectHandler.newDownstreamConnection(EndPoint endPoint,
ConcurrentMap<String,Object> context,
ByteBuffer buffer) |
protected ConnectHandler.UpstreamConnection |
ConnectHandler.newUpstreamConnection(EndPoint endPoint,
ConnectHandler.ConnectContext connectContext) |
protected abstract int |
ProxyConnection.read(EndPoint endPoint,
ByteBuffer buffer) |
protected int |
ConnectHandler.read(EndPoint endPoint,
ByteBuffer buffer)
Reads (with non-blocking semantic) into the given
buffer from the given endPoint . |
protected int |
ConnectHandler.UpstreamConnection.read(EndPoint endPoint,
ByteBuffer buffer) |
protected int |
ConnectHandler.DownstreamConnection.read(EndPoint endPoint,
ByteBuffer buffer) |
protected abstract void |
ProxyConnection.write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback) |
protected void |
ConnectHandler.write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback)
Writes (with non-blocking semantic) the given buffer of data onto the given endPoint.
|
protected void |
ConnectHandler.UpstreamConnection.write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback) |
protected void |
ConnectHandler.DownstreamConnection.write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback) |
Constructor and Description |
---|
ConnectHandler.DownstreamConnection(EndPoint endPoint,
Executor executor,
ByteBufferPool bufferPool,
ConcurrentMap<String,Object> context,
ByteBuffer buffer) |
ConnectHandler.UpstreamConnection(EndPoint endPoint,
Executor executor,
ByteBufferPool bufferPool,
ConnectHandler.ConnectContext connectContext) |
ProxyConnection(EndPoint endp,
Executor executor,
ByteBufferPool bufferPool,
ConcurrentMap<String,Object> context) |
Modifier and Type | Class and Description |
---|---|
class |
LocalConnector.LocalEndPoint |
Modifier and Type | Method and Description |
---|---|
EndPoint |
HttpChannel.getEndPoint() |
Modifier and Type | Method and Description |
---|---|
Collection<EndPoint> |
Connector.getConnectedEndPoints() |
Collection<EndPoint> |
AbstractConnector.getConnectedEndPoints() |
Modifier and Type | Method and Description |
---|---|
protected AbstractConnection |
AbstractConnectionFactory.configure(AbstractConnection connection,
Connector connector,
EndPoint endPoint) |
Connection |
SslConnectionFactory.newConnection(Connector connector,
EndPoint endPoint) |
Connection |
NegotiatingServerConnectionFactory.newConnection(Connector connector,
EndPoint endPoint) |
Connection |
HttpConnectionFactory.newConnection(Connector connector,
EndPoint endPoint) |
Connection |
ConnectionFactory.newConnection(Connector connector,
EndPoint endPoint)
Creates a new
Connection with the given parameters |
protected abstract AbstractConnection |
NegotiatingServerConnectionFactory.newServerConnection(Connector connector,
EndPoint endPoint,
SSLEngine engine,
List<String> protocols,
String defaultProtocol) |
protected SslConnection |
SslConnectionFactory.newSslConnection(Connector connector,
EndPoint endPoint,
SSLEngine engine) |
protected void |
AbstractConnector.onEndPointClosed(EndPoint endp) |
protected void |
AbstractConnector.onEndPointOpened(EndPoint endp) |
Constructor and Description |
---|
HttpChannel(Connector connector,
HttpConfiguration configuration,
EndPoint endPoint,
HttpTransport transport,
HttpInput<T> input) |
HttpConnection.HttpChannelOverHttp(Connector connector,
HttpConfiguration config,
EndPoint endPoint,
HttpTransport transport,
HttpInput<ByteBuffer> input) |
HttpConnection(HttpConfiguration config,
Connector connector,
EndPoint endPoint) |
NegotiatingServerConnection(Connector connector,
EndPoint endPoint,
SSLEngine engine,
List<String> protocols,
String defaultProtocol) |
Constructor and Description |
---|
StandardSession(short version,
ByteBufferPool bufferPool,
Scheduler scheduler,
Controller controller,
EndPoint endPoint,
IdleListener idleListener,
int initialStreamId,
SessionFrameListener listener,
Generator generator,
FlowControlStrategy flowControlStrategy) |
Modifier and Type | Method and Description |
---|---|
Connection |
SPDYClientConnectionFactory.newConnection(EndPoint endPoint,
Map<String,Object> context) |
Connection |
NPNClientConnectionFactory.newConnection(EndPoint endPoint,
Map<String,Object> context) |
Constructor and Description |
---|
NPNClientConnection(EndPoint endPoint,
Executor executor,
ClientConnectionFactory connectionFactory,
SSLEngine sslEngine,
Map<String,Object> context,
String protocol) |
SPDYConnection(EndPoint endPoint,
ByteBufferPool bufferPool,
Parser parser,
Executor executor,
boolean dispatchIO) |
SPDYConnection(EndPoint endPoint,
ByteBufferPool bufferPool,
Parser parser,
Executor executor,
boolean dispatchIO,
int bufferSize) |
Modifier and Type | Method and Description |
---|---|
Connection |
HttpClientTransportOverSPDY.newConnection(EndPoint endPoint,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
Connection |
SPDYServerConnectionFactory.newConnection(Connector connector,
EndPoint endPoint) |
protected AbstractConnection |
NPNServerConnectionFactory.newServerConnection(Connector connector,
EndPoint endPoint,
SSLEngine engine,
List<String> protocols,
String defaultProtocol) |
protected ServerSessionFrameListener |
SPDYServerConnectionFactory.provideServerSessionFrameListener(Connector connector,
EndPoint endPoint) |
Constructor and Description |
---|
NPNServerConnection(EndPoint endPoint,
SSLEngine engine,
Connector connector,
List<String> protocols,
String defaultProtocol) |
Modifier and Type | Method and Description |
---|---|
protected ServerSessionFrameListener |
HTTPSPDYServerConnectionFactory.provideServerSessionFrameListener(Connector connector,
EndPoint endPoint) |
Constructor and Description |
---|
HttpChannelOverSPDY(Connector connector,
HttpConfiguration configuration,
EndPoint endPoint,
HttpTransport transport,
HttpInputOverSPDY input,
Stream stream) |
HttpTransportOverSPDY(Connector connector,
HttpConfiguration configuration,
EndPoint endPoint,
PushStrategy pushStrategy,
Stream stream,
Fields requestHeaders) |
Modifier and Type | Method and Description |
---|---|
Connection |
ProxyHTTPConnectionFactory.newConnection(Connector connector,
EndPoint endPoint) |
Constructor and Description |
---|
ProxyHTTPSPDYConnection(Connector connector,
HttpConfiguration config,
EndPoint endPoint,
short version,
ProxyEngineSelector proxyEngineSelector) |
Modifier and Type | Method and Description |
---|---|
protected EndPoint |
WebSocketClientSelectorManager.newEndPoint(SocketChannel channel,
SelectorManager.ManagedSelector selectSet,
SelectionKey selectionKey) |
Modifier and Type | Method and Description |
---|---|
Connection |
WebSocketClientSelectorManager.newConnection(SocketChannel channel,
EndPoint endPoint,
Object attachment) |
UpgradeConnection |
WebSocketClientSelectorManager.newUpgradeConnection(SocketChannel channel,
EndPoint endPoint,
ConnectPromise connectPromise) |
Constructor and Description |
---|
UpgradeConnection(EndPoint endp,
Executor executor,
ConnectPromise connectPromise) |
WebSocketClientConnection(EndPoint endp,
Executor executor,
ConnectPromise connectPromise,
WebSocketPolicy policy) |
Constructor and Description |
---|
AbstractWebSocketConnection(EndPoint endp,
Executor executor,
Scheduler scheduler,
WebSocketPolicy policy,
ByteBufferPool bufferPool) |
FrameFlusher(ByteBufferPool bufferPool,
Generator generator,
EndPoint endpoint,
int bufferSize,
int maxGather) |
Constructor and Description |
---|
WebSocketServerConnection(EndPoint endp,
Executor executor,
Scheduler scheduler,
WebSocketPolicy policy,
ByteBufferPool bufferPool) |
Copyright © 1995-2015 Webtide. All Rights Reserved.