public class SinkTcpInitiator extends SinkTcp
Constructor and Description |
---|
SinkTcpInitiator(ChronicleQueueBuilder.ReplicaChronicleQueueBuilder builder) |
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) |
public SinkTcpInitiator(ChronicleQueueBuilder.ReplicaChronicleQueueBuilder builder)
public SocketChannel openSocketChannel() throws IOException
openSocketChannel
in class SinkTcp
IOException
public boolean isLocalhost()
isLocalhost
in class SinkTcp
protected void setSocketChannel(SocketChannel socketChannel) throws IOException
IOException
public SocketChannel socketChannel()
public boolean isOpen()
public String debugString()
public int write(ByteBuffer buffer) throws IOException
IOException
public void writeAllOrEOF(net.openhft.lang.io.DirectByteBufferBytes bb) throws IOException
IOException
public void writeAllOrEOF(ByteBuffer bb) throws IOException
IOException
public void writeAll(net.openhft.lang.io.DirectByteBufferBytes bb) throws IOException
IOException
public void writeAll(ByteBuffer bb) throws IOException
IOException
public int read(ByteBuffer buffer) throws IOException
IOException
public boolean read(ByteBuffer buffer, int size) throws IOException
IOException
public boolean read(ByteBuffer buffer, int threshod, int size) throws IOException
IOException
public boolean read(ByteBuffer buffer, int threshod, int size, int readCount) throws IOException
IOException
public boolean readAtLeast(ByteBuffer buffer, int size, int readCount) throws IOException
IOException
public boolean readAllOrNone(ByteBuffer buffer, int readCount) throws IOException
IOException
public void readFullyOrEOF(@NotNull ByteBuffer bb) throws IOException
IOException
public void readAvailable(@NotNull ByteBuffer bb) throws IOException
IOException
public boolean readUpTo(ByteBuffer buffer, int size, int readCount) throws IOException
IOException
public void writeSizeAndIndex(ByteBuffer buffer, int action, long index) throws IOException
IOException
public void writeAction(ByteBuffer buffer, long action, long index) throws IOException
IOException
Copyright © 2017. All rights reserved.