1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
|
// Copyright (C) 2014-2015 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 VSOMEIP_SD_SERVICE_DISCOVERY_FSM_HPP
#define VSOMEIP_SD_SERVICE_DISCOVERY_FSM_HPP
#include <mutex>
#include <string>
#include <boost/mpl/list.hpp>
#include <boost/statechart/custom_reaction.hpp>
#include <boost/statechart/state.hpp>
#include <boost/statechart/state_machine.hpp>
#include <boost/statechart/transition.hpp>
#include "../include/fsm_base.hpp"
#include "../include/fsm_events.hpp"
namespace vsomeip {
namespace sd {
class service_discovery_fsm;
class service_discovery;
///////////////////////////////////////////////////////////////////////////////
// Machine
///////////////////////////////////////////////////////////////////////////////
namespace mpl = boost::mpl;
namespace sc = boost::statechart;
namespace _sd {
struct inactive;
struct fsm: sc::state_machine<fsm, inactive>, public fsm_base {
fsm(boost::asio::io_service &_io);
virtual ~fsm();
void set_fsm(std::shared_ptr<service_discovery_fsm> _fsm);
void timer_expired(const boost::system::error_code &_error);
uint32_t initial_delay_;
uint32_t repetitions_base_delay_;
uint8_t repetitions_max_;
uint32_t cyclic_offer_delay_;
bool is_up_;
uint8_t run_;
std::weak_ptr<service_discovery_fsm> fsm_;
};
struct inactive: sc::state<inactive, fsm> {
inactive(my_context context);
typedef mpl::list<sc::custom_reaction<ev_none>,
sc::custom_reaction<ev_status_change> > reactions;
sc::result react(const ev_none &_event);
sc::result react(const ev_status_change &_event);
};
struct initial;
struct active: sc::state<active, fsm, initial> {
active(my_context _context);
~active();
typedef sc::custom_reaction<ev_status_change> reactions;
sc::result react(const ev_status_change &_event);
};
struct initial: sc::state<initial, active> {
initial(my_context _context);
typedef sc::custom_reaction<ev_timeout> reactions;
sc::result react(const ev_timeout &_event);
};
struct repeat: sc::state<repeat, active> {
repeat(my_context _context);
typedef mpl::list<sc::custom_reaction<ev_timeout>,
sc::custom_reaction<ev_find_service> > reactions;
sc::result react(const ev_timeout &_event);
sc::result react(const ev_find_service &_event);
};
struct announce: sc::state<announce, active> {
announce(my_context _context);
typedef mpl::list<sc::custom_reaction<ev_timeout>,
sc::custom_reaction<ev_find_service>,
sc::custom_reaction<ev_offer_change> > reactions;
sc::result react(const ev_timeout &_event);
sc::result react(const ev_find_service &_event);
sc::result react(const ev_offer_change &_event);
};
} // namespace _offer
///////////////////////////////////////////////////////////////////////////////
// Interface
///////////////////////////////////////////////////////////////////////////////
class service_discovery_fsm: public std::enable_shared_from_this<
service_discovery_fsm> {
public:
service_discovery_fsm(std::shared_ptr<service_discovery> _discovery);
void start();
void stop();
void send(bool _is_announcing);
inline void process(const sc::event_base &_event) {
std::lock_guard<std::mutex> its_lock(lock_);
fsm_->process_event(_event);
}
private:
std::weak_ptr<service_discovery> discovery_;
std::shared_ptr<_sd::fsm> fsm_;
std::mutex lock_;
};
} // namespace sd
} // namespace vsomeip
#endif // VSOMEIP_SD_SERVICE_DISCOVERY_FSM_HPP
|
