java.lang.Object
com.oracle.libuv.Handle
com.oracle.libuv.TCPHandle
- All Implemented Interfaces:
java.io.Closeable,java.lang.AutoCloseable
public class TCPHandle extends Handle
-
Field Summary
Fields Modifier and Type Field Description protected booleanclosedprotected StreamCloseCallbackonCloseprotected StreamConnectCallbackonConnectprotected StreamConnectionCallbackonConnectionprotected StreamReadCallbackonReadprotected StreamShutdownCallbackonShutdownprotected StreamWriteCallbackonWriteprotected booleanreadStarted -
Method Summary
Modifier and Type Method Description intaccept(com.oracle.libuv.StreamHandle client)intbind(java.lang.String address, int port, boolean ipv6)protected voidcallClose()protected voidcallConnect(int status, java.lang.Exception error, java.lang.Object context)protected voidcallConnection(int status, java.lang.Exception error)protected voidcallRead(java.nio.ByteBuffer data)protected voidcallShutdown(int status, java.lang.Exception error, java.lang.Object context)protected voidcallWrite(int status, java.lang.Exception error, java.lang.Object context)voidclose()intcloseWrite()intconnect(java.lang.String address, int port, boolean ipv6)AddressgetPeerName()AddressgetSocketName()booleanisReadable()booleanisWritable()intlisten(int backlog)voidreadStart()voidreadStop()voidsetCloseCallback(StreamCloseCallback callback)voidsetConnectCallback(StreamConnectCallback callback)voidsetConnectionCallback(StreamConnectionCallback callback)intsetKeepAlive(boolean enable, int delay)intsetNoDelay(boolean enable)voidsetReadCallback(StreamReadCallback callback)voidsetShutdownCallback(StreamShutdownCallback callback)intsetSimultaneousAccepts(boolean enable)voidsetWriteCallback(StreamWriteCallback callback)intwrite(java.lang.String str)intwrite(java.lang.String str, java.nio.charset.Charset encoding)intwrite(java.nio.ByteBuffer buffer)intwrite(java.nio.ByteBuffer buffer, int offset, int length)longwriteQueueSize()
-
Field Details
-
closed
protected boolean closed -
readStarted
protected boolean readStarted -
onRead
-
onWrite
-
onConnect
-
onConnection
-
onClose
-
onShutdown
-
-
Method Details
-
bind
public int bind(java.lang.String address, int port, boolean ipv6) -
connect
public int connect(java.lang.String address, int port, boolean ipv6) -
listen
public int listen(int backlog) -
accept
public int accept(com.oracle.libuv.StreamHandle client) -
getSocketName
-
getPeerName
-
setNoDelay
public int setNoDelay(boolean enable) -
setKeepAlive
public int setKeepAlive(boolean enable, int delay) -
setSimultaneousAccepts
public int setSimultaneousAccepts(boolean enable) -
setReadCallback
-
setWriteCallback
-
setConnectCallback
-
setConnectionCallback
-
setCloseCallback
-
setShutdownCallback
-
readStart
public void readStart() -
readStop
public void readStop() -
write
public int write(java.lang.String str) -
write
public int write(java.lang.String str, java.nio.charset.Charset encoding) -
write
public int write(java.nio.ByteBuffer buffer, int offset, int length) -
write
public int write(java.nio.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(java.nio.ByteBuffer data) -
callWrite
protected void callWrite(int status, java.lang.Exception error, java.lang.Object context) -
callConnect
protected void callConnect(int status, java.lang.Exception error, java.lang.Object context) -
callConnection
protected void callConnection(int status, java.lang.Exception error) -
callClose
protected void callClose() -
callShutdown
protected void callShutdown(int status, java.lang.Exception error, java.lang.Object context)
-