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 from . import context | |
30 from . import testcase | |
31 | |
32 class WorkPacket(object): | |
33 def __init__(self, peer=None, context=None, tests=None, binaries=None, | |
34 base_revision=None, patch=None, pubkey=None): | |
35 self.peer = peer | |
36 self.context = context | |
37 self.tests = tests | |
38 self.binaries = binaries | |
39 self.base_revision = base_revision | |
40 self.patch = patch | |
41 self.pubkey_fingerprint = pubkey | |
42 | |
43 def Pack(self, binaries_dict): | |
44 """ | |
45 Creates a JSON serializable object containing the data of this | |
46 work packet. | |
47 """ | |
48 need_libv8 = False | |
49 binaries = [] | |
50 for shell in self.peer.shells: | |
51 prefetched_binary = binaries_dict[shell] | |
52 binaries.append({"name": shell, | |
53 "blob": prefetched_binary[0], | |
54 "sign": prefetched_binary[1]}) | |
55 if prefetched_binary[2]: | |
56 need_libv8 = True | |
57 if need_libv8: | |
58 libv8 = binaries_dict["libv8.so"] | |
59 binaries.append({"name": "libv8.so", | |
60 "blob": libv8[0], | |
61 "sign": libv8[1]}) | |
62 tests = [] | |
63 test_map = {} | |
64 for t in self.peer.tests: | |
65 test_map[t.id] = t | |
66 tests.append(t.PackTask()) | |
67 result = { | |
68 "binaries": binaries, | |
69 "pubkey": self.pubkey_fingerprint, | |
70 "context": self.context.Pack(), | |
71 "base_revision": self.base_revision, | |
72 "patch": self.patch, | |
73 "tests": tests | |
74 } | |
75 return result, test_map | |
76 | |
77 @staticmethod | |
78 def Unpack(packed): | |
79 """ | |
80 Creates a WorkPacket object from the given packed representation. | |
81 """ | |
82 binaries = packed["binaries"] | |
83 pubkey_fingerprint = packed["pubkey"] | |
84 ctx = context.Context.Unpack(packed["context"]) | |
85 base_revision = packed["base_revision"] | |
86 patch = packed["patch"] | |
87 tests = [ testcase.TestCase.UnpackTask(t) for t in packed["tests"] ] | |
88 return WorkPacket(context=ctx, tests=tests, binaries=binaries, | |
89 base_revision=base_revision, patch=patch, | |
90 pubkey=pubkey_fingerprint) | |
OLD | NEW |