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 |