summaryrefslogtreecommitdiffstats
path: root/messagebus_test/src/tests/speed/cpp-client.cpp
diff options
context:
space:
mode:
Diffstat (limited to 'messagebus_test/src/tests/speed/cpp-client.cpp')
-rw-r--r--messagebus_test/src/tests/speed/cpp-client.cpp11
1 files changed, 6 insertions, 5 deletions
diff --git a/messagebus_test/src/tests/speed/cpp-client.cpp b/messagebus_test/src/tests/speed/cpp-client.cpp
index d8ba5d85169..bfd2faf735e 100644
--- a/messagebus_test/src/tests/speed/cpp-client.cpp
+++ b/messagebus_test/src/tests/speed/cpp-client.cpp
@@ -9,7 +9,7 @@
#include <vespa/messagebus/testlib/simplereply.h>
#include <vespa/vespalib/util/time.h>
#include <thread>
-#include <vespa/fastos/app.h>
+#include <vespa/vespalib/util/signalhandler.h>
using namespace mbus;
using namespace std::chrono_literals;
@@ -84,14 +84,14 @@ Client::handleReply(Reply::UP reply) {
send();
}
-class App : public FastOS_Application
+class App
{
public:
- int Main() override;
+ int main(int argc, char **argv);
};
int
-App::Main()
+App::main(int, char **)
{
auto retryPolicy = std::make_shared<RetryTransientErrorsPolicy>();
retryPolicy->setBaseDelay(0.1);
@@ -133,10 +133,11 @@ App::Main()
}
int main(int argc, char **argv) {
+ vespalib::SignalHandler::PIPE.ignore();
fprintf(stderr, "started '%s'\n", argv[0]);
fflush(stderr);
App app;
- int r = app.Entry(argc, argv);
+ int r = app.main(argc, argv);
fprintf(stderr, "stopping '%s'\n", argv[0]);
fflush(stderr);
return r;