OLD | NEW |
| (Empty) |
1 # Copyright 2012 the V8 project authors. All rights reserved. | |
2 # Redistribution and use in source and binary forms, with or without | |
3 # modification, are permitted provided that the following conditions are | |
4 # met: | |
5 # | |
6 # * Redistributions of source code must retain the above copyright | |
7 # notice, this list of conditions and the following disclaimer. | |
8 # * Redistributions in binary form must reproduce the above | |
9 # copyright notice, this list of conditions and the following | |
10 # disclaimer in the documentation and/or other materials provided | |
11 # with the distribution. | |
12 # * Neither the name of Google Inc. nor the names of its | |
13 # contributors may be used to endorse or promote products derived | |
14 # from this software without specific prior written permission. | |
15 # | |
16 # THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | |
17 # "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | |
18 # LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR | |
19 # A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT | |
20 # OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | |
21 # SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT | |
22 # LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | |
23 # DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | |
24 # THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | |
25 # (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | |
26 # OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | |
27 | |
28 | |
29 import multiprocessing | |
30 import os | |
31 import Queue | |
32 import threading | |
33 import time | |
34 | |
35 from ..local import execution | |
36 from ..local import progress | |
37 from ..local import testsuite | |
38 from ..local import utils | |
39 from ..server import compression | |
40 | |
41 | |
42 class EndpointProgress(progress.ProgressIndicator): | |
43 def __init__(self, sock, server, ctx): | |
44 super(EndpointProgress, self).__init__() | |
45 self.sock = sock | |
46 self.server = server | |
47 self.context = ctx | |
48 self.results_queue = [] # Accessors must synchronize themselves. | |
49 self.sender_lock = threading.Lock() | |
50 self.senderthread = threading.Thread(target=self._SenderThread) | |
51 self.senderthread.start() | |
52 | |
53 def HasRun(self, test): | |
54 # The runners that call this have a lock anyway, so this is safe. | |
55 self.results_queue.append(test) | |
56 | |
57 def _SenderThread(self): | |
58 keep_running = True | |
59 tests = [] | |
60 self.sender_lock.acquire() | |
61 while keep_running: | |
62 time.sleep(0.1) | |
63 t1 = time.time() | |
64 # This should be "atomic enough" without locking :-) | |
65 # (We don't care which list any new elements get appended to, as long | |
66 # as we don't lose any and the last one comes last.) | |
67 current = self.results_queue | |
68 self.results_queue = [] | |
69 for c in current: | |
70 if c is None: | |
71 keep_running = False | |
72 else: | |
73 tests.append(c) | |
74 if keep_running and len(tests) < 1: | |
75 continue # Wait for more results. | |
76 if len(tests) < 1: break # We're done here. | |
77 result = [] | |
78 for t in tests: | |
79 result.append(t.PackResult()) | |
80 compression.Send(result, self.sock) | |
81 for t in tests: | |
82 self.server.CompareOwnPerf(t, self.context.arch, self.context.mode) | |
83 tests = [] | |
84 self.sender_lock.release() | |
85 | |
86 | |
87 def Execute(workspace, ctx, tests, sock, server): | |
88 suite_paths = utils.GetSuitePaths(os.path.join(workspace, "test")) | |
89 suites = [] | |
90 for root in suite_paths: | |
91 suite = testsuite.TestSuite.LoadTestSuite( | |
92 os.path.join(workspace, "test", root)) | |
93 if suite: | |
94 suites.append(suite) | |
95 | |
96 suites_dict = {} | |
97 for s in suites: | |
98 suites_dict[s.name] = s | |
99 s.tests = [] | |
100 for t in tests: | |
101 suite = suites_dict[t.suite] | |
102 t.suite = suite | |
103 suite.tests.append(t) | |
104 | |
105 suites = [ s for s in suites if len(s.tests) > 0 ] | |
106 for s in suites: | |
107 s.DownloadData() | |
108 | |
109 progress_indicator = EndpointProgress(sock, server, ctx) | |
110 runner = execution.Runner(suites, progress_indicator, ctx) | |
111 runner.Run(server.jobs) | |
112 progress_indicator.HasRun(None) # Sentinel to signal the end. | |
113 progress_indicator.sender_lock.acquire() # Released when sending is done. | |
114 progress_indicator.sender_lock.release() | |
OLD | NEW |