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
184
185
186
187
188
189
190
191
192
193
194
195
196
197
198
199
200
201
202
|
#!/usr/bin/python
import os
import socket
import sys
import rpc_pb2 as rpc
import argparse
import subprocess
from tempfile import mkstemp
import time
log_file = 'config_file_test.log'
does_not_exist = 'does-not.exist'
def setup_swrk():
print('Connecting to CRIU in swrk mode.')
s1, s2 = socket.socketpair(socket.AF_UNIX, socket.SOCK_SEQPACKET)
kwargs = {}
if sys.version_info.major == 3:
kwargs["pass_fds"] = [s1.fileno()]
swrk = subprocess.Popen(['./criu', "swrk", "%d" % s1.fileno()], **kwargs)
s1.close()
return swrk, s2
def setup_config_file(content):
# Creating a temporary file which will be used as configuration file.
fd, path = mkstemp()
with os.fdopen(fd, 'w') as f:
f.write(content)
os.environ['CRIU_CONFIG_FILE'] = path
return path
def cleanup_config_file(path):
if os.environ.get('CRIU_CONFIG_FILE', None) is not None:
del os.environ['CRIU_CONFIG_FILE']
os.unlink(path)
def cleanup_output(path):
for f in (does_not_exist, log_file):
f = os.path.join(path, f)
if os.access(f, os.F_OK):
os.unlink(f)
def setup_criu_dump_request():
# Create criu msg, set it's type to dump request
# and set dump options. Checkout more options in protobuf/rpc.proto
req = rpc.criu_req()
req.type = rpc.DUMP
req.opts.leave_running = True
req.opts.log_level = 4
req.opts.log_file = log_file
req.opts.images_dir_fd = os.open(args['dir'], os.O_DIRECTORY)
# Not necessary, just for testing
req.opts.tcp_established = True
req.opts.shell_job = True
return req
def do_rpc(s, req):
# Send request
s.send(req.SerializeToString())
# Recv response
resp = rpc.criu_resp()
MAX_MSG_SIZE = 1024
resp.ParseFromString(s.recv(MAX_MSG_SIZE))
s.close()
return resp
def test_broken_configuration_file():
# Testing RPC configuration file mode with a broken configuration file.
# This should fail
content = 'hopefully-this-option-will-never=exist'
path = setup_config_file(content)
swrk, s = setup_swrk()
s.close()
# This test is only about detecting wrong configuration files.
# If we do not sleep it might happen that we kill CRIU before
# it parses the configuration file. A short sleep makes sure
# that the configuration file has been parsed. Hopefully.
# (I am sure this will fail horribly at some point)
time.sleep(0.3)
swrk.kill()
return_code = swrk.wait()
# delete temporary file again
cleanup_config_file(path)
if return_code != 1:
print('FAIL: CRIU should have returned 1 instead of %d' % return_code)
sys.exit(-1)
def search_in_log_file(log, message):
with open(os.path.join(args['dir'], log)) as f:
if message not in f.read():
print(
'FAIL: Missing the expected error message (%s) in the log file'
% message)
sys.exit(-1)
def check_results(resp, log):
# Check if the specified log file exists
if not os.path.isfile(os.path.join(args['dir'], log)):
print('FAIL: Expected log file %s does not exist' % log)
sys.exit(-1)
# Dump should have failed with: 'The criu itself is within dumped tree'
if resp.type != rpc.DUMP:
print('FAIL: Unexpected msg type %r' % resp.type)
sys.exit(-1)
if 'The criu itself is within dumped tree' not in resp.cr_errmsg:
print('FAIL: Missing the expected error message in RPC response')
sys.exit(-1)
# Look into the log file for the same message
search_in_log_file(log, 'The criu itself is within dumped tree')
def test_rpc_without_configuration_file():
# Testing without configuration file
# Just doing a dump and checking for the logfile
req = setup_criu_dump_request()
_, s = setup_swrk()
resp = do_rpc(s, req)
s.close()
check_results(resp, log_file)
def test_rpc_with_configuration_file():
# Testing with configuration file
# Just doing a dump and checking for the logfile
# Setting a different log file via configuration file
# This should not work as RPC settings overwrite configuration
# file settings in the default configuration.
log = does_not_exist
content = 'log-file ' + log + '\n'
content += 'no-tcp-established\nno-shell-job'
path = setup_config_file(content)
req = setup_criu_dump_request()
_, s = setup_swrk()
do_rpc(s, req)
s.close()
cleanup_config_file(path)
# Check if the specified log file exists
# It should not as configuration files do not overwrite RPC values.
if os.path.isfile(os.path.join(args['dir'], log)):
print('FAIL: log file %s should not exist' % log)
sys.exit(-1)
def test_rpc_with_configuration_file_overwriting_rpc():
# Testing with configuration file
# Just doing a dump and checking for the logfile
# Setting a different log file via configuration file
# This should not work as RPC settings overwrite configuration
# file settings in the default configuration.
log = does_not_exist
content = 'log-file ' + log + '\n'
content += 'no-tcp-established\nno-shell-job'
path = setup_config_file(content)
# Only set the configuration file via RPC;
# not via environment variable
del os.environ['CRIU_CONFIG_FILE']
req = setup_criu_dump_request()
req.opts.config_file = path
_, s = setup_swrk()
resp = do_rpc(s, req)
s.close()
cleanup_config_file(path)
check_results(resp, log)
parser = argparse.ArgumentParser(
description="Test config files using CRIU RPC")
parser.add_argument('dir',
type=str,
help="Directory where CRIU images should be placed")
args = vars(parser.parse_args())
cleanup_output(args['dir'])
test_broken_configuration_file()
cleanup_output(args['dir'])
test_rpc_without_configuration_file()
cleanup_output(args['dir'])
test_rpc_with_configuration_file()
cleanup_output(args['dir'])
test_rpc_with_configuration_file_overwriting_rpc()
cleanup_output(args['dir'])
|
