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 void
copy(Socket4Adapter sock, java.io.OutputStream rawout, int length, boolean update)
protected void
copy(java.io.InputStream rawin, Socket4Adapter sock, boolean update)
double
getStatus()
abstract void
processClient(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:
getStatus
in 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
-
-