com.oracle.libuv.handles

Class PipeHandle

java.lang.Object

com.oracle.libuv.handles.Handle

com.oracle.libuv.handles.PipeHandle

All Implemented Interfaces:

Closeable, AutoCloseable

public class PipeHandle
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.handles.Handle

loop, pointer

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	PipeHandle(LoopHandle loop, boolean ipc)
protected	PipeHandle(LoopHandle loop, long pointer, boolean ipc)

Method Summary

Modifier and Type	Method and Description
int	accept(com.oracle.libuv.handles.StreamHandle client)
int	bind(String name)
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()
void	connect(String name)
boolean	isReadable()
boolean	isWritable()
int	listen(int backlog)
int	open(int fd)
void	readStart()
void	readStop()
void	setCloseCallback(StreamCloseCallback callback)
void	setConnectCallback(StreamConnectCallback callback)
void	setConnectionCallback(StreamConnectionCallback callback)
void	setReadCallback(StreamReadCallback callback)
void	setShutdownCallback(StreamShutdownCallback callback)
void	setWriteCallback(StreamWriteCallback callback)
int	write(ByteBuffer buffer)
int	write(ByteBuffer buffer, int offset, int length)
int	write(String str)
int	write(String str, String encoding)
int	writeLowerBytes(String str)
long	writeQueueSize()

Methods inherited from class com.oracle.libuv.handles.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

Constructor Detail

PipeHandle

protected PipeHandle(LoopHandle loop,
                     boolean ipc)

PipeHandle

protected PipeHandle(LoopHandle loop,
                     long pointer,
                     boolean ipc)

Method Detail

open

public int open(int fd)

bind

public int bind(String name)

accept

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

connect

public void connect(String name)

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,
                 String encoding)
          throws UnsupportedEncodingException

Throws:

UnsupportedEncodingException

writeLowerBytes

public int writeLowerBytes(String str)

write

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

write

public int write(ByteBuffer buffer)

closeWrite

public int closeWrite()

close

public void close()

listen

public int listen(int backlog)

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)