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) |
sendcreate, create, getFieldSet, getName, run, withListRequestIdentifierprotected Bucket bucket
protected boolean freeOnSent
public void readFrom(java.io.InputStream is,
BucketFactory bf,
FCPServer server)
throws java.io.IOException,
MessageInvalidException
readFrom in class BaseDataCarryingMessagejava.io.IOExceptionMessageInvalidExceptionprotected void writeData(java.io.OutputStream os)
throws java.io.IOException
writeData in class BaseDataCarryingMessagejava.io.IOExceptionpublic RandomAccessBucket getRandomAccessBucket()