public abstract class MsgBlob extends MsgD implements BlobStatus
| Modifier and Type | Field and Description |
|---|---|
BlobImpl |
_blob |
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 and Description |
|---|
MsgBlob() |
| Modifier and Type | Method and Description |
|---|---|
protected void |
copy(java.io.InputStream rawin,
Socket4Adapter sock,
boolean update) |
protected void |
copy(Socket4Adapter sock,
java.io.OutputStream rawout,
int length,
boolean update) |
double |
getStatus() |
abstract void |
processClient(Socket4Adapter socket) |
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, writeStringcheckParentTransaction, 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, writeExceptionpublic BlobImpl _blob
public double getStatus()
getStatus in interface BlobStatuspublic abstract void processClient(Socket4Adapter socket) throws java.io.IOException
java.io.IOExceptionprotected void copy(Socket4Adapter sock, java.io.OutputStream rawout, int length, boolean update) throws java.io.IOException
java.io.IOExceptionprotected void copy(java.io.InputStream rawin,
Socket4Adapter sock,
boolean update)
throws java.io.IOException
java.io.IOException