blob: b8062017b8cafbd60a9f40f4b524eb1bdecc6f33 (
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
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
|
#pragma once
#include "ikvm_args.hpp"
#include "ikvm_input.hpp"
#include "ikvm_video.hpp"
#include <rfb/rfb.h>
#include <vector>
namespace ikvm
{
/*
* @class Server
* @brief Manages the RFB server connection and updates
*/
class Server
{
public:
/*
* @struct ClientData
* @brief Store necessary data for each connected RFB client
*/
struct ClientData
{
/*
* @brief Constructs ClientData object
*
* @param[in] s - Number of frames to skip when client connects
* @param[in] i - Pointer to Input object
*/
ClientData(int s, Input* i) : skipFrame(s), input(i)
{
}
~ClientData() = default;
ClientData(const ClientData&) = default;
ClientData& operator=(const ClientData&) = default;
ClientData(ClientData&&) = default;
ClientData& operator=(ClientData&&) = default;
int skipFrame;
Input* input;
};
/*
* @brief Constructs Server object
*
* @param[in] args - Reference to Args object
* @param[in] i - Reference to Input object
* @param[in] v - Reference to Video object
*/
Server(const Args& args, Input& i, Video& v);
~Server();
Server(const Server&) = default;
Server& operator=(const Server&) = default;
Server(Server&&) = default;
Server& operator=(Server&&) = default;
/* @brief Resizes the RFB framebuffer */
void resize();
/* @brief Executes any pending RFB updates and client input */
void run();
/* @brief Sends pending video frame to clients */
void sendFrame();
/*
* @brief Indicates whether or not video data is desired
*
* @return Boolean to indicate whether any clients need a video frame
*/
inline bool wantsFrame() const
{
return server->clientHead;
}
/*
* @brief Get the Video object
*
* @return Reference to the Video object
*/
inline const Video& getVideo() const
{
return video;
}
private:
/*
* @brief Handler for a client disconnecting
*
* @param[in] cl - Handle to the client object
*/
static void clientGone(rfbClientPtr cl);
/*
* @brief Handler for client connecting
*
* @param[in] cl - Handle to the client object
*/
static enum rfbNewClientAction newClient(rfbClientPtr cl);
/* @brief Performs the resize operation on the framebuffer */
void doResize();
/* @brief Boolean to indicate if a resize operation is on-going */
bool pendingResize;
/* @brief Number of frames handled since a client connected */
int frameCounter;
/* @brief Number of connected clients */
unsigned int numClients;
/* @brief Microseconds to process RFB events every frame */
long int processTime;
/* @brief Handle to the RFB server object */
rfbScreenInfoPtr server;
/* @brief Reference to the Input object */
Input& input;
/* @brief Reference to the Video object */
Video& video;
/* @brief Default framebuffer storage */
std::vector<char> framebuffer;
/* @brief Cursor bitmap width */
static constexpr int cursorWidth = 20;
/* @brief Cursor bitmap height */
static constexpr int cursorHeight = 20;
/* @brief Cursor bitmap */
static constexpr char cursor[] = " "
" x "
" xx "
" xxx "
" xxxx "
" xxxxx "
" xxxxxx "
" xxxxxxx "
" xxxxxxxx "
" xxxxxxxxx "
" xxxxxxxxxx "
" xxxxxxxxxxx "
" xxxxxxx "
" xxxxxxx "
" xxx xxx "
" xx xxx "
" x xxx "
" xxx "
" x "
" ";
/* @brief Cursor bitmap mask */
static constexpr char cursorMask[] = " o "
"oxo "
"oxxo "
"oxxxo "
"oxxxxo "
"oxxxxxo "
"oxxxxxxo "
"oxxxxxxxo "
"oxxxxxxxxo "
"oxxxxxxxxxo "
"oxxxxxxxxxxo "
"oxxxxxxxxxxxo "
"oxxxxxxxoooo "
"oxxxxxxxo "
"oxxxooxxxo "
"oxxo oxxxo "
"oxo oxxxo "
" o oxxxo "
" oxo "
" o ";
};
} // namespace ikvm
|
