summaryrefslogtreecommitdiff
path: root/test/restart_routing_tests/restart_routing_test_client.hpp
diff options
context:
space:
mode:
authorJuergen Gehring <juergen.gehring@bmw.de>2017-04-07 03:30:13 -0700
committerJuergen Gehring <juergen.gehring@bmw.de>2017-04-07 03:30:13 -0700
commit5315798ff81796217b55eb8c622f154bb0a1c487 (patch)
treea414da54a2ab36be5fbc2c95e551585c41cbc6f8 /test/restart_routing_tests/restart_routing_test_client.hpp
parentc35b82a9459b866ab22bc3cabe274c7b36bca290 (diff)
downloadvSomeIP-maintain/2.6.tar.gz
vSomeIP 2.6.22.6.2maintain/2.6
Diffstat (limited to 'test/restart_routing_tests/restart_routing_test_client.hpp')
-rw-r--r--test/restart_routing_tests/restart_routing_test_client.hpp50
1 files changed, 50 insertions, 0 deletions
diff --git a/test/restart_routing_tests/restart_routing_test_client.hpp b/test/restart_routing_tests/restart_routing_test_client.hpp
new file mode 100644
index 0000000..fdc56d4
--- /dev/null
+++ b/test/restart_routing_tests/restart_routing_test_client.hpp
@@ -0,0 +1,50 @@
+
+// Copyright (C) 2015-2017 Bayerische Motoren Werke Aktiengesellschaft (BMW AG)
+// This Source Code Form is subject to the terms of the Mozilla Public
+// License, v. 2.0. If a copy of the MPL was not distributed with this
+// file, You can obtain one at http://mozilla.org/MPL/2.0/.
+
+#ifndef RESTART_ROUTING_TEST_CLIENT_HPP
+#define RESTART_ROUTING_TEST_CLIENT_HPP
+
+#include <gtest/gtest.h>
+
+#include <vsomeip/vsomeip.hpp>
+
+#include "../someip_test_globals.hpp"
+
+#include <thread>
+#include <mutex>
+#include <condition_variable>
+#include <atomic>
+
+class routing_restart_test_client {
+public:
+ routing_restart_test_client();
+ bool init();
+ void start();
+ void stop();
+
+ void on_state(vsomeip::state_type_e _state);
+ void on_availability(vsomeip::service_t _service,
+ vsomeip::instance_t _instance, bool _is_available);
+ void on_message(const std::shared_ptr<vsomeip::message> &_response);
+
+ void run();
+ void join_sender_thread();
+
+private:
+ void shutdown_service();
+
+ std::shared_ptr<vsomeip::application> app_;
+
+ std::mutex mutex_;
+ std::condition_variable condition_;
+ bool is_available_;
+
+ std::thread sender_;
+
+ std::atomic<std::uint32_t> received_responses_;
+};
+
+#endif // RESTART_ROUTING_TEST_CLIENT_HPP