| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/s/write_ops/ |
| H A D | batched_command_request.cpp | 75 BatchedCommandRequest BatchedCommandRequest::parseInsert(const OpMsgRequest& request) { in parseInsert()
79 BatchedCommandRequest BatchedCommandRequest::parseUpdate(const OpMsgRequest& request) { in parseUpdate()
83 BatchedCommandRequest BatchedCommandRequest::parseDelete(const OpMsgRequest& request) { in parseDelete()
112 case BatchedCommandRequest::BatchType_Insert: in sizeWriteOps()
114 case BatchedCommandRequest::BatchType_Update: in sizeWriteOps()
116 case BatchedCommandRequest::BatchType_Delete: in sizeWriteOps()
122 bool BatchedCommandRequest::isVerboseWC() const { in isVerboseWC()
146 case BatchedCommandRequest::BatchType_Insert: in serialize()
168 BSONObj BatchedCommandRequest::toBSON() const { in toBSON()
179 BatchedCommandRequest BatchedCommandRequest::cloneInsertWithIds( in cloneInsertWithIds()
[all …]
|
| H A D | batched_command_request.h | 46 class BatchedCommandRequest {
50 BatchedCommandRequest(write_ops::Insert insertOp) in BatchedCommandRequest() function
54 BatchedCommandRequest(write_ops::Update updateOp) in BatchedCommandRequest() function
58 BatchedCommandRequest(write_ops::Delete deleteOp) in BatchedCommandRequest() function
62 BatchedCommandRequest(BatchedCommandRequest&&) = default;
64 static BatchedCommandRequest parseInsert(const OpMsgRequest& request);
135 static BatchedCommandRequest cloneInsertWithIds(BatchedCommandRequest origCmdRequest);
157 BatchItemRef(const BatchedCommandRequest* request, int itemIndex) in BatchItemRef()
160 const BatchedCommandRequest* getRequest() const { in getRequest()
168 BatchedCommandRequest::BatchType getOpType() const { in getOpType()
[all …]
|
| H A D | batched_command_request_test.cpp | 42 TEST(BatchedCommandRequest, BasicInsert) { in TEST() argument
56 const auto insertRequest(BatchedCommandRequest::parseInsert(opMsgRequest)); in TEST()
63 TEST(BatchedCommandRequest, InsertWithShardVersion) { in TEST() argument
81 const auto insertRequest(BatchedCommandRequest::parseInsert(opMsgRequest)); in TEST()
89 TEST(BatchedCommandRequest, InsertCloneWithIds) { in TEST() argument
90 BatchedCommandRequest batchedRequest([&] { in TEST()
103 const auto clonedRequest(BatchedCommandRequest::cloneInsertWithIds(std::move(batchedRequest))); in TEST()
121 TEST(BatchedCommandRequest, IndexInsertCloneWithIds) { in TEST() argument
127 BatchedCommandRequest batchedRequest([&] { in TEST()
134 const auto clonedRequest(BatchedCommandRequest::cloneInsertWithIds(std::move(batchedRequest))); in TEST()
|
| H A D | batch_write_op.cpp | 384 BatchedCommandRequest BatchWriteOp::buildBatchRequest( in buildBatchRequest()
401 case BatchedCommandRequest::BatchType_Insert: in buildBatchRequest()
407 case BatchedCommandRequest::BatchType_Update: in buildBatchRequest()
413 case BatchedCommandRequest::BatchType_Delete: in buildBatchRequest()
429 BatchedCommandRequest request([&] { in buildBatchRequest()
431 case BatchedCommandRequest::BatchType_Insert: in buildBatchRequest()
432 return BatchedCommandRequest([&] { in buildBatchRequest()
437 case BatchedCommandRequest::BatchType_Update: in buildBatchRequest()
438 return BatchedCommandRequest([&] { in buildBatchRequest()
443 case BatchedCommandRequest::BatchType_Delete: in buildBatchRequest()
[all …]
|
| H A D | batch_write_exec_test.cpp | 102 const auto actualBatchedInsert(BatchedCommandRequest::parseInsert(opMsgRequest)); in expectInsertsReturnSuccess()
196 BatchedCommandRequest request([&] { in TEST_F()
233 BatchedCommandRequest request([&] { in TEST_F()
267 BatchedCommandRequest request([&] { in TEST_F()
303 BatchedCommandRequest request([&] { in TEST_F()
334 BatchedCommandRequest request([&] { in TEST_F()
371 BatchedCommandRequest request([&] { in TEST_F()
416 BatchedCommandRequest request([&] { in TEST_F()
450 BatchedCommandRequest request([&] { in TEST_F()
489 BatchedCommandRequest request([&] { in TEST_F()
[all …]
|
| H A D | batch_write_op_test.cpp | 141 BatchedCommandRequest request([&] { in TEST_F()
174 BatchedCommandRequest request([&] { in TEST_F()
213 BatchedCommandRequest request([&] { in TEST_F()
247 BatchedCommandRequest request([&] { in TEST_F()
289 BatchedCommandRequest request([&] { in TEST_F()
344 BatchedCommandRequest request([&] { in TEST_F()
381 BatchedCommandRequest request([&] { in TEST_F()
425 BatchedCommandRequest request([&] { in TEST_F()
492 BatchedCommandRequest request([&] { in TEST_F()
538 BatchedCommandRequest request([&] { in TEST_F()
[all …]
|
| H A D | write_op_test.cpp | 72 BatchedCommandRequest request([&] { in TEST()
97 BatchedCommandRequest request([&] { in TEST()
133 BatchedCommandRequest request([&] { in TEST()
172 BatchedCommandRequest request([&] { in TEST()
217 BatchedCommandRequest request([&] { in TEST()
258 BatchedCommandRequest request([&] { in TEST()
297 BatchedCommandRequest request([&] { in TEST()
|
| H A D | batch_write_op.h | 123 BatchWriteOp(OperationContext* opCtx, const BatchedCommandRequest& clientRequest);
149 BatchedCommandRequest buildBatchRequest(const TargetedWriteBatch& targetedBatch) const;
207 const BatchedCommandRequest& _clientRequest;
|
| H A D | write_op.cpp | 61 if (_itemRef.getOpType() == BatchedCommandRequest::BatchType_Insert) { in targetWrites()
73 } else if (_itemRef.getOpType() == BatchedCommandRequest::BatchType_Update) { in targetWrites()
75 } else if (_itemRef.getOpType() == BatchedCommandRequest::BatchType_Delete) { in targetWrites()
|
| H A D | batch_write_exec.h | 73 const BatchedCommandRequest& clientRequest,
|
| H A D | batch_write_exec.cpp | 88 const BatchedCommandRequest& clientRequest, in executeBatch()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/s/commands/ |
| H A D | cluster_write_cmd.cpp | 58 void batchErrorToLastError(const BatchedCommandRequest& request, in batchErrorToLastError()
124 BatchedCommandRequest parseRequest(BatchedCommandRequest::BatchType type, in parseRequest()
127 case BatchedCommandRequest::BatchType_Insert: in parseRequest()
128 return BatchedCommandRequest::cloneInsertWithIds( in parseRequest()
129 BatchedCommandRequest::parseInsert(request)); in parseRequest()
130 case BatchedCommandRequest::BatchType_Update: in parseRequest()
131 return BatchedCommandRequest::parseUpdate(request); in parseRequest()
132 case BatchedCommandRequest::BatchType_Delete: in parseRequest()
133 return BatchedCommandRequest::parseDelete(request); in parseRequest()
224 if (_writeType == BatchedCommandRequest::BatchType_Insert) { in enhancedRun()
[all …]
|
| H A D | cluster_write.h | 47 const BatchedCommandRequest& request,
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/commands/write_commands/ |
| H A D | write_commands_common.cpp | 93 BatchedCommandRequest::BatchType cmdType, in checkAuthForWriteCommand()
103 if (cmdType == BatchedCommandRequest::BatchType_Insert) { in checkAuthForWriteCommand()
119 } else if (cmdType == BatchedCommandRequest::BatchType_Update) { in checkAuthForWriteCommand()
129 fassert(17251, cmdType == BatchedCommandRequest::BatchType_Delete); in checkAuthForWriteCommand()
|
| H A D | write_commands.cpp | 77 BatchedCommandRequest::BatchType batchType, in checkAuthForWriteCommand()
250 opCtx->getClient(), BatchedCommandRequest::BatchType_Insert, request); in checkAuthForRequest()
281 opCtx->getClient(), BatchedCommandRequest::BatchType_Update, request); in checkAuthForRequest()
348 opCtx->getClient(), BatchedCommandRequest::BatchType_Delete, request); in checkAuthForRequest()
|
| H A D | write_commands_common.h | 47 BatchedCommandRequest::BatchType cmdType,
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/db/ |
| H A D | sessions_collection_sharded.cpp | 94 auto request = BatchedCommandRequest::parseUpdate(opMsg); in refreshSessions()
117 auto request = BatchedCommandRequest::parseDelete(opMsg); in removeRecords()
|
| H A D | keys_collection_client_direct.cpp | 139 BatchedCommandRequest request([&] { in _insert()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/s/client/ |
| H A D | shard.h | 46 class BatchedCommandRequest; variable
203 const BatchedCommandRequest& batchRequest,
|
| H A D | shard.cpp | 185 const BatchedCommandRequest& batchRequest, in runBatchWriteCommand()
|
| /dports/databases/mongodb36/mongodb-src-r3.6.23/src/mongo/s/catalog/ |
| H A D | sharding_catalog_client.h | 47 class BatchedCommandRequest; variable
325 const BatchedCommandRequest& request,
|
| H A D | sharding_catalog_client_mock.h | 126 const BatchedCommandRequest& request,
|
| H A D | sharding_catalog_client_mock.cpp | 177 const BatchedCommandRequest& request, in writeConfigServerDirect()
|
| H A D | sharding_catalog_client_impl.cpp | 1021 const BatchedCommandRequest& batchRequest, in writeConfigServerDirect()
1040 BatchedCommandRequest request([&] { in insertConfigDocument()
1128 BatchedCommandRequest request([&] { in _updateConfigDocument()
1163 BatchedCommandRequest request([&] { in removeConfigDocuments()
|
| H A D | sharding_catalog_client_impl.h | 150 const BatchedCommandRequest& request,
|