public class DataServerMessage extends Object
Modifier and Type | Field and Description |
---|---|
static short |
DATA_SERVER_REQUEST_MESSAGE |
static short |
DATA_SERVER_RESPONSE_MESSAGE |
Modifier and Type | Method and Description |
---|---|
void |
checkReady() |
void |
close() |
static DataServerMessage |
createBlockRequestMessage() |
static DataServerMessage |
createBlockRequestMessage(long blockId) |
static DataServerMessage |
createBlockRequestMessage(long blockId,
long offset,
long len) |
static DataServerMessage |
createBlockResponseMessage(boolean toSend,
long blockId) |
static DataServerMessage |
createBlockResponseMessage(boolean toSend,
long blockId,
long offset,
long len) |
boolean |
finishSending() |
long |
getBlockId() |
long |
getLength() |
long |
getOffset() |
ByteBuffer |
getReadOnlyData() |
boolean |
isMessageReady() |
int |
recv(SocketChannel socketChannel) |
void |
send(SocketChannel socketChannel) |
public static final short DATA_SERVER_REQUEST_MESSAGE
public static final short DATA_SERVER_RESPONSE_MESSAGE
public static DataServerMessage createBlockRequestMessage()
public static DataServerMessage createBlockRequestMessage(long blockId)
public static DataServerMessage createBlockRequestMessage(long blockId, long offset, long len)
public static DataServerMessage createBlockResponseMessage(boolean toSend, long blockId)
public static DataServerMessage createBlockResponseMessage(boolean toSend, long blockId, long offset, long len)
public void close()
public int recv(SocketChannel socketChannel) throws IOException
IOException
public void send(SocketChannel socketChannel) throws IOException
IOException
public boolean finishSending()
public boolean isMessageReady()
public void checkReady()
public long getBlockId()
public long getOffset()
public long getLength()
public ByteBuffer getReadOnlyData()
Copyright © 2014. All rights reserved.