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
|
"""
Utility for submitting files to a web server over HTTP.
"""
import plistlib
import sys
import urllib
import urllib2
import contextlib
import json
import lnt.server.instance
from lnt.util import ImportData
# FIXME: I used to maintain this file in such a way that it could be used
# separate from LNT to do submission. This could be useful for adapting an
# older system to report to LNT, for example. It might be nice to factor the
# simplified submit code into a separate utility.
def _show_json_error(reply):
try:
error = json.loads(reply)
except ValueError:
print "error: {}".format(reply)
return
sys.stderr.write("error: lnt server: {}\n".format(error.get('error')))
message = error.get('message', '')
if message:
sys.stderr.write(message + '\n')
def submitFileToServer(url, file, select_machine, merge_run):
with open(file, 'rb') as f:
values = {
'input_data': f.read(),
'commit': "1", # compatibility with old servers.
'select_machine': select_machine,
'merge': merge_run,
}
headers = {'Accept': 'application/json'}
data = urllib.urlencode(values)
try:
response = urllib2.urlopen(urllib2.Request(url, data, headers=headers))
except urllib2.HTTPError as e:
_show_json_error(e.read())
return
result_data = response.read()
# The result is expected to be a JSON object.
try:
return json.loads(result_data)
except:
import traceback
print "Unable to load result, not a valid JSON object."
print
print "Traceback:"
traceback.print_exc()
print
print "Result:"
print "error:", result_data
return
return reply
def submitFileToInstance(path, file, select_machine='match',
merge_run='replace'):
# Otherwise, assume it is a local url and submit to the default database
# in the instance.
instance = lnt.server.instance.Instance.frompath(path)
config = instance.config
db_name = 'default'
with contextlib.closing(config.get_database(db_name)) as db:
if db is None:
raise ValueError("no default database in instance: %r" % (path,))
session = db.make_session()
return lnt.util.ImportData.import_and_report(
config, db_name, db, session, file, format='<auto>', ts_name='nts',
select_machine=select_machine, merge_run=merge_run)
def submitFile(url, file, verbose, select_machine='match',
merge_run='replace'):
# If this is a real url, submit it using urllib.
if '://' in url:
result = submitFileToServer(url, file, select_machine, merge_run)
else:
result = submitFileToInstance(url, file, select_machine, merge_run)
return result
def submitFiles(url, files, verbose, select_machine='match',
merge_run='replace'):
results = []
for file in files:
result = submitFile(url, file, verbose, select_machine=select_machine,
merge_run=merge_run)
if result:
results.append(result)
return results
|
