| # Copyright 2012 the V8 project authors. All rights reserved. | |
| # Redistribution and use in source and binary forms, with or without | |
| # modification, are permitted provided that the following conditions are | |
| # met: | |
| # | |
| # * Redistributions of source code must retain the above copyright | |
| # notice, this list of conditions and the following disclaimer. | |
| # * Redistributions in binary form must reproduce the above | |
| # copyright notice, this list of conditions and the following | |
| # disclaimer in the documentation and/or other materials provided | |
| # with the distribution. | |
| # * Neither the name of Google Inc. nor the names of its | |
| # contributors may be used to endorse or promote products derived | |
| # from this software without specific prior written permission. | |
| # | |
| # THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS | |
| # "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT | |
| # LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR | |
| # A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT | |
| # OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, | |
| # SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT | |
| # LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, | |
| # DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY | |
| # THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT | |
| # (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE | |
| # OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | |
| from . import context | |
| from . import testcase | |
| class WorkPacket(object): | |
| def __init__(self, peer=None, context=None, tests=None, binaries=None, | |
| base_revision=None, patch=None, pubkey=None): | |
| self.peer = peer | |
| self.context = context | |
| self.tests = tests | |
| self.binaries = binaries | |
| self.base_revision = base_revision | |
| self.patch = patch | |
| self.pubkey_fingerprint = pubkey | |
| def Pack(self, binaries_dict): | |
| """ | |
| Creates a JSON serializable object containing the data of this | |
| work packet. | |
| """ | |
| need_libv8 = False | |
| binaries = [] | |
| for shell in self.peer.shells: | |
| prefetched_binary = binaries_dict[shell] | |
| binaries.append({"name": shell, | |
| "blob": prefetched_binary[0], | |
| "sign": prefetched_binary[1]}) | |
| if prefetched_binary[2]: | |
| need_libv8 = True | |
| if need_libv8: | |
| libv8 = binaries_dict["libv8.so"] | |
| binaries.append({"name": "libv8.so", | |
| "blob": libv8[0], | |
| "sign": libv8[1]}) | |
| tests = [] | |
| test_map = {} | |
| for t in self.peer.tests: | |
| test_map[t.id] = t | |
| tests.append(t.PackTask()) | |
| result = { | |
| "binaries": binaries, | |
| "pubkey": self.pubkey_fingerprint, | |
| "context": self.context.Pack(), | |
| "base_revision": self.base_revision, | |
| "patch": self.patch, | |
| "tests": tests | |
| } | |
| return result, test_map | |
| @staticmethod | |
| def Unpack(packed): | |
| """ | |
| Creates a WorkPacket object from the given packed representation. | |
| """ | |
| binaries = packed["binaries"] | |
| pubkey_fingerprint = packed["pubkey"] | |
| ctx = context.Context.Unpack(packed["context"]) | |
| base_revision = packed["base_revision"] | |
| patch = packed["patch"] | |
| tests = [ testcase.TestCase.UnpackTask(t) for t in packed["tests"] ] | |
| return WorkPacket(context=ctx, tests=tests, binaries=binaries, | |
| base_revision=base_revision, patch=patch, | |
| pubkey=pubkey_fingerprint) |