From 64c08801e0ac5094fb111c5fe3ea63cc7597506d Mon Sep 17 00:00:00 2001 From: Henning Baldersheim Date: Tue, 1 Mar 2022 05:42:38 +0000 Subject: Let the InvocationService drive the clock instead of having its own ticking loop. Also use sleep_until to get intervals indendant of invoke cost as long as cost is within interval. This also also saves a clock sample and simplifies implementation. --- searchcore/src/tests/proton/documentdb/documentdb_test.cpp | 6 ++---- 1 file changed, 2 insertions(+), 4 deletions(-) (limited to 'searchcore/src/tests/proton/documentdb/documentdb_test.cpp') diff --git a/searchcore/src/tests/proton/documentdb/documentdb_test.cpp b/searchcore/src/tests/proton/documentdb/documentdb_test.cpp index c6a8df79a5e..1f3be7511da 100644 --- a/searchcore/src/tests/proton/documentdb/documentdb_test.cpp +++ b/searchcore/src/tests/proton/documentdb/documentdb_test.cpp @@ -127,7 +127,6 @@ struct Fixture : public FixtureBase { DummyFileHeaderContext _fileHeaderContext; TransLogServer _tls; matching::QueryLimiter _queryLimiter; - vespalib::Clock _clock; std::unique_ptr make_config_store(); Fixture(); @@ -151,8 +150,7 @@ Fixture::Fixture(bool file_config) _db(), _fileHeaderContext(), _tls(_shared_service.transport(), "tmp", 9014, ".", _fileHeaderContext), - _queryLimiter(), - _clock() + _queryLimiter() { auto documenttypesConfig = std::make_shared(); DocumentType docType("typea", 0); @@ -167,7 +165,7 @@ Fixture::Fixture(bool file_config) tuneFileDocumentDB, HwInfo()); mgr.forwardConfig(b); mgr.nextGeneration(_shared_service.transport(), 0ms); - _db = DocumentDB::create(".", mgr.getConfig(), "tcp/localhost:9014", _queryLimiter, _clock, DocTypeName("typea"), + _db = DocumentDB::create(".", mgr.getConfig(), "tcp/localhost:9014", _queryLimiter, DocTypeName("typea"), makeBucketSpace(), *b->getProtonConfigSP(), _myDBOwner, _shared_service, _bucketExecutor, _tls, _dummy, _fileHeaderContext, make_config_store(), -- cgit v1.2.3