public abstract class DataCarryingMessage extends BaseDataCarryingMessage
Modifier and Type | Field and Description |
---|---|
protected Bucket |
bucket
If this is a message from the client, then the Bucket was created by createBucket() and
will be a RandomAccessBucket.
|
protected boolean |
freeOnSent |
BUILD, BULK_CHK_INSERT_REJECTS, BULK_CHK_REQUEST_REJECTS, BULK_SSK_INSERT_REJECTS, BULK_SSK_REQUEST_REJECTS, CODE, HTL, IDENTIFIER, LINK_LENGTHS, LOCAL, LOCATION, OUTPUT_BANDWIDTH, OUTPUT_BANDWIDTH_CLASS, OVERALL_BULK_OUTPUT_CAPACITY_USAGE, PROBE_IDENTIFIER, STORE_SIZE, TYPE, UPTIME_PERCENT
Constructor and Description |
---|
DataCarryingMessage() |
Modifier and Type | Method and Description |
---|---|
RandomAccessBucket |
getRandomAccessBucket()
Should only be called from code parsing a message sent to us, in which case Bucket will be a
RandomAccessBucket, which it needs to be as it's likely to be inserted.
|
void |
readFrom(java.io.InputStream is,
BucketFactory bf,
FCPServer server) |
protected void |
writeData(java.io.OutputStream os) |
send
create, create, getFieldSet, getName, run, withListRequestIdentifier
protected Bucket bucket
protected boolean freeOnSent
public void readFrom(java.io.InputStream is, BucketFactory bf, FCPServer server) throws java.io.IOException, MessageInvalidException
readFrom
in class BaseDataCarryingMessage
java.io.IOException
MessageInvalidException
protected void writeData(java.io.OutputStream os) throws java.io.IOException
writeData
in class BaseDataCarryingMessage
java.io.IOException
public RandomAccessBucket getRandomAccessBucket()