net.openhft.chronicle.tcp

Class SinkTcpInitiator

java.lang.Object

net.openhft.chronicle.tcp.SinkTcp

net.openhft.chronicle.tcp.SinkTcpInitiator

public class SinkTcpInitiator
extends SinkTcp

Field Summary

Fields inherited from class net.openhft.chronicle.tcp.SinkTcp

builder, logger, name, running

Constructor Summary

Constructors

Constructor and Description
SinkTcpInitiator(ChronicleQueueBuilder.ReplicaChronicleQueueBuilder builder)

Method Summary

Modifier and Type	Method and Description
String	debugString()
boolean	isLocalhost()
boolean	isOpen()
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()
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 net.openhft.chronicle.tcp.SinkTcp

close, open, open, toString

Methods inherited from class java.lang.Object

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

Constructor Detail

SinkTcpInitiator

public SinkTcpInitiator(ChronicleQueueBuilder.ReplicaChronicleQueueBuilder builder)

Method Detail

openSocketChannel

public SocketChannel openSocketChannel()
                                throws IOException

Specified by:

openSocketChannel in class SinkTcp

Throws:

IOException

isLocalhost

public boolean isLocalhost()

Specified by:

isLocalhost in class SinkTcp

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