1 | # -*- coding: utf-8 -*-
|
---|
2 | # $Id: tst-txsclient.py 62484 2016-07-22 18:35:33Z vboxsync $
|
---|
3 |
|
---|
4 | """
|
---|
5 | Simple testcase for txsclient.py.
|
---|
6 | """
|
---|
7 |
|
---|
8 | __copyright__ = \
|
---|
9 | """
|
---|
10 | Copyright (C) 2010-2016 Oracle Corporation
|
---|
11 |
|
---|
12 | This file is part of VirtualBox Open Source Edition (OSE), as
|
---|
13 | available from http://www.virtualbox.org. This file is free software;
|
---|
14 | you can redistribute it and/or modify it under the terms of the GNU
|
---|
15 | General Public License (GPL) as published by the Free Software
|
---|
16 | Foundation, in version 2 as it comes in the "COPYING" file of the
|
---|
17 | VirtualBox OSE distribution. VirtualBox OSE is distributed in the
|
---|
18 | hope that it will be useful, but WITHOUT ANY WARRANTY of any kind.
|
---|
19 |
|
---|
20 | The contents of this file may alternatively be used under the terms
|
---|
21 | of the Common Development and Distribution License Version 1.0
|
---|
22 | (CDDL) only, as it comes in the "COPYING.CDDL" file of the
|
---|
23 | VirtualBox OSE distribution, in which case the provisions of the
|
---|
24 | CDDL are applicable instead of those of the GPL.
|
---|
25 |
|
---|
26 | You may elect to license modified versions of this file under the
|
---|
27 | terms and conditions of either the GPL or the CDDL or both.
|
---|
28 | """
|
---|
29 | __version__ = "$Revision: 62484 $"
|
---|
30 |
|
---|
31 | # Standard python imports.
|
---|
32 | import os
|
---|
33 | import sys
|
---|
34 | import types
|
---|
35 |
|
---|
36 | # Validation Kit imports.
|
---|
37 | sys.path.insert(0, '.');
|
---|
38 | sys.path.insert(0, '..');
|
---|
39 | import testdriver.txsclient as txsclient
|
---|
40 | import testdriver.reporter as reporter
|
---|
41 | from common import utils;
|
---|
42 |
|
---|
43 | g_cTests = 0;
|
---|
44 | g_cFailures = 0
|
---|
45 |
|
---|
46 | def boolRes(rc, fExpect = True):
|
---|
47 | """Checks a boolean result."""
|
---|
48 | global g_cTests, g_cFailures;
|
---|
49 | g_cTests = g_cTests + 1;
|
---|
50 | if isinstance(rc, types.BooleanType):
|
---|
51 | if rc == fExpect:
|
---|
52 | return 'PASSED';
|
---|
53 | g_cFailures = g_cFailures + 1;
|
---|
54 | return 'FAILED';
|
---|
55 |
|
---|
56 | def stringRes(rc, sExpect):
|
---|
57 | """Checks a string result."""
|
---|
58 | global g_cTests, g_cFailures;
|
---|
59 | g_cTests = g_cTests + 1;
|
---|
60 | if isinstance(rc, basestring):
|
---|
61 | if rc == sExpect:
|
---|
62 | return 'PASSED';
|
---|
63 | g_cFailures = g_cFailures + 1;
|
---|
64 | return 'FAILED';
|
---|
65 |
|
---|
66 | def main(asArgs): # pylint: disable=C0111,R0914,R0915
|
---|
67 | cMsTimeout = long(30*1000);
|
---|
68 | sAddress = 'localhost';
|
---|
69 | uPort = None;
|
---|
70 | fReversedSetup = False;
|
---|
71 | fReboot = False;
|
---|
72 | fStdTests = True;
|
---|
73 |
|
---|
74 | i = 1;
|
---|
75 | while i < len(asArgs):
|
---|
76 | if asArgs[i] == '--hostname':
|
---|
77 | sAddress = asArgs[i + 1];
|
---|
78 | i = i + 2;
|
---|
79 | elif asArgs[i] == '--port':
|
---|
80 | uPort = int(asArgs[i + 1]);
|
---|
81 | i = i + 2;
|
---|
82 | elif asArgs[i] == '--reversed-setup':
|
---|
83 | fReversedSetup = True;
|
---|
84 | i = i + 1;
|
---|
85 | elif asArgs[i] == '--timeout':
|
---|
86 | cMsTimeout = long(asArgs[i + 1]);
|
---|
87 | i = i + 2;
|
---|
88 | elif asArgs[i] == '--reboot':
|
---|
89 | fReboot = True;
|
---|
90 | fStdTests = False;
|
---|
91 | i = i + 1;
|
---|
92 | elif asArgs[i] == '--help':
|
---|
93 | print 'tst-txsclient.py [--hostname <addr|name>] [--port <num>] [--timeout <cMS>] [--reboot] [--reversed-setup]'
|
---|
94 | return 0;
|
---|
95 | else:
|
---|
96 | print 'Unknown argument: %s' % (asArgs[i]);
|
---|
97 | return 2;
|
---|
98 |
|
---|
99 | if uPort is None:
|
---|
100 | oSession = txsclient.openTcpSession(cMsTimeout, sAddress, fReversedSetup = fReversedSetup);
|
---|
101 | else:
|
---|
102 | oSession = txsclient.openTcpSession(cMsTimeout, sAddress, uPort = uPort, fReversedSetup = fReversedSetup);
|
---|
103 | if oSession is None:
|
---|
104 | print 'openTcpSession failed';
|
---|
105 | return 1;
|
---|
106 |
|
---|
107 | fDone = oSession.waitForTask(30*1000);
|
---|
108 | print 'connect: waitForTask -> %s, result %s' % (fDone, oSession.getResult());
|
---|
109 | if fDone is True and oSession.isSuccess():
|
---|
110 | if fStdTests:
|
---|
111 | # Get the UUID of the remote instance.
|
---|
112 | sUuid = oSession.syncUuid();
|
---|
113 | if sUuid is not False:
|
---|
114 | print '%s: UUID = %s' % (boolRes(True), sUuid);
|
---|
115 | else:
|
---|
116 | print '%s: UUID' % (boolRes(False),);
|
---|
117 |
|
---|
118 | # Create and remove a directory on the scratch area.
|
---|
119 | rc = oSession.syncMkDir('${SCRATCH}/testdir1');
|
---|
120 | print '%s: MKDIR(${SCRATCH}/testdir1) -> %s' % (boolRes(rc), rc);
|
---|
121 |
|
---|
122 | rc = oSession.syncIsDir('${SCRATCH}/testdir1');
|
---|
123 | print '%s: ISDIR(${SCRATCH}/testdir1) -> %s' % (boolRes(rc), rc);
|
---|
124 |
|
---|
125 | rc = oSession.syncRmDir('${SCRATCH}/testdir1');
|
---|
126 | print '%s: RMDIR(${SCRATCH}/testdir1) -> %s' % (boolRes(rc), rc);
|
---|
127 |
|
---|
128 | # Create a two-level subdir.
|
---|
129 | rc = oSession.syncMkDirPath('${SCRATCH}/testdir2/subdir1');
|
---|
130 | print '%s: MKDRPATH(${SCRATCH}/testdir2/subdir1) -> %s' % (boolRes(rc), rc);
|
---|
131 |
|
---|
132 | rc = oSession.syncIsDir('${SCRATCH}/testdir2');
|
---|
133 | print '%s: ISDIR(${SCRATCH}/testdir2) -> %s' % (boolRes(rc), rc);
|
---|
134 | rc = oSession.syncIsDir('${SCRATCH}/testdir2/');
|
---|
135 | print '%s: ISDIR(${SCRATCH}/testdir2/) -> %s' % (boolRes(rc), rc);
|
---|
136 | rc = oSession.syncIsDir('${SCRATCH}/testdir2/subdir1');
|
---|
137 | print '%s: ISDIR(${SCRATCH}/testdir2/subdir1) -> %s' % (boolRes(rc), rc);
|
---|
138 |
|
---|
139 | rc = oSession.syncRmTree('${SCRATCH}/testdir2');
|
---|
140 | print '%s: RMTREE(${SCRATCH}/testdir2) -> %s' % (boolRes(rc), rc);
|
---|
141 |
|
---|
142 | # Check out a simple file.
|
---|
143 | rc = oSession.syncUploadString('howdy', '${SCRATCH}/howdyfile');
|
---|
144 | print '%s: PUT FILE(${SCRATCH}/howdyfile) -> %s' % (boolRes(rc), rc);
|
---|
145 |
|
---|
146 | rc = oSession.syncUploadString('howdy-replaced', '${SCRATCH}/howdyfile');
|
---|
147 | print '%s: PUT FILE(${SCRATCH}/howdyfile) -> %s' % (boolRes(rc), rc);
|
---|
148 |
|
---|
149 | rc = oSession.syncDownloadString('${SCRATCH}/howdyfile');
|
---|
150 | print '%s: GET FILE(${SCRATCH}/howdyfile) -> "%s" expected "howdy-replaced"' % (stringRes(rc, 'howdy-replaced'), rc);
|
---|
151 |
|
---|
152 | rc = oSession.syncIsFile('${SCRATCH}/howdyfile');
|
---|
153 | print '%s: ISFILE(${SCRATCH}/howdyfile) -> %s' % (boolRes(rc), rc);
|
---|
154 | rc = oSession.syncIsDir('${SCRATCH}/howdyfile');
|
---|
155 | print '%s: ISDIR(${SCRATCH}/howdyfile) -> %s' % (boolRes(rc, False), rc);
|
---|
156 | rc = oSession.syncIsSymlink('${SCRATCH}/howdyfile');
|
---|
157 | print '%s: ISSYMLNK(${SCRATCH}/howdyfile) -> %s' % (boolRes(rc, False), rc);
|
---|
158 |
|
---|
159 | rc = oSession.syncRmFile('${SCRATCH}/howdyfile');
|
---|
160 | print '%s: RMFILE(${SCRATCH}/howdyfile) -> %s' % (boolRes(rc), rc);
|
---|
161 |
|
---|
162 | # Unicode filename (may or may not work, LANG/LC_TYPE dependent on some hosts).
|
---|
163 | rc = oSession.syncUploadString('howdy', u'${SCRATCH}/Schröder');
|
---|
164 | print (u'%s: PUT FILE(${SCRATCH}/Schröder) -> %s' % (boolRes(rc), rc)).encode('ascii', 'replace');
|
---|
165 |
|
---|
166 | rc = oSession.syncIsFile(u'${SCRATCH}/Schröder');
|
---|
167 | print (u'%s: ISFILE(${SCRATCH}/Schröder) -> %s' % (boolRes(rc), rc)).encode('ascii', 'replace');
|
---|
168 |
|
---|
169 | rc = oSession.syncRmFile(u'${SCRATCH}/Schröder');
|
---|
170 | print (u'%s: RMFILE(${SCRATCH}/Schröder) -> %s' % (boolRes(rc), rc)).encode('ascii', 'replace');
|
---|
171 |
|
---|
172 | # Finally, some file uploading and downloading with unicode filenames.
|
---|
173 | strUpFile = 'tst-txsclient-upload.bin';
|
---|
174 | strDwnFile = 'tst-txsclient-download.bin';
|
---|
175 | try:
|
---|
176 | abRandFile = os.urandom(257897);
|
---|
177 | except:
|
---|
178 | print 'INFO: no urandom... falling back on a simple string.'
|
---|
179 | abRandFile = 'asdflkjasdlfkjasdlfkjq023942relwjgkna9epr865u2nm345;hndafgoukhasre5kb2453km';
|
---|
180 | for i in range(1, 64):
|
---|
181 | abRandFile += abRandFile;
|
---|
182 | try:
|
---|
183 | oLocalFile = utils.openNoInherit(strUpFile, 'w+b');
|
---|
184 | oLocalFile.write(abRandFile);
|
---|
185 | oLocalFile.close();
|
---|
186 | rc = True;
|
---|
187 | except:
|
---|
188 | rc = False;
|
---|
189 | print('%s: creating file (%s) to upload failed....' % (boolRes(rc), strUpFile));
|
---|
190 |
|
---|
191 | if rc is True:
|
---|
192 | rc = oSession.syncUploadFile(strUpFile, '${SCRATCH}/tst-txsclient-uploaded.bin')
|
---|
193 | print('%s: PUT FILE(%s, ${SCRATCH}/tst-txsclient-uploaded.bin) -> %s' % (boolRes(rc), strUpFile, rc));
|
---|
194 |
|
---|
195 | rc = oSession.syncDownloadFile('${SCRATCH}/tst-txsclient-uploaded.bin', strDwnFile)
|
---|
196 | print('%s: GET FILE(${SCRATCH}/tst-txsclient-uploaded.bin, tst-txsclient-downloaded.txt) -> %s'
|
---|
197 | % (boolRes(rc), rc));
|
---|
198 |
|
---|
199 | try:
|
---|
200 | oLocalFile = utils.openNoInherit(strDwnFile, "rb");
|
---|
201 | abDwnFile = oLocalFile.read();
|
---|
202 | oLocalFile.close();
|
---|
203 | if abRandFile == abDwnFile:
|
---|
204 | print '%s: downloaded file matches the uploaded file' % (boolRes(True),);
|
---|
205 | else:
|
---|
206 | print '%s: downloaded file does not match the uploaded file' % (boolRes(False),);
|
---|
207 | print 'abRandFile=%s' % (abRandFile,);
|
---|
208 | print 'abDwnFile =%s' % (abRandFile,);
|
---|
209 | except:
|
---|
210 | print '%s: reading downloaded file (%s) failed....' % (boolRes(False), strDwnFile);
|
---|
211 |
|
---|
212 | rc = oSession.syncRmFile(u'${SCRATCH}/tst-txsclient-uploaded.bin');
|
---|
213 | print '%s: RMFILE(${SCRATCH}/tst-txsclient-uploaded.bin) -> %s' % (boolRes(rc), rc);
|
---|
214 |
|
---|
215 | try: os.remove(strUpFile);
|
---|
216 | except: pass;
|
---|
217 | try: os.remove(strDwnFile);
|
---|
218 | except: pass;
|
---|
219 |
|
---|
220 | # Execute some simple thing, if available.
|
---|
221 | # Intentionally skip this test if file is not available due to
|
---|
222 | # another inserted CD-ROM (e.g. not TestSuite.iso).
|
---|
223 | sProg = '${CDROM}/${OS/ARCH}/NetPerf${EXESUFF}';
|
---|
224 | rc = oSession.syncIsFile(sProg, 30 * 1000, True);
|
---|
225 | if rc is True:
|
---|
226 | rc = oSession.syncExecEx(sProg, (sProg, '--help'));
|
---|
227 | print '%s: EXEC(%s ${SCRATCH}) -> %s' % (boolRes(rc), sProg, rc);
|
---|
228 |
|
---|
229 | rc = oSession.syncExecEx(sProg, (sProg, 'there', 'is no such', 'parameter'), \
|
---|
230 | oStdOut='${SCRATCH}/stdout', \
|
---|
231 | oStdErr='${SCRATCH}/stderr');
|
---|
232 | print('%s: EXEC(%s there is not such parameter > ${SCRATCH}/stdout 2> ${SCRATCH}/stderr) -> %s'
|
---|
233 | % (boolRes(rc, False), sProg, rc));
|
---|
234 |
|
---|
235 | rc = oSession.syncDownloadString('${SCRATCH}/stdout');
|
---|
236 | print 'INFO: GET FILE(${SCRATCH}/stdout) -> "%s"' % (rc);
|
---|
237 | rc = oSession.syncDownloadString('${SCRATCH}/stderr');
|
---|
238 | print 'INFO: GET FILE(${SCRATCH}/stderr) -> "%s"' % (rc);
|
---|
239 |
|
---|
240 | print 'TESTING: syncExec...'
|
---|
241 | rc = oSession.syncExec(sProg, (sProg, '--version'));
|
---|
242 | print '%s: EXEC(%s --version) -> %s' % (boolRes(rc), sProg, rc);
|
---|
243 |
|
---|
244 | print 'TESTING: syncExec...'
|
---|
245 | rc = oSession.syncExec(sProg, (sProg, '--help'));
|
---|
246 | print '%s: EXEC(%s --help) -> %s' % (boolRes(rc), sProg, rc);
|
---|
247 |
|
---|
248 | #print 'TESTING: syncExec sleep 30...'
|
---|
249 | #rc = oSession.syncExec('/usr/bin/sleep', ('/usr/bin/sleep', '30'));
|
---|
250 | #print '%s: EXEC(/bin/sleep 30) -> %s' % (boolRes(rc), rc);
|
---|
251 | else:
|
---|
252 | print 'SKIP: Execution of %s skipped, does not exist on CD-ROM' % (sProg,);
|
---|
253 |
|
---|
254 | # Execute a non-existing file on CD-ROM.
|
---|
255 | sProg = '${CDROM}/${OS/ARCH}/NonExisting${EXESUFF}';
|
---|
256 | rc = oSession.syncExecEx(sProg, (sProg,), oStdIn = '/dev/null', oStdOut = '/dev/null', \
|
---|
257 | oStdErr = '/dev/null', oTestPipe = '/dev/null', \
|
---|
258 | sAsUser = '', cMsTimeout = 3600000, fIgnoreErrors = True);
|
---|
259 | if rc is None:
|
---|
260 | rc = True;
|
---|
261 | else:
|
---|
262 | reporter.error('Unexpected value \"%s\" while executing non-existent file "%s"' % (rc, sProg));
|
---|
263 | print '%s: EXEC(%s ${SCRATCH}) -> %s' % (boolRes(rc), sProg, rc);
|
---|
264 |
|
---|
265 | # Done
|
---|
266 | rc = oSession.syncDisconnect();
|
---|
267 | print '%s: disconnect() -> %s' % (boolRes(rc), rc);
|
---|
268 |
|
---|
269 | elif fReboot:
|
---|
270 | print 'TESTING: syncReboot...'
|
---|
271 | rc = oSession.syncReboot();
|
---|
272 | print '%s: REBOOT() -> %s' % (boolRes(rc), rc);
|
---|
273 |
|
---|
274 | if g_cFailures != 0:
|
---|
275 | print 'tst-txsclient.py: %u out of %u test failed' % (g_cFailures, g_cTests);
|
---|
276 | return 1;
|
---|
277 | print 'tst-txsclient.py: all %u tests passed!' % (g_cTests);
|
---|
278 | return 0;
|
---|
279 |
|
---|
280 |
|
---|
281 | if __name__ == '__main__':
|
---|
282 | reporter.incVerbosity();
|
---|
283 | reporter.incVerbosity();
|
---|
284 | reporter.incVerbosity();
|
---|
285 | reporter.incVerbosity();
|
---|
286 | sys.exit(main(sys.argv));
|
---|
287 |
|
---|