diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2020-10-04 21:44:35 +0200 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-10-04 21:44:35 +0200 |
commit | 9a45a980fef3febe99d30eb53b437ca778b61ce0 (patch) | |
tree | 2b9b003bd1244086e38476078dcd28c0e5ba9531 /searchcore | |
parent | 5dbb928c24bc6c3f2df934f5d353ca106d5a622c (diff) | |
parent | e9f4fcc45694159a6658d6488e03ea9daafc4501 (diff) |
Merge pull request #14710 from vespa-engine/balder/use-shared-executor-when-reading-from-summary-store
Use shared executor when accessing docstore.
Diffstat (limited to 'searchcore')
-rw-r--r-- | searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp | 11 |
1 files changed, 4 insertions, 7 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp b/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp index 84dad379d31..6654f31ac5d 100644 --- a/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp +++ b/searchcore/src/vespa/searchcore/proton/server/storeonlyfeedview.cpp @@ -507,18 +507,15 @@ StoreOnlyFeedView::internalUpdate(FeedToken token, const UpdateOperation &updOp) if (useDocumentStore(serialNum)) { putSummary(serialNum, lid, std::move(futureStream), onWriteDone); } -#pragma GCC diagnostic push -#pragma GCC diagnostic ignored "-Winline" // Avoid spurious inlining warning from GCC related to lambda destructor. _writeService - .attributeFieldWriter() - .execute(serialNum, + .shared() + .execute(makeLambdaTask( [upd = updOp.getUpdate(), serialNum, lid, onWriteDone, promisedDoc = std::move(promisedDoc), promisedStream = std::move(promisedStream), this]() mutable - { + { makeUpdatedDocument(serialNum, lid, *upd, onWriteDone, std::move(promisedDoc), std::move(promisedStream)); - }); -#pragma GCC diagnostic pop + })); updateAttributes(serialNum, lid, std::move(futureDoc), immediateCommit, onWriteDone); } } |