forked from QubesOS/qubes-vmm-xen
-
Notifications
You must be signed in to change notification settings - Fork 0
/
patch-0001-vchan-socket-proxy-add-reconnect-marker-support.patch
146 lines (138 loc) · 5.98 KB
/
patch-0001-vchan-socket-proxy-add-reconnect-marker-support.patch
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
From 2c4fdbc7fea7bb36ed868ad7e3dceeba60e9bfdd Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Marek=20Marczykowski-G=C3=B3recki?=
Date: Sat, 3 Sep 2022 03:48:42 +0200
Subject: [PATCH 1/2] vchan-socket-proxy: add reconnect marker support
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit
When vchan client reconnect quickly, the server may not notice it. This
means, it won't reconnect the UNIX socket either. For QMP, it will
prevent the client to see the QMP protocol handshake, and the
communication will timeout.
Solve the issue by sending in-band connect marker. Whenever server sees
one (elsewhere than the first byte in the connection), handle it as a
client had reconnected. The marker is a one byte, and the user need to
choose something that doesn't appear in the data stream elsewhere.
Signed-off-by: Marek Marczykowski-Górecki <[email protected]>
---
tools/vchan/vchan-socket-proxy.c | 51 +++++++++++++++++++++++++++++++-
1 file changed, 50 insertions(+), 1 deletion(-)
diff --git a/tools/vchan/vchan-socket-proxy.c b/tools/vchan/vchan-socket-proxy.c
index e1d959c6d15c..006c84ad5970 100644
--- a/tools/libvchan/vchan-socket-proxy.c
+++ b/tools/libvchan/vchan-socket-proxy.c
@@ -31,6 +31,7 @@
* One client is served at a time, clients needs to coordinate this themselves.
*/
+#define _GNU_SOURCE
#include <stdlib.h>
#include <stdio.h>
#include <string.h>
@@ -54,6 +55,9 @@ static void usage(char** argv)
"\t-m, --mode=client|server - vchan connection mode (client by default)\n"
"\t-s, --state-path=path - xenstore path where write \"running\" to \n"
"\t at startup\n"
+ "\t-r, --reconnect-marker=value - send(client)/expect(server) a\n"
+ "\t single-byte marker to detect quick reconnects and\n"
+ "\t force reconnecting UNIX socket\n"
"\t-v, --verbose - verbose logging\n"
"\n"
"client: client of a vchan connection, fourth parameter can be:\n"
@@ -61,7 +65,7 @@ static void usage(char** argv)
"\t whenever new connection is accepted;\n"
"\t handle multiple _subsequent_ connections, until terminated\n"
"\n"
- "\tfile-no: except open FD of a socket in listen mode;\n"
+ "\tfile-no: expect open FD of a socket in listen mode;\n"
"\t otherwise similar to socket-path\n"
"\n"
"\t-: open vchan connection immediately and pass the data\n"
@@ -88,6 +92,7 @@ char outbuf[BUFSIZE];
int insiz = 0;
int outsiz = 0;
int verbose = 0;
+int reconnect_marker_value = -1;
struct vchan_proxy_state {
struct libxenvchan *ctrl;
@@ -291,6 +296,7 @@ int data_loop(struct vchan_proxy_state *state)
int ret;
int libxenvchan_fd;
int max_fd;
+ bool just_connected = true;
libxenvchan_fd = libxenvchan_fd_for_select(state->ctrl);
for (;;) {
@@ -368,8 +374,33 @@ int data_loop(struct vchan_proxy_state *state)
exit(1);
if (verbose)
fprintf(stderr, "from-vchan: %.*s\n", ret, outbuf + outsiz);
+ if (reconnect_marker_value != -1) {
+ char *reconnect_found =
+ memrchr(outbuf + outsiz, reconnect_marker_value, ret);
+ if (just_connected && reconnect_found == outbuf + outsiz) {
+ /* skip reconnect marker at the very first byte of the data
+ * stream */
+ memmove(outbuf + outsiz, outbuf + outsiz + 1, ret - 1);
+ ret -= 1;
+ } else if (reconnect_found) {
+ size_t newsiz = outbuf + outsiz + ret - reconnect_found - 1;
+ if (verbose)
+ fprintf(stderr, "reconnect marker found\n");
+ /* discard everything before and including the reconnect
+ * marker */
+ memmove(outbuf, reconnect_found + 1, newsiz);
+ outsiz = newsiz;
+ /* then handle it as the client had just disconnected */
+ close(state->output_fd);
+ state->output_fd = -1;
+ close(state->input_fd);
+ state->input_fd = -1;
+ return 0;
+ }
+ }
outsiz += ret;
socket_wr(state->output_fd);
+ just_connected = false;
}
}
return 0;
@@ -385,6 +416,7 @@ static struct option options[] = {
{ "mode", required_argument, NULL, 'm' },
{ "verbose", no_argument, NULL, 'v' },
{ "state-path", required_argument, NULL, 's' },
+ { "reconnect-marker", required_argument, NULL, 'r' },
{ }
};
@@ -421,6 +453,14 @@ int main(int argc, char **argv)
case 's':
state_path = optarg;
break;
+ case 'r':
+ reconnect_marker_value = atoi(optarg);
+ if (reconnect_marker_value < 0 || reconnect_marker_value > 255) {
+ fprintf(stderr, "invalid argument for --reconnect-marker, "
+ "must be a number between 0 and 255\n");
+ usage(argv);
+ }
+ break;
case '?':
usage(argv);
}
@@ -509,6 +549,15 @@ int main(int argc, char **argv)
ret = 1;
break;
}
+ if (reconnect_marker_value != -1) {
+ const char marker_buf[] = { reconnect_marker_value };
+
+ if (libxenvchan_write(state.ctrl, marker_buf, sizeof(marker_buf))
+ != sizeof(marker_buf)) {
+ fprintf(stderr, "failed to send reconnect marker\n");
+ break;
+ }
+ }
if (data_loop(&state) != 0)
break;
/* don't reconnect if output was stdout */
--
2.35.3