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
168
169
170
171
172
173
174
175
176
177
178
179
180
181
182
183
|
/*
Copyright (C) 2009-2016 Red Hat, Inc.
This library is free software; you can redistribute it and/or
modify it under the terms of the GNU Lesser General Public
License as published by the Free Software Foundation; either
version 2.1 of the License, or (at your option) any later version.
This library is distributed in the hope that it will be useful,
but WITHOUT ANY WARRANTY; without even the implied warranty of
MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU
Lesser General Public License for more details.
You should have received a copy of the GNU Lesser General Public
License along with this library; if not, see <http://www.gnu.org/licenses/>.
*/
#ifndef RED_CHANNEL_CLIENT_H_
#define RED_CHANNEL_CLIENT_H_
#include <glib-object.h>
#include <gio/gio.h>
#include <common/marshaller.h>
#include "red-pipe-item.h"
#include "red-stream.h"
#include "red-channel.h"
G_BEGIN_DECLS
#define RED_TYPE_CHANNEL_CLIENT red_channel_client_get_type()
SPICE_DECLARE_TYPE(RedChannelClient, red_channel_client, CHANNEL_CLIENT);
struct RedChannelClient: public GObject
{
bool is_connected() const;
static void default_migrate(RedChannelClient *rcc);
bool is_waiting_for_migrate_data() const;
bool test_remote_common_cap(uint32_t cap) const;
bool test_remote_cap(uint32_t cap) const;
/* shutdown is the only safe thing to do out of the client/channel
* thread. It will not touch the rings, just shutdown the socket.
* It should be followed by some way to guarantee a disconnection. */
void shutdown();
/* handles general channel msgs from the client */
static bool handle_message(RedChannelClient *rcc, uint16_t type,
uint32_t size, void *message);
/* when preparing send_data: should call init and then use marshaller */
void init_send_data(uint16_t msg_type);
uint64_t get_message_serial() const;
/* When sending a msg. Should first call begin_send_message.
* It will first send the pending urgent data, if there is any, and then
* the rest of the data.
*/
void begin_send_message();
/*
* Stores the current send data, and switches to urgent send data.
* When it begins the actual send, it will send first the urgent data
* and afterward the rest of the data.
* Should be called only if during the marshalling of on message,
* the need to send another message, before, rises.
* Important: the serial of the non-urgent sent data, will be succeeded.
* return: the urgent send data marshaller
*/
SpiceMarshaller *switch_to_urgent_sender();
/* returns -1 if we don't have an estimation */
int get_roundtrip_ms() const;
/* Checks periodically if the connection is still alive */
void start_connectivity_monitoring(uint32_t timeout_ms);
void pipe_add_push(RedPipeItem *item);
void pipe_add(RedPipeItem *item);
void pipe_add_after(RedPipeItem *item, RedPipeItem *pos);
void pipe_add_after_pos(RedPipeItem *item, GList *pos);
int pipe_item_is_linked(RedPipeItem *item);
void pipe_remove_and_release(RedPipeItem *item);
void pipe_remove_and_release_pos(GList *item_pos);
void pipe_add_tail(RedPipeItem *item);
/* for types that use this routine -> the pipe item should be freed */
void pipe_add_type(int pipe_item_type);
static RedPipeItem *new_empty_msg(int msg_type);
void pipe_add_empty_msg(int msg_type);
gboolean pipe_is_empty();
uint32_t get_pipe_size();
GQueue* get_pipe();
bool is_mini_header() const;
void ack_zero_messages_window();
void ack_set_client_window(int client_window);
void push_set_ack();
bool is_blocked() const;
/* helper for channels that have complex logic that can possibly ready a send */
int send_message_pending();
bool no_item_being_sent() const;
void push();
void receive();
void send();
void disconnect();
/* Note: the valid times to call red_channel_get_marshaller are just during send_item callback. */
SpiceMarshaller *get_marshaller();
RedStream *get_stream();
RedClient *get_client();
/* Note that the header is valid only between red_channel_reset_send_data and
* red_channel_begin_send_message.*/
void set_header_sub_list(uint32_t sub_list);
/*
* blocking functions.
*
* timeout is in nano sec. -1 for no timeout.
*
* Return: TRUE if waiting succeeded. FALSE if timeout expired.
*/
bool wait_pipe_item_sent(GList *item_pos, int64_t timeout);
bool wait_outgoing_item(int64_t timeout);
RedChannel* get_channel();
void semi_seamless_migration_complete();
void init_outgoing_messages_window();
bool set_migration_seamless();
/* allow to block or unblock reading */
void block_read();
void unblock_read();
void ref() { g_object_ref(this); }
void unref() { g_object_unref(this); }
RedChannelClientPrivate *priv;
};
struct RedChannelClientClass
{
GObjectClass parent_class;
/* configure socket connected to the client */
bool (*config_socket)(RedChannelClient *rcc);
uint8_t *(*alloc_recv_buf)(RedChannelClient *channel, uint16_t type, uint32_t size);
void (*release_recv_buf)(RedChannelClient *channel, uint16_t type, uint32_t size, uint8_t *msg);
void (*on_disconnect)(RedChannelClient *rcc);
};
#define SPICE_SERVER_ERROR spice_server_error_quark()
GQuark spice_server_error_quark(void);
typedef enum
{
SPICE_SERVER_ERROR_FAILED
} SpiceServerError;
/* Messages handled by RedChannel
* SET_ACK - sent to client on channel connection
* Note that the numbers don't have to correspond to spice message types,
* but we keep the 100 first allocated for base channel approach.
* */
enum {
RED_PIPE_ITEM_TYPE_SET_ACK=1,
RED_PIPE_ITEM_TYPE_MIGRATE,
RED_PIPE_ITEM_TYPE_EMPTY_MSG,
RED_PIPE_ITEM_TYPE_PING,
RED_PIPE_ITEM_TYPE_MARKER,
RED_PIPE_ITEM_TYPE_CHANNEL_BASE=101,
};
G_END_DECLS
#endif /* RED_CHANNEL_CLIENT_H_ */
|
