blob: bb455be24ded6e430a42a7fa7704f017b0c60b91 (
plain)
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
|
/*
Itay Marom
Cisco Systems, Inc.
*/
/*
Copyright (c) 2015-2015 Cisco Systems, Inc.
Licensed under the Apache License, Version 2.0 (the "License");
you may not use this file except in compliance with the License.
You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software
distributed under the License is distributed on an "AS IS" BASIS,
WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
See the License for the specific language governing permissions and
limitations under the License.
*/
#ifndef __TREX_RPC_SERVER_API_H__
#define __TREX_RPC_SERVER_API_H__
#include <stdint.h>
#include <vector>
#include <thread>
#include <string>
#include <stdexcept>
#include <trex_rpc_exception_api.h>
class TrexRpcServerInterface;
/**
* defines a configuration of generic RPC server
*
* @author imarom (17-Aug-15)
*/
class TrexRpcServerConfig {
public:
enum rpc_prot_e {
RPC_PROT_TCP
};
TrexRpcServerConfig(rpc_prot_e protocol, uint16_t port) : m_protocol(protocol), m_port(port) {
}
uint16_t get_port() {
return m_port;
}
rpc_prot_e get_protocol() {
return m_protocol;
}
private:
rpc_prot_e m_protocol;
uint16_t m_port;
};
/**
* generic type RPC server instance
*
* @author imarom (12-Aug-15)
*/
class TrexRpcServerInterface {
public:
TrexRpcServerInterface(const TrexRpcServerConfig &cfg);
virtual ~TrexRpcServerInterface();
/**
* starts the server
*
*/
void start();
/**
* stops the server
*
*/
void stop();
/**
* return TRUE if server is active
*
*/
bool is_running();
protected:
/**
* instances implement this
*
*/
virtual void _rpc_thread_cb() = 0;
virtual void _stop_rpc_thread() = 0;
TrexRpcServerConfig m_cfg;
bool m_is_running;
std::thread *m_thread;
};
/**
* TREX RPC server
* may contain serveral types of RPC servers
* (request response, async and etc.)
*
* @author imarom (12-Aug-15)
*/
class TrexRpcServer {
public:
/* currently only request response server config is required */
TrexRpcServer(const TrexRpcServerConfig &req_resp_cfg);
~TrexRpcServer();
void start();
void stop();
static const std::string &get_server_uptime() {
return s_server_uptime;
}
private:
std::vector<TrexRpcServerInterface *> m_servers;
static const std::string s_server_uptime;
};
#endif /* __TREX_RPC_SERVER_API_H__ */
|
