diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-03-31 13:00:32 +0000 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-03-31 13:00:32 +0000 |
commit | 94f53ab6a93aefa007200b97846ce47ea166bd70 (patch) | |
tree | 0421134fe3a839da8b36c18636bd901ae9939f60 /searchcore/src/tests/proton/persistenceengine/persistenceengine_test.cpp | |
parent | d0fa48f2559c297e7b9c15137f3c04bc32fc65fa (diff) |
GC unused Context parameter
Diffstat (limited to 'searchcore/src/tests/proton/persistenceengine/persistenceengine_test.cpp')
-rw-r--r-- | searchcore/src/tests/proton/persistenceengine/persistenceengine_test.cpp | 59 |
1 files changed, 23 insertions, 36 deletions
diff --git a/searchcore/src/tests/proton/persistenceengine/persistenceengine_test.cpp b/searchcore/src/tests/proton/persistenceengine/persistenceengine_test.cpp index 6fb7a35fffe..cf58056cae8 100644 --- a/searchcore/src/tests/proton/persistenceengine/persistenceengine_test.cpp +++ b/searchcore/src/tests/proton/persistenceengine/persistenceengine_test.cpp @@ -446,17 +446,16 @@ TEST_F("require that getPartitionStates() prepares all handlers", SimpleFixture) TEST_F("require that puts are routed to handler", SimpleFixture) { - Context context(storage::spi::Priority(0), storage::spi::Trace::TraceLevel(0)); - f.engine.put(bucket1, tstamp1, doc1, context); + f.engine.put(bucket1, tstamp1, doc1); TEST_DO(assertHandler(bucket1, tstamp1, docId1, f.hset.handler1)); TEST_DO(assertHandler(bucket0, tstamp0, docId0, f.hset.handler2)); - f.engine.put(bucket1, tstamp1, doc2, context); + f.engine.put(bucket1, tstamp1, doc2); TEST_DO(assertHandler(bucket1, tstamp1, docId1, f.hset.handler1)); TEST_DO(assertHandler(bucket1, tstamp1, docId2, f.hset.handler2)); EXPECT_EQUAL(Result(Result::ErrorType::PERMANENT_ERROR, "No handler for document type 'type3'"), - f.engine.put(bucket1, tstamp1, doc3, context)); + f.engine.put(bucket1, tstamp1, doc3)); } @@ -465,39 +464,35 @@ TEST_F("require that put is rejected if resource limit is reached", SimpleFixtur f._writeFilter._acceptWriteOperation = false; f._writeFilter._message = "Disk is full"; - Context context(storage::spi::Priority(0), storage::spi::Trace::TraceLevel(0)); EXPECT_EQUAL( Result(Result::ErrorType::RESOURCE_EXHAUSTED, "Put operation rejected for document 'id:type3:type3::1': 'Disk is full'"), - f.engine.put(bucket1, tstamp1, doc3, context)); + f.engine.put(bucket1, tstamp1, doc3)); } TEST_F("require that updates are routed to handler", SimpleFixture) { - Context context(storage::spi::Priority(0), storage::spi::Trace::TraceLevel(0)); f.hset.handler1.setExistingTimestamp(tstamp2); - UpdateResult ur = f.engine.update(bucket1, tstamp1, upd1, context); + UpdateResult ur = f.engine.update(bucket1, tstamp1, upd1); TEST_DO(assertHandler(bucket1, tstamp1, docId1, f.hset.handler1)); TEST_DO(assertHandler(bucket0, tstamp0, docId0, f.hset.handler2)); EXPECT_EQUAL(tstamp2, ur.getExistingTimestamp()); f.hset.handler2.setExistingTimestamp(tstamp3); - ur = f.engine.update(bucket1, tstamp1, upd2, context); + ur = f.engine.update(bucket1, tstamp1, upd2); TEST_DO(assertHandler(bucket1, tstamp1, docId1, f.hset.handler1)); TEST_DO(assertHandler(bucket1, tstamp1, docId2, f.hset.handler2)); EXPECT_EQUAL(tstamp3, ur.getExistingTimestamp()); EXPECT_EQUAL(Result(Result::ErrorType::PERMANENT_ERROR, "No handler for document type 'type3'"), - f.engine.update(bucket1, tstamp1, upd3, context)); + f.engine.update(bucket1, tstamp1, upd3)); } TEST_F("require that updates with bad ids are rejected", SimpleFixture) { - Context context(storage::spi::Priority(0), storage::spi::Trace::TraceLevel(0)); - EXPECT_EQUAL(UpdateResult(Result::ErrorType::PERMANENT_ERROR, "Update operation rejected due to bad id (id:type2:type2::1, type1)"), - f.engine.update(bucket1, tstamp1, bad_id_upd, context)); + f.engine.update(bucket1, tstamp1, bad_id_upd)); } TEST_F("require that simple, cheap update is not rejected if resource limit is reached", SimpleFixture) @@ -505,10 +500,8 @@ TEST_F("require that simple, cheap update is not rejected if resource limit is r f._writeFilter._acceptWriteOperation = false; f._writeFilter._message = "Disk is full"; - Context context(storage::spi::Priority(0), storage::spi::Trace::TraceLevel(0)); - EXPECT_EQUAL(Result(Result::ErrorType::NONE, ""), - f.engine.update(bucket1, tstamp1, upd1, context)); + f.engine.update(bucket1, tstamp1, upd1)); } TEST_F("require that update is rejected if resource limit is reached", SimpleFixture) @@ -516,7 +509,6 @@ TEST_F("require that update is rejected if resource limit is reached", SimpleFix f._writeFilter._acceptWriteOperation = false; f._writeFilter._message = "Disk is full"; - Context context(storage::spi::Priority(0), storage::spi::Trace::TraceLevel(0)); DocumentType type(createDocType("type_with_one_string", 1)); document::Field field("string", 1, *document::DataType::STRING); type.addField(field); @@ -526,13 +518,12 @@ TEST_F("require that update is rejected if resource limit is reached", SimpleFix EXPECT_EQUAL( Result(Result::ErrorType::RESOURCE_EXHAUSTED, "Update operation rejected for document 'id:type1:type1::1': 'Disk is full'"), - f.engine.update(bucket1, tstamp1, upd, context)); + f.engine.update(bucket1, tstamp1, upd)); } TEST_F("require that removes are routed to handlers", SimpleFixture) { - Context context(storage::spi::Priority(0), storage::spi::Trace::TraceLevel(0)); - RemoveResult rr = f.engine.remove(bucket1, tstamp1, docId3, context); + RemoveResult rr = f.engine.remove(bucket1, tstamp1, docId3); TEST_DO(assertHandler(bucket0, tstamp0, docId0, f.hset.handler1)); TEST_DO(assertHandler(bucket0, tstamp0, docId0, f.hset.handler2)); EXPECT_FALSE(rr.wasFound()); @@ -540,7 +531,7 @@ TEST_F("require that removes are routed to handlers", SimpleFixture) EXPECT_EQUAL(Result(Result::ErrorType::PERMANENT_ERROR, "No handler for document type 'type3'"), rr); f.hset.handler1.setExistingTimestamp(tstamp2); - rr = f.engine.remove(bucket1, tstamp1, docId1, context); + rr = f.engine.remove(bucket1, tstamp1, docId1); TEST_DO(assertHandler(bucket1, tstamp1, docId1, f.hset.handler1)); TEST_DO(assertHandler(bucket0, tstamp0, docId0, f.hset.handler2)); EXPECT_TRUE(rr.wasFound()); @@ -548,14 +539,14 @@ TEST_F("require that removes are routed to handlers", SimpleFixture) f.hset.handler1.setExistingTimestamp(tstamp0); f.hset.handler2.setExistingTimestamp(tstamp3); - rr = f.engine.remove(bucket1, tstamp1, docId2, context); + rr = f.engine.remove(bucket1, tstamp1, docId2); TEST_DO(assertHandler(bucket1, tstamp1, docId1, f.hset.handler1)); TEST_DO(assertHandler(bucket1, tstamp1, docId2, f.hset.handler2)); EXPECT_TRUE(rr.wasFound()); EXPECT_FALSE(rr.hasError()); f.hset.handler2.setExistingTimestamp(tstamp0); - rr = f.engine.remove(bucket1, tstamp1, docId2, context); + rr = f.engine.remove(bucket1, tstamp1, docId2); TEST_DO(assertHandler(bucket1, tstamp1, docId1, f.hset.handler1)); TEST_DO(assertHandler(bucket1, tstamp1, docId2, f.hset.handler2)); EXPECT_FALSE(rr.wasFound()); @@ -567,9 +558,7 @@ TEST_F("require that remove is NOT rejected if resource limit is reached", Simpl f._writeFilter._acceptWriteOperation = false; f._writeFilter._message = "Disk is full"; - Context context(storage::spi::Priority(0), storage::spi::Trace::TraceLevel(0)); - - EXPECT_EQUAL(RemoveResult(false), f.engine.remove(bucket1, tstamp1, docId1, context)); + EXPECT_EQUAL(RemoveResult(false), f.engine.remove(bucket1, tstamp1, docId1)); } @@ -619,11 +608,10 @@ TEST_F("require that getBucketInfo() is routed to handlers and merged", SimpleFi TEST_F("require that createBucket() is routed to handlers and merged", SimpleFixture) { - Context context(storage::spi::Priority(0), storage::spi::Trace::TraceLevel(0)); f.hset.handler1._createBucketResult = Result(Result::ErrorType::TRANSIENT_ERROR, "err1a"); f.hset.handler2._createBucketResult = Result(Result::ErrorType::PERMANENT_ERROR, "err2a"); - Result result = f.engine.createBucket(bucket1, context); + Result result = f.engine.createBucket(bucket1); EXPECT_EQUAL(Result::ErrorType::PERMANENT_ERROR, result.getErrorCode()); EXPECT_EQUAL("err1a, err2a", result.getErrorMessage()); } @@ -631,11 +619,10 @@ TEST_F("require that createBucket() is routed to handlers and merged", SimpleFix TEST_F("require that deleteBucket() is routed to handlers and merged", SimpleFixture) { - Context context(storage::spi::Priority(0), storage::spi::Trace::TraceLevel(0)); f.hset.handler1.deleteBucketResult = Result(Result::ErrorType::TRANSIENT_ERROR, "err1"); f.hset.handler2.deleteBucketResult = Result(Result::ErrorType::PERMANENT_ERROR, "err2"); - Result result = f.engine.deleteBucket(bucket1, context); + Result result = f.engine.deleteBucket(bucket1); EXPECT_EQUAL(Result::ErrorType::PERMANENT_ERROR, result.getErrorCode()); EXPECT_EQUAL("err1, err2", result.getErrorMessage()); } @@ -680,7 +667,7 @@ TEST_F("require that createIterator does", SimpleFixture) { EXPECT_TRUE(result.getIteratorId()); uint64_t max_size = 1024; - IterateResult it_result = f.engine.iterate(result.getIteratorId(), max_size, context); + IterateResult it_result = f.engine.iterate(result.getIteratorId(), max_size); EXPECT_FALSE(it_result.hasError()); } @@ -700,7 +687,7 @@ TEST_F("require that iterator ids are unique", SimpleFixture) { TEST_F("require that iterate requires valid iterator", SimpleFixture) { uint64_t max_size = 1024; Context context(storage::spi::Priority(0), storage::spi::Trace::TraceLevel(0)); - IterateResult it_result = f.engine.iterate(IteratorId(1), max_size, context); + IterateResult it_result = f.engine.iterate(IteratorId(1), max_size); EXPECT_TRUE(it_result.hasError()); EXPECT_EQUAL(Result::ErrorType::PERMANENT_ERROR, it_result.getErrorCode()); EXPECT_EQUAL("Unknown iterator with id 1", it_result.getErrorMessage()); @@ -710,7 +697,7 @@ TEST_F("require that iterate requires valid iterator", SimpleFixture) { storage::spi::NEWEST_DOCUMENT_ONLY, context); EXPECT_TRUE(result.getIteratorId()); - it_result = f.engine.iterate(result.getIteratorId(), max_size, context); + it_result = f.engine.iterate(result.getIteratorId(), max_size); EXPECT_FALSE(it_result.hasError()); } @@ -725,7 +712,7 @@ TEST_F("require that iterate returns documents", SimpleFixture) { storage::spi::NEWEST_DOCUMENT_ONLY, context); EXPECT_TRUE(result.getIteratorId()); - IterateResult it_result = f.engine.iterate(result.getIteratorId(), max_size, context); + IterateResult it_result = f.engine.iterate(result.getIteratorId(), max_size); EXPECT_FALSE(it_result.hasError()); EXPECT_EQUAL(2u, it_result.getEntries().size()); } @@ -739,11 +726,11 @@ TEST_F("require that destroyIterator prevents iteration", SimpleFixture) { storage::spi::NEWEST_DOCUMENT_ONLY, context); EXPECT_TRUE(create_result.getIteratorId()); - Result result = f.engine.destroyIterator(create_result.getIteratorId(), context); + Result result = f.engine.destroyIterator(create_result.getIteratorId()); EXPECT_FALSE(result.hasError()); uint64_t max_size = 1024; - IterateResult it_result = f.engine.iterate(create_result.getIteratorId(), max_size, context); + IterateResult it_result = f.engine.iterate(create_result.getIteratorId(), max_size); EXPECT_TRUE(it_result.hasError()); EXPECT_EQUAL(Result::ErrorType::PERMANENT_ERROR, it_result.getErrorCode()); string msg_prefix = "Unknown iterator with id"; |