com.oracle.libuv

Class TCPHandle

java.lang.Object

com.oracle.libuv.Handle

com.oracle.libuv.TCPHandle

All Implemented Interfaces:

Closeable, AutoCloseable

public class TCPHandle
extends Handle

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	closed
protected StreamCloseCallback	onClose
protected StreamConnectCallback	onConnect
protected StreamConnectionCallback	onConnection
protected StreamReadCallback	onRead
protected StreamShutdownCallback	onShutdown
protected StreamWriteCallback	onWrite
protected boolean	readStarted

Fields inherited from class com.oracle.libuv.Handle

loop, pointer

Method Summary

Modifier and Type	Method and Description
int	accept(com.oracle.libuv.StreamHandle client)
int	bind(String address, int port, boolean ipv6)
int	bind(String address, int port, boolean ipv6, EnumSet<TcpFlags> flags)
int	bind(String address, int port, boolean ipv6, int flags)
protected void	callClose()
protected void	callConnect(int status, Exception error, Object context)
protected void	callConnection(int status, Exception error)
protected void	callRead(ByteBuffer data)
protected void	callShutdown(int status, Exception error, Object context)
protected void	callWrite(int status, Exception error, Object context)
void	close()
int	closeWrite()
int	connect(String address, int port, boolean ipv6)
Address	getPeerName()
Address	getSocketName()
boolean	isReadable()
boolean	isWritable()
int	listen(int backlog)
void	readStart()
void	readStop()
void	setCloseCallback(StreamCloseCallback callback)
void	setConnectCallback(StreamConnectCallback callback)
void	setConnectionCallback(StreamConnectionCallback callback)
int	setKeepAlive(boolean enable, int delay)
int	setNoDelay(boolean enable)
void	setReadCallback(StreamReadCallback callback)
void	setShutdownCallback(StreamShutdownCallback callback)
int	setSimultaneousAccepts(boolean enable)
void	setWriteCallback(StreamWriteCallback callback)
int	write(ByteBuffer buffer)
int	write(ByteBuffer buffer, int offset, int length)
int	write(String str)
int	write(String str, Charset encoding)
long	writeQueueSize()

Methods inherited from class com.oracle.libuv.Handle

equals, hashCode, isClosing, ref, toString, unref

Methods inherited from class java.lang.Object

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

Field Detail

closed

protected boolean closed

readStarted

protected boolean readStarted

onRead

protected StreamReadCallback onRead

onWrite

protected StreamWriteCallback onWrite

onConnect

protected StreamConnectCallback onConnect

onConnection

protected StreamConnectionCallback onConnection

onClose

protected StreamCloseCallback onClose

onShutdown

protected StreamShutdownCallback onShutdown

Method Detail

bind

public int bind(String address,
                int port,
                boolean ipv6)

bind

public int bind(String address,
                int port,
                boolean ipv6,
                EnumSet<TcpFlags> flags)

bind

public int bind(String address,
                int port,
                boolean ipv6,
                int flags)

connect

public int connect(String address,
                   int port,
                   boolean ipv6)

listen

public int listen(int backlog)

accept

public int accept(com.oracle.libuv.StreamHandle client)

getSocketName

public Address getSocketName()

getPeerName

public Address getPeerName()

setNoDelay

public int setNoDelay(boolean enable)

setKeepAlive

public int setKeepAlive(boolean enable,
                        int delay)

setSimultaneousAccepts

public int setSimultaneousAccepts(boolean enable)

setReadCallback

public void setReadCallback(StreamReadCallback callback)

setWriteCallback

public void setWriteCallback(StreamWriteCallback callback)

setConnectCallback

public void setConnectCallback(StreamConnectCallback callback)

setConnectionCallback

public void setConnectionCallback(StreamConnectionCallback callback)

setCloseCallback

public void setCloseCallback(StreamCloseCallback callback)

setShutdownCallback

public void setShutdownCallback(StreamShutdownCallback callback)

readStart

public void readStart()

readStop

public void readStop()

write

public int write(String str)

write

public int write(String str,
                 Charset encoding)

write

public int write(ByteBuffer buffer,
                 int offset,
                 int length)

write

public int write(ByteBuffer buffer)

closeWrite

public int closeWrite()

close

public void close()

isReadable

public boolean isReadable()

isWritable

public boolean isWritable()

writeQueueSize

public long writeQueueSize()

callRead

protected void callRead(ByteBuffer data)

callWrite

protected void callWrite(int status,
                         Exception error,
                         Object context)

callConnect

protected void callConnect(int status,
                           Exception error,
                           Object context)

callConnection

protected void callConnection(int status,
                              Exception error)

callClose

protected void callClose()

callShutdown

protected void callShutdown(int status,
                            Exception error,
                            Object context)