Package org.jboss.netty.channel.socket.http

Class HttpTunnelingClientSocketChannel

java.lang.Object

org.jboss.netty.channel.AbstractChannel

org.jboss.netty.channel.socket.http.HttpTunnelingClientSocketChannel

All Implemented Interfaces:

Comparable<Channel>, Channel, SocketChannel

class HttpTunnelingClientSocketChannel
extends AbstractChannel
implements SocketChannel

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
(package private) final class	HttpTunnelingClientSocketChannel.ServletChannelHandler

Field Summary

Fields

Modifier and Type	Field	Description
(package private) final HttpTunnelingSocketChannelConfig	config
private final HttpTunnelingClientSocketChannel.ServletChannelHandler	handler
(package private) final Object	interestOpsLock
(package private) final SocketChannel	realChannel
(package private) boolean	requestHeaderWritten

Fields inherited from interface org.jboss.netty.channel.Channel

OP_NONE, OP_READ, OP_READ_WRITE, OP_WRITE

Constructor Summary

Constructors

Constructor	Description
HttpTunnelingClientSocketChannel(ChannelFactory factory, ChannelPipeline pipeline, ChannelSink sink, ClientSocketChannelFactory clientSocketChannelFactory)

Method Summary

Modifier and Type	Method	Description
(package private) void	bindReal(SocketAddress localAddress, ChannelFuture future)
(package private) void	closeReal(ChannelFuture future)
(package private) void	connectReal(SocketAddress remoteAddress, ChannelFuture future)
(package private) void	disconnectReal(ChannelFuture future)
HttpTunnelingSocketChannelConfig	getConfig()	Returns the configuration of this channel.
int	getInterestOps()	Returns the current interestOps of this channel.
InetSocketAddress	getLocalAddress()	Returns the local address where this channel is bound to.
InetSocketAddress	getRemoteAddress()	Returns the remote address where this channel is connected to.
boolean	isBound()	Returns true if and only if this channel is bound to a local address.
boolean	isConnected()	Returns true if and only if this channel is connected to a remote address.
boolean	isWritable()	Returns true if and only if the I/O thread will perform the requested write operation immediately.
protected boolean	setClosed()	Marks this channel as closed.
(package private) void	setInterestOpsReal(int interestOps, ChannelFuture future)
(package private) void	unbindReal(ChannelFuture future)
ChannelFuture	write(Object message, SocketAddress remoteAddress)	Sends a message to this channel asynchronously.
private ChannelFuture	writeLastChunk()
(package private) void	writeReal(ChannelBuffer a, ChannelFuture future)

Methods inherited from class org.jboss.netty.channel.AbstractChannel

bind, close, compareTo, connect, disconnect, equals, getAttachment, getCloseFuture, getFactory, getId, getInternalInterestOps, getParent, getPipeline, getSucceededFuture, getUnsupportedOperationFuture, getUserDefinedWritability, hashCode, isOpen, isReadable, setAttachment, setInterestOps, setInternalInterestOps, setReadable, setUnwritable, setUserDefinedWritability, setWritable, toString, unbind, write

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.jboss.netty.channel.Channel

bind, close, connect, disconnect, getAttachment, getCloseFuture, getFactory, getId, getParent, getPipeline, getUserDefinedWritability, isOpen, isReadable, setAttachment, setInterestOps, setReadable, setUserDefinedWritability, unbind, write

Methods inherited from interface java.lang.Comparable

compareTo

Field Details

config

final HttpTunnelingSocketChannelConfig config

requestHeaderWritten

volatile boolean requestHeaderWritten

interestOpsLock

final Object interestOpsLock

realChannel

final SocketChannel realChannel

handler

private final HttpTunnelingClientSocketChannel.ServletChannelHandler handler

Constructor Details

HttpTunnelingClientSocketChannel

HttpTunnelingClientSocketChannel(ChannelFactory factory,
 ChannelPipeline pipeline,
 ChannelSink sink,
 ClientSocketChannelFactory clientSocketChannelFactory)

