diff options
| author | Henning Baldersheim <balder@yahoo-inc.com> | 2022-03-01 05:42:38 +0000 |
|---|---|---|
| committer | Henning Baldersheim <balder@yahoo-inc.com> | 2022-03-03 11:39:52 +0000 |
| commit | 64c08801e0ac5094fb111c5fe3ea63cc7597506d (patch) | |
| tree | a34f000d2743b864e22e322d9ce94b655c86ac97 /searchcore/src/tests/proton/documentdb/documentdb_test.cpp | |
| parent | 6f78fdc9750ad3ac03b14166b6838c628487458c (diff) | |
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.
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/documentdb_test.cpp')
| -rw-r--r-- | searchcore/src/tests/proton/documentdb/documentdb_test.cpp | 6 |
1 files changed, 2 insertions, 4 deletions
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<ConfigStore> 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<DocumenttypesConfig>(); 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(), |