diff options
Diffstat (limited to 'messagebus/test/src/tests/speed/cpp-server.cpp')
-rw-r--r-- | messagebus/test/src/tests/speed/cpp-server.cpp | 77 |
1 files changed, 0 insertions, 77 deletions
diff --git a/messagebus/test/src/tests/speed/cpp-server.cpp b/messagebus/test/src/tests/speed/cpp-server.cpp deleted file mode 100644 index c2cd9bf262a..00000000000 --- a/messagebus/test/src/tests/speed/cpp-server.cpp +++ /dev/null @@ -1,77 +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> - -using namespace mbus; - -class Server : public IMessageHandler -{ -private: - DestinationSession::UP _session; -public: - Server(MessageBus &bus); - ~Server(); - void handleMessage(Message::UP msg); -}; - -Server::Server(MessageBus &bus) - : _session(bus.createDestinationSession("session", true, *this)) -{ - fprintf(stderr, "cpp server started\n"); -} - -Server::~Server() -{ - _session.reset(); -} - -void -Server::handleMessage(Message::UP msg) { - if ((msg->getProtocol() == SimpleProtocol::NAME) - && (msg->getType() == SimpleProtocol::MESSAGE) - && (static_cast<SimpleMessage&>(*msg).getValue() == "message")) - { - Reply::UP reply(new SimpleReply("OK")); - msg->swapState(*reply); - _session->reply(std::move(reply)); - } else { - Reply::UP reply(new SimpleReply("FAIL")); - msg->swapState(*reply); - _session->reply(std::move(reply)); - } -} - -class App : public FastOS_Application -{ -public: - int Main(); -}; - -int -App::Main() -{ - RPCMessageBus mb(ProtocolSet().add(IProtocol::SP(new SimpleProtocol())), - RPCNetworkParams() - .setIdentity(Identity("server/cpp")) - .setSlobrokConfig("file:slobrok.cfg"), - "file:routing.cfg"); - Server server(mb.getMessageBus()); - while (true) { - FastOS_Thread::Sleep(1000); - } - return 0; -} - -int main(int argc, char **argv) { - App app; - return app.Entry(argc, argv); -} |