diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-10-14 23:20:25 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-10-14 23:20:25 +0200 |
commit | bc337a34cce61e302c1ee70414839adaf6a4b39c (patch) | |
tree | 77d3b6a7b9b88483c4f54e1aaa9f05def3018b1a | |
parent | 9d287031dff65308469ab2d128ebfdfdaf3ccc90 (diff) |
Reformat.
-rw-r--r-- | searchcore/src/vespa/searchcore/proton/persistenceengine/persistenceengine.cpp | 25 |
1 files changed, 8 insertions, 17 deletions
diff --git a/searchcore/src/vespa/searchcore/proton/persistenceengine/persistenceengine.cpp b/searchcore/src/vespa/searchcore/proton/persistenceengine/persistenceengine.cpp index 93648b70b57..ddaf7d8d6a4 100644 --- a/searchcore/src/vespa/searchcore/proton/persistenceengine/persistenceengine.cpp +++ b/searchcore/src/vespa/searchcore/proton/persistenceengine/persistenceengine.cpp @@ -343,22 +343,16 @@ PersistenceEngine::put(const Bucket& b, Timestamp t, const document::Document::S } std::shared_lock<std::shared_timed_mutex> rguard(_rwMutex); DocTypeName docType(doc->getType()); - LOG(spam, - "put(%s, %" PRIu64 ", (\"%s\", \"%s\"))", - b.toString().c_str(), - static_cast<uint64_t>(t.getValue()), - docType.toString().c_str(), - doc->getId().toString().c_str()); + LOG(spam, "put(%s, %" PRIu64 ", (\"%s\", \"%s\"))", b.toString().c_str(), static_cast<uint64_t>(t.getValue()), + docType.toString().c_str(), doc->getId().toString().c_str()); if (!doc->getId().hasDocType()) { - return Result(Result::PERMANENT_ERROR, make_string( - "Old id scheme not supported in elastic mode (%s)", - doc->getId().toString().c_str())); + return Result(Result::PERMANENT_ERROR, + make_string("Old id scheme not supported in elastic mode (%s)", doc->getId().toString().c_str())); } IPersistenceHandler::SP handler = getHandler(b.getBucketSpace(), docType); if (!handler) { return Result(Result::PERMANENT_ERROR, - make_string("No handler for document type '%s'", - docType.toString().c_str())); + make_string("No handler for document type '%s'", docType.toString().c_str())); } TransportLatch latch(1); FeedToken token(latch); @@ -371,11 +365,8 @@ PersistenceEngine::RemoveResult PersistenceEngine::remove(const Bucket& b, Timestamp t, const DocumentId& did, Context&) { std::shared_lock<std::shared_timed_mutex> rguard(_rwMutex); - LOG(spam, - "remove(%s, %" PRIu64 ", \"%s\")", - b.toString().c_str(), - static_cast<uint64_t>(t.getValue()), - did.toString().c_str()); + LOG(spam, "remove(%s, %" PRIu64 ", \"%s\")", b.toString().c_str(), + static_cast<uint64_t>(t.getValue()), did.toString().c_str()); HandlerSnapshot::UP snap = getHandlerSnapshot(b.getBucketSpace(), did); if (!snap) { return RemoveResult(false); @@ -705,7 +696,7 @@ private: public: ActiveBucketIdListResultHandler() : _bucketMap() { } - virtual void handle(const BucketIdListResult &result) override { + void handle(const BucketIdListResult &result) override { const BucketIdListResult::List &buckets = result.getList(); for (size_t i = 0; i < buckets.size(); ++i) { IR ir(_bucketMap.insert(std::make_pair(buckets[i], 1u))); |