public class ClientPutComplexDirMessage extends ClientPutDirMessage
ClientPutComplexDir < ... standard ClientPutDir headers ... > Files.0.Name=hello.txt Files.0.UploadFrom=direct Files.0.Metadata.ContentType=text/plain Files.0.DataLength=6 ( upload the 6 bytes following this message as hello.txt, type plain text) Files.1.Name=something.pdf Files.1.UploadFrom=disk Files.1.Filename=something.pdf ( upload something.pdf, guess the mime type from the filename ) Files.2.Name=toad.jpeg Files.2.UploadFrom=redirect Files.2.TargetURI=CHK@...,...,... Files.2.Metadata.ContentType=image/jpeg ( not yet supported, but would be really useful! FIXME ! ) (note that the Files.x must always be a decimal integer. We use these for sort order for UploadFrom=direct. they must be sequential and start at 0). ... End <data from above direct uploads, ***in alphabetical order***>
forkOnCacheableBUILD, 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 |
|---|
ClientPutComplexDirMessage(SimpleFieldSet fs,
BucketFactory bfTemp,
PersistentTempBucketFactory bfPersistent) |
| Modifier and Type | Method and Description |
|---|---|
java.lang.String |
getName() |
void |
readFrom(java.io.InputStream is,
BucketFactory bf,
FCPServer server) |
void |
run(FCPConnectionHandler handler,
Node node)
Do whatever it is that we do with this type of message.
|
protected void |
writeData(java.io.OutputStream os) |
getFieldSetsendcreate, create, withListRequestIdentifierpublic ClientPutComplexDirMessage(SimpleFieldSet fs, BucketFactory bfTemp, PersistentTempBucketFactory bfPersistent) throws MessageInvalidException
MessageInvalidExceptionpublic java.lang.String getName()
getName in class FCPMessagepublic 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 void run(FCPConnectionHandler handler, Node node) throws MessageInvalidException
FCPMessagerun in class FCPMessageMessageInvalidException