| Commit message (Collapse) | Author | Age | Files | Lines |
| |
|
|
|
|
|
|
| |
delete mode 100644 jstests/change_streams/error_label.js
create mode 100644 jstests/noPassthrough/change_stream_error_label.js
create mode 100644 jstests/sharding/change_stream_error_label.js
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
| |
create mode 100644 src/mongo/db/pipeline/process_interface/SConscript
rename src/mongo/db/pipeline/{process_interface_standalone.cpp => process_interface/common_mongod_process_interface.cpp} (72%)
rename src/mongo/db/pipeline/{process_interface_standalone.h => process_interface/common_mongod_process_interface.h} (69%)
rename src/mongo/db/pipeline/{mongo_process_common.cpp => process_interface/common_process_interface.cpp} (91%)
rename src/mongo/db/pipeline/{mongo_process_common.h => process_interface/common_process_interface.h} (91%)
rename src/mongo/db/pipeline/{ => process_interface}/mongo_process_interface.cpp (96%)
rename src/mongo/db/pipeline/{ => process_interface}/mongo_process_interface.h (100%)
rename src/mongo/db/pipeline/{process_interface_factory_mongod.cpp => process_interface/mongod_process_interface_factory.cpp} (84%)
rename src/mongo/db/pipeline/{ => process_interface}/mongos_process_interface.cpp (93%)
rename src/mongo/db/pipeline/{ => process_interface}/mongos_process_interface.h (97%)
rename src/mongo/db/pipeline/{ => process_interface}/mongos_process_interface_test.cpp (84%)
create mode 100644 src/mongo/db/pipeline/process_interface/non_shardsvr_process_interface.cpp
create mode 100644 src/mongo/db/pipeline/process_interface/non_shardsvr_process_interface.h
rename src/mongo/db/pipeline/{process_interface_shardsvr.cpp => process_interface/shardsvr_process_interface.cpp} (88%)
rename src/mongo/db/pipeline/{process_interface_shardsvr.h => process_interface/shardsvr_process_interface.h} (95%)
rename src/mongo/db/pipeline/{process_interface_standalone_test.cpp => process_interface/shardsvr_process_interface_test.cpp} (95%)
rename src/mongo/db/pipeline/{stub_mongo_process_interface_lookup_single_document.cpp => process_interface/stub_lookup_single_document_process_interface.cpp} (89%)
rename src/mongo/db/pipeline/{stub_mongo_process_interface_lookup_single_document.h => process_interface/stub_lookup_single_document_process_interface.h} (93%)
rename src/mongo/db/pipeline/{ => process_interface}/stub_mongo_process_interface.h (99%)
|
|
|
|
|
| |
create mode 100644 jstests/aggregation/sources/unionWith/unionWith.js
create mode 100644 jstests/noPassthrough/unionWith_sharded_unsharded_mix.js
|
|
|
|
| |
shard cannot be targeted for updateLookup
|
|
|
|
|
|
| |
Document/Value is now used throughout the query execution
engine, and therefore should move into the directory which
holds query execution code.
|
|
|
|
| |
resume logic
|
| |
|
| |
|
|
|
|
|
|
|
| |
This stage is distinguished from the Mock stage in that it doesn't
bother tracking state about which methods have been called. The queue
version is simpler and is used in production code (namely the update
system), whereas the mock is still preferred in testing environments.
|
|
|
|
| |
This commit also renames DocumentSourceMock::create to DocumentSourceMock::createForTest.
|
|
|
|
| |
collation inheritance for single-collection streams
|
|
|
|
| |
client token during resume
|
|
|
|
|
|
| |
Remove leading comments that are just stating the filename.
Move any file-level comments below the copyright banner.
Remove leading blank lines.
|
| |
|
|
|
|
| |
attachCursorSourceToPipeline
|
|
|
|
| |
foreign collection
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
stream documents have the same clusterTime as the resume token but lower-sorting UUIDs
|
|
|
|
| |
does not contain the shard key
|
|
|
|
| |
'$_resumeAfterClusterTime' in $changeStream
|
|
|
|
|
|
|
|
|
| |
log entries
with the same timestamps if the operations are coming from multiple shards. When we
resume the change stream we have to position to the right place - the position is determined
both by the timestamp and the document id. Previously we checked the timestamp only,
now we loop over the equal timestamps and find the right document.
|
|
|
|
|
|
| |
mongos against a sharded foreign collection"
This reverts commit 7298d273c0497f2720ec1471ad0f4910bff07af4.
|
|
|
|
| |
against a sharded foreign collection
|
|
|
|
|
|
| |
Similarly shorten other similar MongoProcessInterface implementation's
names, e.g. MongoSProcessInterface -> MongoSInterface and
MockMongoProcessInterface -> MockMongoInterface.
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
| |
|
|
|
|
| |
All users were converted to just use AssertionException.
|
| |
|
|
notifications from, which always errors if no entry with the given resumeToken exists
|