summaryrefslogtreecommitdiffstats
path: root/searchcore
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2017-08-24 17:47:41 +0200
committerHenning Baldersheim <balder@yahoo-inc.com>2017-08-24 17:47:41 +0200
commite12f3f8bafd8258ae091890f42709b64948a462e (patch)
tree25774f32e873cae3d22a641ca61e2d0725b86837 /searchcore
parent54db78e20f3bf04d498a5e6a3c4459ec7fee506a (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.cpp12
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;