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,
List<String> protocols) |
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(SelectableChannel channel,
ManagedSelector selector,
SelectionKey key) |
Modifier and Type | Method and Description |
---|---|
Connection |
Socks4Proxy.Socks4ProxyClientConnectionFactory.newConnection(EndPoint endPoint,
Map<String,Object> context) |
Connection |
AbstractHttpClientTransport.ClientSelectorManager.newConnection(SelectableChannel channel,
EndPoint endPoint,
Object attachment) |
Modifier and Type | Method and Description |
---|---|
Connection |
HttpClientTransportOverHTTP.newConnection(EndPoint endPoint,
Map<String,Object> context) |
protected HttpConnectionOverHTTP |
HttpClientTransportOverHTTP.newHttpConnection(EndPoint endPoint,
HttpDestination destination,
Promise<Connection> promise) |
Constructor and Description |
---|
HttpConnectionOverHTTP(EndPoint endPoint,
HttpDestination destination,
Promise<Connection> promise) |
Modifier and Type | Method and Description |
---|---|
Connection |
HttpClientTransportOverFCGI.newConnection(EndPoint endPoint,
Map<String,Object> context) |
protected HttpConnectionOverFCGI |
HttpClientTransportOverFCGI.newHttpConnection(EndPoint endPoint,
HttpDestination destination,
Promise<Connection> promise) |
Constructor and Description |
---|
HttpConnectionOverFCGI(EndPoint endPoint,
HttpDestination destination,
Promise<Connection> promise,
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) |
ServerFCGIConnection(Connector connector,
EndPoint endPoint,
HttpConfiguration configuration,
boolean sendStatus200) |
Modifier and Type | Method and Description |
---|---|
EndPoint |
HTTP2Session.getEndPoint() |
Constructor and Description |
---|
HTTP2Connection(ByteBufferPool byteBufferPool,
Executor executor,
EndPoint endPoint,
Parser parser,
ISession session,
int bufferSize) |
HTTP2Session(Scheduler scheduler,
EndPoint endPoint,
Generator generator,
Session.Listener listener,
FlowControlStrategy flowControl,
int initialStreamId) |
Modifier and Type | Method and Description |
---|---|
Connection |
HTTP2ClientConnectionFactory.newConnection(EndPoint endPoint,
Map<String,Object> context) |
Constructor and Description |
---|
HTTP2ClientSession(Scheduler scheduler,
EndPoint endPoint,
Generator generator,
Session.Listener listener,
FlowControlStrategy flowControl) |
Modifier and Type | Method and Description |
---|---|
Connection |
HttpClientTransportOverHTTP2.newConnection(EndPoint endPoint,
Map<String,Object> context) |
Modifier and Type | Method and Description |
---|---|
Connection |
AbstractHTTP2ServerConnectionFactory.newConnection(Connector connector,
EndPoint endPoint) |
protected ServerSessionListener |
RawHTTP2ServerConnectionFactory.newSessionListener(Connector connector,
EndPoint endPoint) |
protected ServerSessionListener |
HTTP2ServerConnectionFactory.newSessionListener(Connector connector,
EndPoint endPoint) |
protected abstract ServerSessionListener |
AbstractHTTP2ServerConnectionFactory.newSessionListener(Connector connector,
EndPoint endPoint) |
Connection |
HTTP2CServerConnectionFactory.upgradeConnection(Connector connector,
EndPoint endPoint,
MetaData.Request request,
HttpFields response101) |
Constructor and Description |
---|
HTTP2ServerConnection(ByteBufferPool byteBufferPool,
Executor executor,
EndPoint endPoint,
HttpConfiguration httpConfig,
ServerParser parser,
ISession session,
int inputBufferSize,
ServerSessionListener listener) |
HTTP2ServerSession(Scheduler scheduler,
EndPoint endPoint,
Generator generator,
ServerSessionListener listener,
FlowControlStrategy flowControl) |
HttpChannelOverHTTP2(Connector connector,
HttpConfiguration configuration,
EndPoint endPoint,
HttpTransportOverHTTP2 transport) |
HTTPServerSessionListener(Connector connector,
EndPoint endPoint) |
Modifier and Type | Class and Description |
---|---|
class |
AbstractEndPoint |
class |
ByteArrayEndPoint
ByteArrayEndPoint.
|
class |
ChannelEndPoint
Channel End Point.
|
class |
NetworkTrafficSelectChannelEndPoint |
class |
SelectChannelEndPoint
Deprecated.
use
SocketChannelEndPoint instead |
class |
SocketChannelEndPoint |
Modifier and Type | Method and Description |
---|---|
EndPoint |
Connection.getEndPoint() |
EndPoint |
AbstractConnection.getEndPoint() |
protected abstract EndPoint |
SelectorManager.newEndPoint(SelectableChannel channel,
ManagedSelector selector,
SelectionKey selectionKey)
Factory method to create
EndPoint . |
Modifier and Type | Method and Description |
---|---|
void |
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(SelectableChannel channel,
EndPoint endpoint,
Object attachment)
Factory method to create
Connection . |
Constructor and Description |
---|
AbstractConnection(EndPoint endp,
Executor executor) |
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(SelectableChannel channel,
ManagedSelector selector,
SelectionKey key) |
Modifier and Type | Method and Description |
---|---|
Connection |
ConnectHandler.ConnectManager.newConnection(SelectableChannel channel,
EndPoint endpoint,
Object attachment) |
protected ConnectHandler.DownstreamConnection |
ConnectHandler.newDownstreamConnection(EndPoint endPoint,
ConcurrentMap<String,Object> context) |
protected ConnectHandler.UpstreamConnection |
ConnectHandler.newUpstreamConnection(EndPoint endPoint,
ConnectHandler.ConnectContext connectContext) |
protected abstract int |
ProxyConnection.read(EndPoint endPoint,
ByteBuffer buffer) |
protected int |
ConnectHandler.UpstreamConnection.read(EndPoint endPoint,
ByteBuffer buffer) |
protected int |
ConnectHandler.DownstreamConnection.read(EndPoint endPoint,
ByteBuffer buffer) |
protected int |
ConnectHandler.read(EndPoint endPoint,
ByteBuffer buffer,
ConcurrentMap<String,Object> context)
Reads (with non-blocking semantic) into the given
buffer from the given endPoint . |
protected abstract void |
ProxyConnection.write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback) |
protected void |
ConnectHandler.UpstreamConnection.write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback) |
protected void |
ConnectHandler.DownstreamConnection.write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback) |
protected void |
ConnectHandler.write(EndPoint endPoint,
ByteBuffer buffer,
Callback callback,
ConcurrentMap<String,Object> context)
Writes (with non-blocking semantic) the given buffer of data onto the given endPoint.
|
Constructor and Description |
---|
DownstreamConnection(EndPoint endPoint,
Executor executor,
ByteBufferPool bufferPool,
ConcurrentMap<String,Object> context) |
ProxyConnection(EndPoint endp,
Executor executor,
ByteBufferPool bufferPool,
ConcurrentMap<String,Object> context) |
UpstreamConnection(EndPoint endPoint,
Executor executor,
ByteBufferPool bufferPool,
ConnectHandler.ConnectContext connectContext) |
Modifier and Type | Class and Description |
---|---|
class |
LocalConnector.LocalEndPoint
Local EndPoint
|
static class |
ProxyConnectionFactory.ProxyEndPoint |
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 |
SslConnectionFactory.configure(AbstractConnection connection,
Connector connector,
EndPoint endPoint) |
protected AbstractConnection |
AbstractConnectionFactory.configure(AbstractConnection connection,
Connector connector,
EndPoint endPoint) |
protected void |
ServerConnector.ServerConnectorManager.endPointClosed(EndPoint endpoint) |
protected void |
ServerConnector.ServerConnectorManager.endPointOpened(EndPoint endpoint) |
Connection |
SslConnectionFactory.newConnection(Connector connector,
EndPoint endPoint) |
Connection |
ProxyConnectionFactory.newConnection(Connector connector,
EndPoint endp) |
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 |
Connection |
ServerConnector.ServerConnectorManager.newConnection(SelectableChannel channel,
EndPoint endpoint,
Object attachment) |
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) |
Connection |
ConnectionFactory.Upgrading.upgradeConnection(Connector connector,
EndPoint endPoint,
MetaData.Request upgradeRequest,
HttpFields responseFields)
Create a connection for an upgrade request.
|
Constructor and Description |
---|
HttpChannel(Connector connector,
HttpConfiguration configuration,
EndPoint endPoint,
HttpTransport transport) |
HttpChannelOverHttp(HttpConnection httpConnection,
Connector connector,
HttpConfiguration config,
EndPoint endPoint,
HttpTransport transport) |
HttpConnection(HttpConfiguration config,
Connector connector,
EndPoint endPoint,
HttpCompliance compliance,
boolean recordComplianceViolations) |
NegotiatingServerConnection(Connector connector,
EndPoint endPoint,
SSLEngine engine,
List<String> protocols,
String defaultProtocol) |
ProxyEndPoint(EndPoint endp,
InetSocketAddress remote,
InetSocketAddress local) |
ProxyProtocolV1Connection(EndPoint endp,
Connector connector,
String next,
ByteBuffer buffer) |
ProxyProtocolV1orV2Connection(EndPoint endp,
Connector connector,
String next) |
ProxyProtocolV2Connection(EndPoint endp,
Connector connector,
String next,
ByteBuffer buffer) |
Modifier and Type | Class and Description |
---|---|
class |
UnixSocketEndPoint |
Modifier and Type | Method and Description |
---|---|
protected EndPoint |
UnixSocketConnector.UnixSocketConnectorManager.newEndPoint(SelectableChannel channel,
ManagedSelector selector,
SelectionKey selectionKey) |
Modifier and Type | Method and Description |
---|---|
protected void |
UnixSocketConnector.UnixSocketConnectorManager.endPointClosed(EndPoint endpoint) |
protected void |
UnixSocketConnector.UnixSocketConnectorManager.endPointOpened(EndPoint endpoint) |
Connection |
UnixSocketConnector.UnixSocketConnectorManager.newConnection(SelectableChannel channel,
EndPoint endpoint,
Object attachment) |
Constructor and Description |
---|
WebSocketClientConnection(EndPoint endp,
Executor executor,
Scheduler scheduler,
WebSocketPolicy websocketPolicy,
ByteBufferPool bufferPool) |
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–2017 Webtide. All rights reserved.