summaryrefslogtreecommitdiffstats
path: root/searchcore/src/tests/proton/documentdb/feedhandler/feedhandler_test.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'searchcore/src/tests/proton/documentdb/feedhandler/feedhandler_test.cpp')
-rw-r--r--searchcore/src/tests/proton/documentdb/feedhandler/feedhandler_test.cpp60
1 files changed, 35 insertions, 25 deletions
diff --git a/searchcore/src/tests/proton/documentdb/feedhandler/feedhandler_test.cpp b/searchcore/src/tests/proton/documentdb/feedhandler/feedhandler_test.cpp
index 168bb7cefad..7df80778cb7 100644
--- a/searchcore/src/tests/proton/documentdb/feedhandler/feedhandler_test.cpp
+++ b/searchcore/src/tests/proton/documentdb/feedhandler/feedhandler_test.cpp
@@ -188,22 +188,8 @@ struct MyFeedView : public test::DummyFeedView {
int prune_removed_count;
int update_count;
SerialNum update_serial;
- MyFeedView(const DocumentTypeRepo::SP &dtr) :
- test::DummyFeedView(dtr),
- putRdz(),
- usePutRdz(false),
- putLatch(),
- metaStore(),
- put_count(0),
- put_serial(0),
- heartbeat_count(0),
- remove_count(0),
- move_count(0),
- prune_removed_count(0),
- update_count(0),
- update_serial(0)
- {
- }
+ MyFeedView(const DocumentTypeRepo::SP &dtr);
+ ~MyFeedView();
void resetPutLatch(uint32_t count) { putLatch.reset(new vespalib::CountDownLatch(count)); }
virtual void preparePut(PutOperation &op) {
prepareDocumentOperation(op, op.getDocument()->getId().getGlobalId());
@@ -250,6 +236,23 @@ struct MyFeedView : public test::DummyFeedView {
}
};
+MyFeedView::MyFeedView(const DocumentTypeRepo::SP &dtr)
+ : test::DummyFeedView(dtr),
+ putRdz(),
+ usePutRdz(false),
+ putLatch(),
+ metaStore(),
+ put_count(0),
+ put_serial(0),
+ heartbeat_count(0),
+ remove_count(0),
+ move_count(0),
+ prune_removed_count(0),
+ update_count(0),
+ update_serial(0)
+{}
+MyFeedView::~MyFeedView() {}
+
struct SchemaContext {
Schema::SP schema;
@@ -294,7 +297,8 @@ struct MyTransport : public FeedToken::ITransport {
vespalib::Gate gate;
ResultUP result;
bool documentWasFound;
- MyTransport() : gate(), result(), documentWasFound(false) {}
+ MyTransport();
+ ~MyTransport();
virtual void send(Reply::UP, ResultUP res, bool documentWasFound_, double) {
result = std::move(res);
documentWasFound = documentWasFound_;
@@ -302,6 +306,9 @@ struct MyTransport : public FeedToken::ITransport {
}
};
+MyTransport::MyTransport() : gate(), result(), documentWasFound(false) {}
+MyTransport::~MyTransport() {}
+
Reply::UP getReply(uint32_t type) {
if (type == DocumentProtocol::REPLY_REMOVEDOCUMENT) {
return Reply::UP(new RemoveDocumentReply);
@@ -316,14 +323,9 @@ struct FeedTokenContext {
FeedToken::UP token_ap;
FeedToken &token;
- FeedTokenContext(uint32_t type = 0) :
- transport(),
- token_ap(new FeedToken(transport, getReply(type))),
- token(*token_ap) {
- token.getReply().getTrace().setLevel(9);
- }
- bool await(uint32_t timeout = 80000)
- { return transport.gate.await(timeout); }
+ FeedTokenContext(uint32_t type = 0);
+ ~FeedTokenContext();
+ bool await(uint32_t timeout = 80000) { return transport.gate.await(timeout); }
const Result *getResult() {
if (transport.result.get()) {
return transport.result.get();
@@ -332,6 +334,14 @@ struct FeedTokenContext {
}
};
+FeedTokenContext::FeedTokenContext(uint32_t type)
+ : transport(),
+ token_ap(new FeedToken(transport, getReply(type))),
+ token(*token_ap)
+{
+ token.getReply().getTrace().setLevel(9);
+}
+FeedTokenContext::~FeedTokenContext() {}
struct PutContext {
FeedTokenContext tokenCtx;