summaryrefslogtreecommitdiffstats
path: root/searchcore
diff options
context:
space:
mode:
authorTor Egge <Tor.Egge@oath.com>2017-10-31 09:36:55 +0000
committerTor Egge <Tor.Egge@oath.com>2017-10-31 09:36:55 +0000
commit1179d3c49520a3763ae0acc97cf662b027c0ace4 (patch)
tree23d0cdda74281ce841151b3b14543ca4e80cea32 /searchcore
parentcfede8e29baba06d2bb8fbf456df826e1a2d06db (diff)
Use std::promise<void> instead of std::promise<bool> when value is ignored.
Diffstat (limited to 'searchcore')
-rw-r--r--searchcore/src/vespa/searchcore/proton/attribute/attribute_manager_initializer.cpp14
-rw-r--r--searchcore/src/vespa/searchcore/proton/initializer/task_runner.cpp8
-rw-r--r--searchcore/src/vespa/searchcore/proton/reference/gid_to_lid_change_listener.cpp24
-rw-r--r--searchcore/src/vespa/searchcore/proton/server/document_subdb_initializer.cpp8
-rw-r--r--searchcore/src/vespa/searchcore/proton/server/proton_configurer.cpp8
-rw-r--r--searchcore/src/vespa/searchcore/proton/server/storeonlydocsubdb.cpp8
6 files changed, 35 insertions, 35 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/attribute/attribute_manager_initializer.cpp b/searchcore/src/vespa/searchcore/proton/attribute/attribute_manager_initializer.cpp
index 9feaa738bf1..c59e3718b1e 100644
--- a/searchcore/src/vespa/searchcore/proton/attribute/attribute_manager_initializer.cpp
+++ b/searchcore/src/vespa/searchcore/proton/attribute/attribute_manager_initializer.cpp
@@ -46,14 +46,14 @@ public:
class AttributeManagerInitializerTask : public vespalib::Executor::Task
{
- std::promise<bool> _promise;
+ std::promise<void> _promise;
search::SerialNum _configSerialNum;
DocumentMetaStore::SP _documentMetaStore;
AttributeManager::SP _attrMgr;
InitializedAttributesResult &_attributesResult;
public:
- AttributeManagerInitializerTask(std::promise<bool> &&promise,
+ AttributeManagerInitializerTask(std::promise<void> &&promise,
search::SerialNum configSerialNum,
DocumentMetaStore::SP documentMetaStore,
AttributeManager::SP attrMgr,
@@ -63,7 +63,7 @@ public:
};
-AttributeManagerInitializerTask::AttributeManagerInitializerTask(std::promise<bool> &&promise,
+AttributeManagerInitializerTask::AttributeManagerInitializerTask(std::promise<void> &&promise,
search::SerialNum configSerialNum,
DocumentMetaStore::SP documentMetaStore,
AttributeManager::SP attrMgr,
@@ -86,7 +86,7 @@ AttributeManagerInitializerTask::run()
_attrMgr->addExtraAttribute(_documentMetaStore);
_attrMgr->addInitializedAttributes(_attributesResult.get());
_attrMgr->pruneRemovedFields(_configSerialNum);
- _promise.set_value(true);
+ _promise.set_value();
}
class AttributeInitializerTasksBuilder : public IAttributeInitializerRegistry
@@ -168,8 +168,8 @@ AttributeManagerInitializer::AttributeManagerInitializer(SerialNum configSerialN
void
AttributeManagerInitializer::run()
{
- std::promise<bool> promise;
- std::future<bool> future = promise.get_future();
+ std::promise<void> promise;
+ auto future = promise.get_future();
/*
* Attribute manager and some its members (e.g. _attributeFieldWriter) assumes that work is performed
* by document db master thread and lacks locking to handle calls from multiple threads.
@@ -179,7 +179,7 @@ AttributeManagerInitializer::run()
_documentMetaStore,
_attrMgr,
_attributesResult));
- (void) future.get();
+ future.wait();
*_attrMgrResult = _attrMgr;
}
diff --git a/searchcore/src/vespa/searchcore/proton/initializer/task_runner.cpp b/searchcore/src/vespa/searchcore/proton/initializer/task_runner.cpp
index 7deb0afa7af..770f00dc264 100644
--- a/searchcore/src/vespa/searchcore/proton/initializer/task_runner.cpp
+++ b/searchcore/src/vespa/searchcore/proton/initializer/task_runner.cpp
@@ -90,11 +90,11 @@ void
TaskRunner::runTask(InitializerTask::SP task)
{
vespalib::ThreadStackExecutor executor(1, 128 * 1024);
- std::promise<bool> promise;
- std::future<bool> future = promise.get_future();
+ std::promise<void> promise;
+ auto future = promise.get_future();
runTask(task, executor,
- makeLambdaTask([&]() { promise.set_value(true); }));
- (void) future.get();
+ makeLambdaTask([&]() { promise.set_value(); }));
+ future.wait();
}
void
diff --git a/searchcore/src/vespa/searchcore/proton/reference/gid_to_lid_change_listener.cpp b/searchcore/src/vespa/searchcore/proton/reference/gid_to_lid_change_listener.cpp
index cb5c5de0f5a..5941ef13365 100644
--- a/searchcore/src/vespa/searchcore/proton/reference/gid_to_lid_change_listener.cpp
+++ b/searchcore/src/vespa/searchcore/proton/reference/gid_to_lid_change_listener.cpp
@@ -28,31 +28,31 @@ GidToLidChangeListener::~GidToLidChangeListener()
void
GidToLidChangeListener::notifyPutDone(document::GlobalId gid, uint32_t lid)
{
- std::promise<bool> promise;
- std::future<bool> future = promise.get_future();
+ std::promise<void> promise;
+ auto future = promise.get_future();
_attributeFieldWriter.executeLambda(_executorId,
- [this, &promise, gid, lid]() { _attr->notifyReferencedPut(gid, lid); promise.set_value(true); });
- (void) future.get();
+ [this, &promise, gid, lid]() { _attr->notifyReferencedPut(gid, lid); promise.set_value(); });
+ future.wait();
}
void
GidToLidChangeListener::notifyRemove(document::GlobalId gid)
{
- std::promise<bool> promise;
- std::future<bool> future = promise.get_future();
+ std::promise<void> promise;
+ auto future = promise.get_future();
_attributeFieldWriter.executeLambda(_executorId,
- [this, &promise, gid]() { _attr->notifyReferencedRemove(gid); promise.set_value(true); });
- (void) future.get();
+ [this, &promise, gid]() { _attr->notifyReferencedRemove(gid); promise.set_value(); });
+ future.wait();
}
void
GidToLidChangeListener::notifyRegistered()
{
- std::promise<bool> promise;
- std::future<bool> future = promise.get_future();
+ std::promise<void> promise;
+ auto future = promise.get_future();
_attributeFieldWriter.executeLambda(_executorId,
- [this, &promise]() { _attr->populateReferencedLids(); promise.set_value(true); });
- (void) future.get();
+ [this, &promise]() { _attr->populateReferencedLids(); promise.set_value(); });
+ future.wait();
}
const vespalib::string &
diff --git a/searchcore/src/vespa/searchcore/proton/server/document_subdb_initializer.cpp b/searchcore/src/vespa/searchcore/proton/server/document_subdb_initializer.cpp
index a9609bf0cc5..510be013c52 100644
--- a/searchcore/src/vespa/searchcore/proton/server/document_subdb_initializer.cpp
+++ b/searchcore/src/vespa/searchcore/proton/server/document_subdb_initializer.cpp
@@ -29,10 +29,10 @@ addDocumentMetaStoreInitTask(InitTask::SP documentMetaStoreInitTask)
void
DocumentSubDbInitializer::run()
{
- std::promise<bool> promise;
- std::future<bool> future = promise.get_future();
- _master.execute(makeLambdaTask([&]() { _subDB.setup(_result); promise.set_value(true); }));
- (void) future.get();
+ std::promise<void> promise;
+ auto future = promise.get_future();
+ _master.execute(makeLambdaTask([&]() { _subDB.setup(_result); promise.set_value(); }));
+ future.wait();
}
} // namespace proton
diff --git a/searchcore/src/vespa/searchcore/proton/server/proton_configurer.cpp b/searchcore/src/vespa/searchcore/proton/server/proton_configurer.cpp
index 436cf3865e5..00360a9c405 100644
--- a/searchcore/src/vespa/searchcore/proton/server/proton_configurer.cpp
+++ b/searchcore/src/vespa/searchcore/proton/server/proton_configurer.cpp
@@ -179,10 +179,10 @@ ProtonConfigurer::applyInitialConfig(InitializeThreads initializeThreads)
{
// called by proton app main thread
assert(!_executor.isCurrentThread());
- std::promise<bool> promise;
- std::future<bool> future = promise.get_future();
- _executor.execute(makeLambdaTask([this, initializeThreads, &promise]() { applyConfig(getPendingConfigSnapshot(), initializeThreads, true); promise.set_value(true); }));
- (void) future.get();
+ std::promise<void> promise;
+ auto future = promise.get_future();
+ _executor.execute(makeLambdaTask([this, initializeThreads, &promise]() { applyConfig(getPendingConfigSnapshot(), initializeThreads, true); promise.set_value(); }));
+ future.wait();
}
} // namespace proton
diff --git a/searchcore/src/vespa/searchcore/proton/server/storeonlydocsubdb.cpp b/searchcore/src/vespa/searchcore/proton/server/storeonlydocsubdb.cpp
index bba03621f8a..e78f8136d26 100644
--- a/searchcore/src/vespa/searchcore/proton/server/storeonlydocsubdb.cpp
+++ b/searchcore/src/vespa/searchcore/proton/server/storeonlydocsubdb.cpp
@@ -200,10 +200,10 @@ StoreOnlyDocSubDB::onReplayDone()
_dms->shrinkLidSpace();
uint32_t docIdLimit = _dms->getCommittedDocIdLimit();
auto &docStore = _rSummaryMgr->getBackingStore();
- std::promise<bool> promise;
- std::future<bool> future = promise.get_future();
- _writeService.summary().execute(makeLambdaTask([&]() { docStoreReplayDone(docStore, docIdLimit); promise.set_value(true); }));
- (void) future.get();
+ std::promise<void> promise;
+ auto future = promise.get_future();
+ _writeService.summary().execute(makeLambdaTask([&]() { docStoreReplayDone(docStore, docIdLimit); promise.set_value(); }));
+ future.wait();
}