summaryrefslogtreecommitdiff
path: root/src/mongo/db/storage/record_store_test_updaterecord.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'src/mongo/db/storage/record_store_test_updaterecord.cpp')
-rw-r--r--src/mongo/db/storage/record_store_test_updaterecord.cpp63
1 files changed, 2 insertions, 61 deletions
diff --git a/src/mongo/db/storage/record_store_test_updaterecord.cpp b/src/mongo/db/storage/record_store_test_updaterecord.cpp
index c6b96def16d..3f7186140a4 100644
--- a/src/mongo/db/storage/record_store_test_updaterecord.cpp
+++ b/src/mongo/db/storage/record_store_test_updaterecord.cpp
@@ -30,9 +30,6 @@
#include "mongo/platform/basic.h"
-#include "mongo/db/storage/record_store_test_updaterecord.h"
-
-
#include "mongo/db/record_id.h"
#include "mongo/db/storage/record_data.h"
#include "mongo/db/storage/record_store.h"
@@ -80,7 +77,7 @@ TEST(RecordStoreTestHarness, UpdateRecord) {
ServiceContext::UniqueOperationContext opCtx(harnessHelper->newOperationContext());
{
WriteUnitOfWork uow(opCtx.get());
- Status res = rs->updateRecord(opCtx.get(), loc, data.c_str(), data.size() + 1, NULL);
+ Status res = rs->updateRecord(opCtx.get(), loc, data.c_str(), data.size() + 1);
ASSERT_OK(res);
uow.commit();
@@ -138,8 +135,7 @@ TEST(RecordStoreTestHarness, UpdateMultipleRecords) {
string data = ss.str();
WriteUnitOfWork uow(opCtx.get());
- Status res =
- rs->updateRecord(opCtx.get(), locs[i], data.c_str(), data.size() + 1, NULL);
+ Status res = rs->updateRecord(opCtx.get(), locs[i], data.c_str(), data.size() + 1);
ASSERT_OK(res);
uow.commit();
@@ -160,60 +156,5 @@ TEST(RecordStoreTestHarness, UpdateMultipleRecords) {
}
}
-// Insert a record, try to update it, and examine how the UpdateNotifier is called.
-TEST(RecordStoreTestHarness, UpdateRecordWithMoveNotifier) {
- const auto harnessHelper(newRecordStoreHarnessHelper());
- unique_ptr<RecordStore> rs(harnessHelper->newNonCappedRecordStore());
-
- {
- ServiceContext::UniqueOperationContext opCtx(harnessHelper->newOperationContext());
- ASSERT_EQUALS(0, rs->numRecords(opCtx.get()));
- }
-
- string oldData = "my record";
- RecordId loc;
- {
- ServiceContext::UniqueOperationContext opCtx(harnessHelper->newOperationContext());
- {
- WriteUnitOfWork uow(opCtx.get());
- StatusWith<RecordId> res =
- rs->insertRecord(opCtx.get(), oldData.c_str(), oldData.size() + 1, Timestamp());
- ASSERT_OK(res.getStatus());
- loc = res.getValue();
- uow.commit();
- }
- }
-
- {
- ServiceContext::UniqueOperationContext opCtx(harnessHelper->newOperationContext());
- ASSERT_EQUALS(1, rs->numRecords(opCtx.get()));
- }
-
- string newData = "my updated record--";
- {
- ServiceContext::UniqueOperationContext opCtx(harnessHelper->newOperationContext());
- {
- UpdateNotifierSpy umn(opCtx.get(), loc, oldData.c_str(), oldData.size());
-
- WriteUnitOfWork uow(opCtx.get());
- Status res =
- rs->updateRecord(opCtx.get(), loc, newData.c_str(), newData.size() + 1, &umn);
- ASSERT_OK(res);
- ASSERT_GTE(1, umn.numInPlaceCallbacks());
-
- uow.commit();
- }
- }
-
- {
- ServiceContext::UniqueOperationContext opCtx(harnessHelper->newOperationContext());
- {
- RecordData record = rs->dataFor(opCtx.get(), loc);
- ASSERT_EQUALS(newData.size() + 1, static_cast<size_t>(record.size()));
- ASSERT_EQUALS(newData, record.data());
- }
- }
-}
-
} // namespace
} // namespace mongo