class OutMessage extends BasicBSONEncoder
| Modifier and Type | Class and Description |
|---|---|
(package private) static class |
OutMessage.OpCode |
| Modifier and Type | Field and Description |
|---|---|
private PoolOutputBuffer |
_buffer |
private DBCollection |
_collection |
private DBEncoder |
_encoder |
private int |
_id |
private int |
_maxBSONObjectSize |
private Mongo |
_mongo |
private int |
_numDocuments |
private OutMessage.OpCode |
_opCode |
private DBObject |
_query |
private int |
_queryOptions |
(package private) static java.util.concurrent.atomic.AtomicInteger |
REQUEST_ID |
_buf| Modifier | Constructor and Description |
|---|---|
private |
OutMessage(DBCollection collection,
DBEncoder enc,
DBObject query,
int options,
ReadPreference readPref,
int maxBSONObjectSize) |
private |
OutMessage(DBCollection collection,
Mongo m,
OutMessage.OpCode opCode,
DBEncoder enc) |
private |
OutMessage(DBCollection collection,
Mongo m,
OutMessage.OpCode opCode,
DBEncoder enc,
DBObject query,
int options,
ReadPreference readPref,
int maxBSONObjectSize) |
private |
OutMessage(DBCollection collection,
OutMessage.OpCode opCode) |
private |
OutMessage(DBCollection collection,
OutMessage.OpCode opCode,
DBEncoder enc) |
private |
OutMessage(DBCollection collection,
OutMessage.OpCode opCode,
DBEncoder enc,
DBObject query) |
private |
OutMessage(Mongo m,
OutMessage.OpCode opCode) |
| Modifier and Type | Method and Description |
|---|---|
(package private) void |
doneWithMessage() |
(package private) int |
getId() |
(package private) static OutMessage |
getMore(DBCollection collection,
long cursorId,
int batchSize) |
(package private) java.lang.String |
getNamespace() |
(package private) int |
getNumDocuments() |
(package private) OutMessage.OpCode |
getOpCode() |
(package private) DBObject |
getQuery() |
(package private) boolean |
hasOption(int option) |
static OutMessage |
insert(DBCollection collection,
DBEncoder encoder,
WriteConcern concern) |
(package private) static OutMessage |
killCursors(Mongo mongo,
int numCursors) |
(package private) void |
pipe(java.io.OutputStream out) |
(package private) void |
prepare() |
int |
putObject(BSONObject o)
Encodes a
BSONObject. |
(package private) static OutMessage |
query(DBCollection collection,
int options,
int numToSkip,
int batchSize,
DBObject query,
DBObject fields,
int maxBSONObjectSize) |
(package private) static OutMessage |
query(DBCollection collection,
int options,
int numToSkip,
int batchSize,
DBObject query,
DBObject fields,
ReadPreference readPref,
DBEncoder enc) |
(package private) static OutMessage |
query(DBCollection collection,
int options,
int numToSkip,
int batchSize,
DBObject query,
DBObject fields,
ReadPreference readPref,
DBEncoder enc,
int maxBSONObjectSize) |
static OutMessage |
remove(DBCollection collection,
DBEncoder encoder,
DBObject query,
boolean multi) |
(package private) int |
size() |
static OutMessage |
update(DBCollection collection,
DBEncoder encoder,
boolean upsert,
boolean multi,
DBObject query,
DBObject o) |
private void |
writeGetMore(long cursorId,
int batchSize) |
private void |
writeInsertPrologue(WriteConcern concern) |
private void |
writeKillCursorsPrologue(int numCursors) |
private void |
writeMessagePrologue(OutMessage.OpCode opCode) |
private void |
writeQuery(DBObject fields,
int numToSkip,
int batchSize) |
private void |
writeRemove(boolean multi) |
private void |
writeUpdate(boolean upsert,
boolean multi,
DBObject query,
DBObject o) |
_put, _put, _putObjectField, _putValueString, done, encode, getOutputBuffer, handleSpecialObjects, putBinary, putBinary, putBoolean, putCode, putCodeWScope, putDate, putNull, putNumber, putObject, putObjectId, putSpecial, putString, putSymbol, putTimestamp, putUndefined, putUUID, set, writeCString, writeInt, writeLongstatic java.util.concurrent.atomic.AtomicInteger REQUEST_ID
private final Mongo _mongo
private final DBCollection _collection
private PoolOutputBuffer _buffer
private final int _id
private final OutMessage.OpCode _opCode
private final int _queryOptions
private final DBObject _query
private final DBEncoder _encoder
private final int _maxBSONObjectSize
private volatile int _numDocuments
private OutMessage(Mongo m, OutMessage.OpCode opCode)
private OutMessage(DBCollection collection, OutMessage.OpCode opCode)
private OutMessage(DBCollection collection, OutMessage.OpCode opCode, DBEncoder enc)
private OutMessage(DBCollection collection, Mongo m, OutMessage.OpCode opCode, DBEncoder enc)
private OutMessage(DBCollection collection, OutMessage.OpCode opCode, DBEncoder enc, DBObject query)
private OutMessage(DBCollection collection, DBEncoder enc, DBObject query, int options, ReadPreference readPref, int maxBSONObjectSize)
private OutMessage(DBCollection collection, Mongo m, OutMessage.OpCode opCode, DBEncoder enc, DBObject query, int options, ReadPreference readPref, int maxBSONObjectSize)
public static OutMessage insert(DBCollection collection, DBEncoder encoder, WriteConcern concern)
public static OutMessage update(DBCollection collection, DBEncoder encoder, boolean upsert, boolean multi, DBObject query, DBObject o)
public static OutMessage remove(DBCollection collection, DBEncoder encoder, DBObject query, boolean multi)
static OutMessage query(DBCollection collection, int options, int numToSkip, int batchSize, DBObject query, DBObject fields, int maxBSONObjectSize)
static OutMessage query(DBCollection collection, int options, int numToSkip, int batchSize, DBObject query, DBObject fields, ReadPreference readPref, DBEncoder enc)
static OutMessage query(DBCollection collection, int options, int numToSkip, int batchSize, DBObject query, DBObject fields, ReadPreference readPref, DBEncoder enc, int maxBSONObjectSize)
static OutMessage getMore(DBCollection collection, long cursorId, int batchSize)
static OutMessage killCursors(Mongo mongo, int numCursors)
private void writeInsertPrologue(WriteConcern concern)
private void writeRemove(boolean multi)
private void writeGetMore(long cursorId,
int batchSize)
private void writeKillCursorsPrologue(int numCursors)
private void writeQuery(DBObject fields, int numToSkip, int batchSize)
private void writeMessagePrologue(OutMessage.OpCode opCode)
void prepare()
void pipe(java.io.OutputStream out) throws java.io.IOException
java.io.IOExceptionint size()
void doneWithMessage()
boolean hasOption(int option)
int getId()
OutMessage.OpCode getOpCode()
DBObject getQuery()
java.lang.String getNamespace()
int getNumDocuments()
public int putObject(BSONObject o)
BasicBSONEncoderBSONObject. This is for the higher level api calls.putObject in interface BSONEncoderputObject in class BasicBSONEncodero - the document to encode