diff options
author | Juergen Gehring <juergen.gehring@bmw.de> | 2017-04-07 03:30:13 -0700 |
---|---|---|
committer | Juergen Gehring <juergen.gehring@bmw.de> | 2017-04-07 03:30:13 -0700 |
commit | 5315798ff81796217b55eb8c622f154bb0a1c487 (patch) | |
tree | a414da54a2ab36be5fbc2c95e551585c41cbc6f8 /test/restart_routing_tests/restart_routing_test_client.hpp | |
parent | c35b82a9459b866ab22bc3cabe274c7b36bca290 (diff) | |
download | vSomeIP-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.hpp | 50 |
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 |