diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2017-08-24 17:47:41 +0200 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2017-08-24 17:47:41 +0200 |
commit | e12f3f8bafd8258ae091890f42709b64948a462e (patch) | |
tree | 25774f32e873cae3d22a641ca61e2d0725b86837 /searchcore | |
parent | 54db78e20f3bf04d498a5e6a3c4459ec7fee506a (diff) |
Separate interface with a const getXXX for readonly and another getXXXSP when you really need the SP.
Diffstat (limited to 'searchcore')
-rw-r--r-- | searchcore/src/apps/vespa-dump-feed/vespa-dump-feed.cpp | 12 |
1 files changed, 4 insertions, 8 deletions
diff --git a/searchcore/src/apps/vespa-dump-feed/vespa-dump-feed.cpp b/searchcore/src/apps/vespa-dump-feed/vespa-dump-feed.cpp index c38811e1962..d942049192a 100644 --- a/searchcore/src/apps/vespa-dump-feed/vespa-dump-feed.cpp +++ b/searchcore/src/apps/vespa-dump-feed/vespa-dump-feed.cpp @@ -4,13 +4,9 @@ #include <vespa/config/print/fileconfigwriter.h> #include <vespa/document/config/config-documenttypes.h> #include <vespa/document/document.h> -#include <vespa/document/repo/documenttyperepo.h> #include <vespa/documentapi/documentapi.h> #include <vespa/documentapi/loadtypes/loadtypeset.h> #include <vespa/messagebus/destinationsession.h> -#include <vespa/messagebus/imessagehandler.h> -#include <vespa/messagebus/iprotocol.h> -#include <vespa/messagebus/message.h> #include <vespa/messagebus/protocolset.h> #include <vespa/messagebus/rpcmessagebus.h> #include <vespa/vespalib/io/fileutil.h> @@ -56,7 +52,7 @@ private: OutputFile &_dat; size_t _numDocs; - void handleDocumentPut(document::Document::SP doc); + void handleDocumentPut(const document::Document::SP & doc); virtual void handleMessage(mbus::Message::UP message) override; public: @@ -66,9 +62,9 @@ public: }; void -FeedHandler::handleDocumentPut(document::Document::SP doc) +FeedHandler::handleDocumentPut(const document::Document::SP & doc) { - if (doc.get() != 0) { + if (doc) { vespalib::nbostream datStream(12345); vespalib::nbostream idxStream(12); doc->serialize(datStream); @@ -86,7 +82,7 @@ FeedHandler::handleMessage(mbus::Message::UP message) documentapi::DocumentMessage::UP msg((documentapi::DocumentMessage*)message.release()); switch (msg->getType()) { case documentapi::DocumentProtocol::MESSAGE_PUTDOCUMENT: - handleDocumentPut(((documentapi::PutDocumentMessage&)(*msg)).getDocument()); + handleDocumentPut(((documentapi::PutDocumentMessage&)(*msg)).getDocumentSP()); break; default: break; |