net.openhft.chronicle.tcp

Class SinkTcp

java.lang.Object

net.openhft.chronicle.tcp.SinkTcp

Direct Known Subclasses:

SinkTcpAcceptor, SinkTcpInitiator

public abstract class SinkTcp
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
protected ChronicleQueueBuilder.ReplicaChronicleQueueBuilder	builder
protected org.slf4j.Logger	logger
protected String	name
protected AtomicBoolean	running

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	SinkTcp(String name, ChronicleQueueBuilder.ReplicaChronicleQueueBuilder builder)

Method Summary

Modifier and Type	Method and Description
void	close()
String	debugString()
abstract boolean	isLocalhost()
boolean	isOpen()
boolean	open()
boolean	open(boolean blocking)
protected abstract SocketChannel	openSocketChannel()
int	read(ByteBuffer buffer)
boolean	read(ByteBuffer buffer, int size)
boolean	read(ByteBuffer buffer, int threshod, int size)
boolean	read(ByteBuffer buffer, int threshod, int size, int readCount)
boolean	readAllOrNone(ByteBuffer buffer, int readCount)
boolean	readAtLeast(ByteBuffer buffer, int size, int readCount)
void	readAvailable(ByteBuffer bb)
void	readFullyOrEOF(ByteBuffer bb)
boolean	readUpTo(ByteBuffer buffer, int size, int readCount)
protected void	setSocketChannel(SocketChannel socketChannel)
SocketChannel	socketChannel()
String	toString()
int	write(ByteBuffer buffer)
void	writeAction(ByteBuffer buffer, long action, long index)
void	writeAll(ByteBuffer bb)
void	writeAll(net.openhft.lang.io.DirectByteBufferBytes bb)
void	writeAllOrEOF(ByteBuffer bb)
void	writeAllOrEOF(net.openhft.lang.io.DirectByteBufferBytes bb)
void	writeSizeAndIndex(ByteBuffer buffer, int action, long index)

Methods inherited from class java.lang.Object

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

Field Detail

logger

protected final org.slf4j.Logger logger

name

protected final String name

running

protected final AtomicBoolean running

builder

protected final ChronicleQueueBuilder.ReplicaChronicleQueueBuilder builder

Constructor Detail

SinkTcp

protected SinkTcp(String name,
                  ChronicleQueueBuilder.ReplicaChronicleQueueBuilder builder)

Method Detail

toString

public String toString()

Overrides:

toString in class Object

open

public boolean open()
             throws IOException

Throws:

IOException

open

public boolean open(boolean blocking)
             throws IOException

Throws:

IOException

close

public void close()
           throws IOException

Throws:

IOException

isLocalhost

public abstract boolean isLocalhost()

openSocketChannel

protected abstract SocketChannel openSocketChannel()
                                            throws IOException

Throws:

IOException

setSocketChannel

protected void setSocketChannel(SocketChannel socketChannel)
                         throws IOException

Throws:

IOException

socketChannel

public SocketChannel socketChannel()

isOpen

public boolean isOpen()

debugString

public String debugString()

write

public int write(ByteBuffer buffer)
          throws IOException

Throws:

IOException

writeAllOrEOF

public void writeAllOrEOF(net.openhft.lang.io.DirectByteBufferBytes bb)
                   throws IOException

Throws:

IOException

writeAllOrEOF

public void writeAllOrEOF(ByteBuffer bb)
                   throws IOException

Throws:

IOException

writeAll

public void writeAll(net.openhft.lang.io.DirectByteBufferBytes bb)
              throws IOException

Throws:

IOException

writeAll

public void writeAll(ByteBuffer bb)
              throws IOException

Throws:

IOException

read

public int read(ByteBuffer buffer)
         throws IOException

Throws:

IOException

read

public boolean read(ByteBuffer buffer,
                    int size)
             throws IOException

Throws:

IOException

read

public boolean read(ByteBuffer buffer,
                    int threshod,
                    int size)
             throws IOException

Throws:

IOException

read

public boolean read(ByteBuffer buffer,
                    int threshod,
                    int size,
                    int readCount)
             throws IOException

Throws:

IOException

readAtLeast

public boolean readAtLeast(ByteBuffer buffer,
                           int size,
                           int readCount)
                    throws IOException

Throws:

IOException

readAllOrNone

public boolean readAllOrNone(ByteBuffer buffer,
                             int readCount)
                      throws IOException

Throws:

IOException

readFullyOrEOF

public void readFullyOrEOF(@NotNull
                           ByteBuffer bb)
                    throws IOException

Throws:

IOException

readAvailable

public void readAvailable(@NotNull
                          ByteBuffer bb)
                   throws IOException

Throws:

IOException

readUpTo

public boolean readUpTo(ByteBuffer buffer,
                        int size,
                        int readCount)
                 throws IOException

Throws:

IOException

writeSizeAndIndex

public void writeSizeAndIndex(ByteBuffer buffer,
                              int action,
                              long index)
                       throws IOException

Throws:

IOException

writeAction

public void writeAction(ByteBuffer buffer,
                        long action,
                        long index)
                 throws IOException

Throws:

IOException