diff options
Diffstat (limited to 'messagebus/test/src/tests/trace/cpp-server.cpp')
-rw-r--r-- | messagebus/test/src/tests/trace/cpp-server.cpp | 90 |
1 files changed, 0 insertions, 90 deletions
diff --git a/messagebus/test/src/tests/trace/cpp-server.cpp b/messagebus/test/src/tests/trace/cpp-server.cpp deleted file mode 100644 index 76e20bc3cfd..00000000000 --- a/messagebus/test/src/tests/trace/cpp-server.cpp +++ /dev/null @@ -1,90 +0,0 @@ -// Copyright 2016 Yahoo Inc. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root. -#include <vespa/fastos/fastos.h> -#include <vespa/log/log.h> -LOG_SETUP("cpp-server"); -#include <vespa/messagebus/messagebus.h> -#include <vespa/messagebus/destinationsession.h> -#include <vespa/messagebus/testlib/simplemessage.h> -#include <vespa/messagebus/testlib/simplereply.h> -#include <vespa/messagebus/testlib/simpleprotocol.h> -#include <vespa/messagebus/rpcmessagebus.h> -#include <vespa/messagebus/iprotocol.h> -#include <vespa/messagebus/protocolset.h> -#include <vespa/messagebus/emptyreply.h> - -using namespace mbus; - -class Server : public IMessageHandler, - public IReplyHandler -{ -private: - IntermediateSession::UP _session; - std::string _name; -public: - Server(MessageBus &bus, const std::string &name); - ~Server(); - void handleMessage(Message::UP msg); - void handleReply(Reply::UP reply); -}; - -Server::Server(MessageBus &bus, const std::string &name) - : _session(bus.createIntermediateSession("session", true, *this, *this)), - _name(name) -{ - fprintf(stderr, "cpp server started: %s\n", _name.c_str()); -} - -Server::~Server() -{ - _session.reset(); -} - -void -Server::handleMessage(Message::UP msg) { - msg->getTrace().trace(1, _name + " (message)", false); - if (!msg->getRoute().hasHops()) { - fprintf(stderr, "**** Server '%s' replying.\n", _name.c_str()); - Reply::UP reply(new EmptyReply()); - msg->swapState(*reply); - handleReply(std::move(reply)); - } else { - fprintf(stderr, "**** Server '%s' forwarding message.\n", _name.c_str()); - _session->forward(std::move(msg)); - } -} - -void -Server::handleReply(Reply::UP reply) { - reply->getTrace().trace(1, _name + " (reply)", false); - _session->forward(std::move(reply)); -} - -class App : public FastOS_Application -{ -public: - int Main(); -}; - -int -App::Main() -{ - if (_argc != 2) { - fprintf(stderr, "usage: %s <service-prefix>\n", _argv[0]); - return 1; - } - RPCMessageBus mb(ProtocolSet().add(IProtocol::SP(new SimpleProtocol())), - RPCNetworkParams() - .setIdentity(Identity(_argv[1])) - .setSlobrokConfig("file:slobrok.cfg"), - "file:routing.cfg"); - Server server(mb.getMessageBus(), _argv[1]); - while (true) { - FastOS_Thread::Sleep(1000); - } - return 0; -} - -int main(int argc, char **argv) { - App app; - return app.Entry(argc, argv); -} |