| Package | Description |
|---|---|
| com.mongodb |
Main package with core files.
|
| Modifier and Type | Field and Description |
|---|---|
private DBPort |
WriteResult._port |
private DBPort |
DBCollectionImpl.Run.RunExecutor.port |
(package private) DBPort |
DBTCPConnector.PinnedRequestStatus.requestPort |
| Modifier and Type | Method and Description |
|---|---|
protected DBPort |
DBPortPool.createNew()
Deprecated.
|
DBPort |
DBPortPool.get()
Deprecated.
|
(package private) DBPort |
DBTCPConnector.MyPort.get(boolean keep,
ReadPreference readPref,
ServerAddress hostNeeded) |
private DBPort |
DBTCPConnector.MyPort.getConnection(ServerSelector serverSelector) |
(package private) DBPort |
DBTCPConnector.MyPort.getPinnedRequestPortForThread() |
(package private) DBPort |
DBTCPConnector.getPort(ReadPreference readPreference)
Deprecated.
|
(package private) DBPort |
DBTCPConnector.getPrimaryPort()
Deprecated.
|
| Modifier and Type | Method and Description |
|---|---|
private WriteResult |
DBTCPConnector._checkWriteError(DB db,
DBPort port,
WriteConcern concern)
Deprecated.
|
void |
DBPortPool.cleanup(DBPort p)
Deprecated.
|
(package private) void |
DBTCPConnector.MyPort.done(DBPort port) |
(package private) <T> T |
DBTCPConnector.doOperation(DB db,
DBPort port,
DBPort.Operation<T> operation)
Deprecated.
|
(package private) void |
DBTCPConnector.MyPort.error(DBPort port,
java.lang.Throwable t)
call this method when there is an IOException or other low level error on port.
|
(package private) BulkWriteResult |
DBCollectionImpl.Run.execute(DBPort port) |
(package private) BulkWriteResult |
DBCollectionImpl.Run.executeInserts(java.util.List<InsertRequest> insertRequests,
DBPort port) |
(package private) BulkWriteResult |
DBCollectionImpl.Run.executeRemoves(java.util.List<RemoveRequest> removeRequests,
DBPort port) |
(package private) BulkWriteResult |
DBCollectionImpl.Run.executeReplaces(java.util.List<ModifyRequest> replaceRequests,
DBPort port) |
(package private) BulkWriteResult |
DBCollectionImpl.Run.executeUpdates(java.util.List<ModifyRequest> updateRequests,
DBPort port) |
private int |
DBCollectionImpl.getMaxWriteBatchSize(DBPort port) |
private MessageSettings |
DBCollectionImpl.getMessageSettings(DBPort port) |
private java.lang.Iterable<DBCollectionImpl.Run> |
DBCollectionImpl.getRunGenerator(boolean ordered,
java.lang.Boolean bypassDocumentValidation,
java.util.List<WriteRequest> writeRequests,
WriteConcern writeConcern,
DBEncoder encoder,
DBPort port) |
private BulkWriteResult |
DBCollectionImpl.insertWithCommandProtocol(java.util.List<DBObject> list,
WriteConcern writeConcern,
DBEncoder encoder,
DBPort port,
java.lang.Boolean bypassDocumentValidation) |
private WriteResult |
DBCollectionImpl.insertWithWriteProtocol(java.util.List<DBObject> list,
WriteConcern concern,
DBEncoder encoder,
DBPort port,
boolean shouldApply) |
private ServerDescription |
ServerMonitor.lookupServerDescription(DBPort connection) |
private boolean |
DBTCPConnector.MyPort.portIsAPrimary(DBPort pinnedRequestPort) |
private CommandResult |
DBCollectionImpl.receiveWriteCommandMessage(DBPort port) |
(package private) void |
DBTCPConnector.releasePort(DBPort port)
Deprecated.
|
private BulkWriteResult |
DBCollectionImpl.removeWithCommandProtocol(java.util.List<RemoveRequest> removeList,
WriteConcern writeConcern,
DBEncoder encoder,
DBPort port) |
(package private) WriteResult |
DBTCPConnector.say(DB db,
OutMessage m,
WriteConcern concern,
DBPort port)
Deprecated.
|
private BaseWriteCommandMessage |
DBCollectionImpl.sendWriteCommandMessage(BaseWriteCommandMessage message,
int batchNum,
DBPort port) |
(package private) void |
DBTCPConnector.MyPort.setPinnedRequestPortForThread(DBPort port) |
private void |
DBCollectionImpl.throwIfBypassDocumentValidationNotSupported(WriteConcern concern,
java.lang.Boolean bypassDocumentValidation,
DBPort port) |
private BulkWriteResult |
DBCollectionImpl.updateWithCommandProtocol(java.util.List<ModifyRequest> updates,
WriteConcern writeConcern,
java.lang.Boolean bypassDocumentValidation,
DBEncoder encoder,
DBPort port) |
private boolean |
DBCollectionImpl.useWriteCommands(WriteConcern concern,
DBPort port) |
private BulkWriteResult |
DBCollectionImpl.writeWithCommandProtocol(DBPort port,
WriteRequest.Type type,
BaseWriteCommandMessage message,
WriteConcern writeConcern) |
| Constructor and Description |
|---|
InUseConnectionBean(DBPort port,
long currentNanoTime)
Deprecated.
|
OrderedRunGenerator(java.util.List<WriteRequest> writeRequests,
java.lang.Boolean bypassDocumentValidation,
WriteConcern writeConcern,
DBEncoder encoder,
DBPort port) |
RunExecutor(DBPort port) |
UnorderedRunGenerator(java.util.List<WriteRequest> writeRequests,
java.lang.Boolean bypassDocumentValidation,
WriteConcern writeConcern,
DBEncoder encoder,
DBPort port) |
WriteResult(DB db,
DBPort p,
WriteConcern concern) |