Package com.db4o.cs.internal.messages
Class MsgBlob
- java.lang.Object
-
- com.db4o.cs.internal.messages.Msg
-
- com.db4o.cs.internal.messages.MsgD
-
- com.db4o.cs.internal.messages.MsgBlob
-
- All Implemented Interfaces:
BlobStatus,Message,java.lang.Cloneable
- Direct Known Subclasses:
MDeleteBlobFile,MReadBlob,MWriteBlob
public abstract class MsgBlob extends MsgD implements BlobStatus
-
-
Field Summary
Fields Modifier and Type Field Description BlobImpl_blob-
Fields inherited from class com.db4o.cs.internal.messages.Msg
CLASS_ID, CLASS_META, CLASS_METADATA_ID_FOR_NAME, CLASS_NAME_FOR_ID, CLOSE, CLOSE_SOCKET, COMMIT, COMMIT_REPLICATION, COMMIT_SYSTEMTRANS, COMMITTED_CALLBACK_REGISTER, COMMITTED_INFO, CREATE_CLASS, CURRENT_VERSION, DELETE, DELETE_BLOB_FILE, ERROR, FAILED, GENERATE_TRANSACTION_TIMESTAMP, GET_ALL, GET_CLASSES, GET_INTERNAL_IDS, GET_THREAD_ID, ID_LIST, IDENTITY, INSTANCE_COUNT, IS_ALIVE, LENGTH, LOGIN, LOGIN_OK, NULL, OBJECT_BY_UUID, OBJECT_TO_CLIENT, OBJECTSET_FETCH, OBJECTSET_FINALIZED, OBJECTSET_GET_ID, OBJECTSET_INDEXOF, OBJECTSET_RESET, OBJECTSET_SIZE, OK, PING, PONG, PREFETCH_IDS, PROCESS_DELETES, QUERY_EXECUTE, QUERY_RESULT, RAISE_COMMIT_TIMESTAMP, READ_BLOB, READ_BYTES, READ_MULTIPLE_OBJECTS, READ_OBJECT, READ_READER_BY_ID, READ_SLOT, RELEASE_SEMAPHORE, REQUEST_EXCEPTION_WITH_RESPONSE, REQUEST_EXCEPTION_WITHOUT_RESPONSE, ROLLBACK, RUNTIME_EXCEPTION, SET_SEMAPHORE, SUCCESS, SWITCH_TO_FILE, SWITCH_TO_MAIN_FILE, TA_DELETE, TA_IS_DELETED, USE_DEFAULT_TRANSACTION_TIMESTAMP, USE_TRANSACTION, USER_MESSAGE, VERSION_FOR_ID, WRITE_BATCHED_MESSAGES, WRITE_BLOB, WRITE_NEW, WRITE_UPDATE
-
-
Constructor Summary
Constructors Constructor Description MsgBlob()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method Description protected voidcopy(Socket4Adapter sock, java.io.OutputStream rawout, int length, boolean update)protected voidcopy(java.io.InputStream rawin, Socket4Adapter sock, boolean update)doublegetStatus()abstract voidprocessClient(Socket4Adapter socket)-
Methods inherited from class com.db4o.cs.internal.messages.MsgD
getByteLoad, getWriter, getWriter, getWriterForBuffer, getWriterForByte, getWriterForInt, getWriterForIntArray, getWriterForInts, getWriterForIntSequence, getWriterForIntString, getWriterForLength, getWriterForLong, getWriterForLongs, getWriterForSingleObject, getWriterForString, payLoad, payLoad, readBoolean, readBytes, readInt, readLong, readObjectFromPayLoad, readSingleObject, readString, writeBytes, writeInt, writeLong, writeString
-
Methods inherited from class com.db4o.cs.internal.messages.Msg
checkParentTransaction, clientMessageDispatcher, config, container, containerLock, equals, getMessage, hashCode, localContainer, logMsg, messageDispatcher, postProcessAtServer, publicClone, readMessage, readMessageBuffer, readMessageBuffer, respondInt, serverMessageDispatcher, serverTransaction, setMessageDispatcher, setTransaction, systemTransaction, toString, transaction, write, write, writeException
-
-
-
-
Field Detail
-
_blob
public BlobImpl _blob
-
-
Method Detail
-
getStatus
public double getStatus()
- Specified by:
getStatusin interfaceBlobStatus
-
processClient
public abstract void processClient(Socket4Adapter socket) throws java.io.IOException
- Throws:
java.io.IOException
-
copy
protected void copy(Socket4Adapter sock, java.io.OutputStream rawout, int length, boolean update) throws java.io.IOException
- Throws:
java.io.IOException
-
copy
protected void copy(java.io.InputStream rawin, Socket4Adapter sock, boolean update) throws java.io.IOException- Throws:
java.io.IOException
-
-