io.apigee.trireme.kernel.handles

Class NetworkPeerPipe

java.lang.Object

io.apigee.trireme.kernel.handles.AbstractHandle

io.apigee.trireme.kernel.handles.NetworkPeerPipe

All Implemented Interfaces:

Handle, SocketHandle

public class NetworkPeerPipe
extends AbstractHandle
implements SocketHandle

Constructor Summary

Constructors

Constructor and Description
NetworkPeerPipe(GenericNodeRuntime runtime)

Method Summary

Modifier and Type	Method and Description
void	bind(java.lang.String address, int port)
void	close()
void	connect(java.lang.String host, int port, IOCompletionHandler<java.lang.Integer> handler)
protected void	doDrain()
NetworkPeerPipe	getPeer()
java.net.InetSocketAddress	getPeerName()
java.net.InetSocketAddress	getSockName()
int	getWritesOutstanding()
void	listen(int backlog, IOCompletionHandler<AbstractHandle> handler)
void	setKeepAlive(boolean nd)
void	setNoDelay(boolean nd)
void	setPeer(NetworkPeerPipe peer)
void	setPeerAddress(java.net.InetSocketAddress peerAddress)
void	setSocketAddress(java.net.InetSocketAddress socketAddress)
void	shutdown(IOCompletionHandler<java.lang.Integer> handler)
void	startReading(IOCompletionHandler<java.nio.ByteBuffer> handler)
void	stopReading()
int	write(java.nio.ByteBuffer buf, IOCompletionHandler<java.lang.Integer> handler)

Methods inherited from class io.apigee.trireme.kernel.handles.AbstractHandle

getReadHandler, setReadHandler, write, writeHandle, writeHandle

Methods inherited from class java.lang.Object

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

Methods inherited from interface io.apigee.trireme.kernel.handles.Handle

getReadHandler, setReadHandler, write, writeHandle, writeHandle

Constructor Detail

NetworkPeerPipe

public NetworkPeerPipe(GenericNodeRuntime runtime)

Method Detail

setSocketAddress

public void setSocketAddress(java.net.InetSocketAddress socketAddress)

setPeerAddress

public void setPeerAddress(java.net.InetSocketAddress peerAddress)

getPeer

public NetworkPeerPipe getPeer()

setPeer

public void setPeer(NetworkPeerPipe peer)

write

public int write(java.nio.ByteBuffer buf,
                 IOCompletionHandler<java.lang.Integer> handler)

Specified by:

write in interface Handle

Overrides:

write in class AbstractHandle

shutdown

public void shutdown(IOCompletionHandler<java.lang.Integer> handler)

Specified by:

shutdown in interface SocketHandle

close

public void close()

Specified by:

close in interface Handle

Specified by:

close in class AbstractHandle

startReading

public void startReading(IOCompletionHandler<java.nio.ByteBuffer> handler)

Specified by:

startReading in interface Handle

Overrides:

startReading in class AbstractHandle

stopReading

public void stopReading()

Specified by:

stopReading in interface Handle

Overrides:

stopReading in class AbstractHandle

getWritesOutstanding

public int getWritesOutstanding()

Specified by:

getWritesOutstanding in interface Handle

Overrides:

getWritesOutstanding in class AbstractHandle

doDrain

protected void doDrain()

getSockName

public java.net.InetSocketAddress getSockName()

Specified by:

getSockName in interface SocketHandle

getPeerName

public java.net.InetSocketAddress getPeerName()

Specified by:

getPeerName in interface SocketHandle

bind

public void bind(java.lang.String address,
                 int port)
          throws OSException

Specified by:

bind in interface SocketHandle

Throws:

OSException

listen

public void listen(int backlog,
                   IOCompletionHandler<AbstractHandle> handler)
            throws OSException

Specified by:

listen in interface SocketHandle

Throws:

OSException

connect

public void connect(java.lang.String host,
                    int port,
                    IOCompletionHandler<java.lang.Integer> handler)
             throws OSException

Specified by:

connect in interface SocketHandle

Throws:

OSException

setNoDelay

public void setNoDelay(boolean nd)

Specified by:

setNoDelay in interface SocketHandle

setKeepAlive

public void setKeepAlive(boolean nd)

Specified by:

setKeepAlive in interface SocketHandle