Method Details

getConfig

public HttpTunnelingSocketChannelConfig getConfig()

Description copied from interface: Channel

Returns the configuration of this channel.

Specified by:

getConfig in interface Channel

Specified by:

getConfig in interface SocketChannel

getLocalAddress

public InetSocketAddress getLocalAddress()

Description copied from interface: Channel

Returns the local address where this channel is bound to. The returned SocketAddress is supposed to be down-cast into more concrete type such as InetSocketAddress to retrieve the detailed information.

Specified by:

getLocalAddress in interface Channel

Specified by:

getLocalAddress in interface SocketChannel

Returns:

the local address of this channel. null if this channel is not bound.

getRemoteAddress

public InetSocketAddress getRemoteAddress()

Description copied from interface: Channel

Returns the remote address where this channel is connected to. The returned SocketAddress is supposed to be down-cast into more concrete type such as InetSocketAddress to retrieve the detailed information.

Specified by:

getRemoteAddress in interface Channel

Specified by:

getRemoteAddress in interface SocketChannel

Returns:

the remote address of this channel. null if this channel is not connected. If this channel is not connected but it can receive messages from arbitrary remote addresses (e.g. DatagramChannel, use MessageEvent.getRemoteAddress() to determine the origination of the received message as this method will return null.

isBound

public boolean isBound()

Description copied from interface: Channel

Returns true if and only if this channel is bound to a local address.

Specified by:

isBound in interface Channel

isConnected

public boolean isConnected()

Description copied from interface: Channel

Returns true if and only if this channel is connected to a remote address.

Specified by:

isConnected in interface Channel

getInterestOps

public int getInterestOps()

Description copied from interface: Channel

Returns the current interestOps of this channel.

Specified by:

getInterestOps in interface Channel

Overrides:

getInterestOps in class AbstractChannel

Returns:

Channel.OP_NONE, Channel.OP_READ, Channel.OP_WRITE, or Channel.OP_READ_WRITE

isWritable

public boolean isWritable()

Description copied from interface: Channel

Returns true if and only if the I/O thread will perform the requested write operation immediately. Any write requests made when this method returns false are queued until the I/O thread is ready to process the queued write requests. This method is a shortcut to the following code:

 return (getInterestOps() invalid input: '&' OP_WRITE) == 0;
 

Specified by:

isWritable in interface Channel

Overrides:

isWritable in class AbstractChannel

setClosed

protected boolean setClosed()

Description copied from class: AbstractChannel

Marks this channel as closed. This method is intended to be called by an internal component - please do not call it unless you know what you are doing.

Overrides:

setClosed in class AbstractChannel

Returns:

true if and only if this channel was not marked as closed yet

write

public ChannelFuture write(Object message,
 SocketAddress remoteAddress)

Description copied from interface: Channel

Sends a message to this channel asynchronously. It has an additional parameter that allows a user to specify where to send the specified message instead of this channel's current remote address. If this channel was created by a connectionless transport (e.g. DatagramChannel) and is not connected yet, you must specify non-null address. Otherwise, the write request will fail with NotYetConnectedException and an 'exceptionCaught' event will be triggered.

Specified by:

write in interface Channel

Overrides:

write in class AbstractChannel

Parameters:

message - the message to write

remoteAddress - where to send the specified message. This method is identical to Channel.write(Object) if null is specified here.

Returns:

the ChannelFuture which will be notified when the write request succeeds or fails

bindReal

void bindReal(SocketAddress localAddress,
 ChannelFuture future)

connectReal

void connectReal(SocketAddress remoteAddress,
 ChannelFuture future)

writeReal

void writeReal(ChannelBuffer a,
 ChannelFuture future)

writeLastChunk

private ChannelFuture writeLastChunk()

setInterestOpsReal

void setInterestOpsReal(int interestOps,
 ChannelFuture future)

disconnectReal

void disconnectReal(ChannelFuture future)

unbindReal

void unbindReal(ChannelFuture future)

closeReal

void closeReal(ChannelFuture future)