Changeset 84596 in webkit
- Timestamp:
- Apr 21, 2011 8:29:59 PM (13 years ago)
- Location:
- trunk/Tools
- Files:
-
- 3 edited
- 2 moved
Legend:
- Unmodified
- Added
- Removed
-
trunk/Tools/ChangeLog
r84595 r84596 1 2011-04-21 Dirk Pranke <dpranke@chromium.org> 2 3 Reviewed by Eric Seidel. 4 5 new-run-webkit-tests: obsolete old code, part 5: rename message_broker2 to message_broker 6 https://bugs.webkit.org/show_bug.cgi?id=58758 7 8 Since worker_mixin is now only used by worker, there's no point 9 in having it split across two files. 10 11 * Scripts/webkitpy/layout_tests/layout_package/manager_worker_broker.py: 12 * Scripts/webkitpy/layout_tests/layout_package/manager_worker_broker_unittest.py: 13 * Scripts/webkitpy/layout_tests/layout_package/message_broker.py: Added 14 * Scripts/webkitpy/layout_tests/layout_package/message_broker2.py: Removed. 15 * Scripts/webkitpy/layout_tests/layout_package/message_broker_unittest.py: * Added 16 * Scripts/webkitpy/layout_tests/layout_package/message_broker2_unittest.py: Removed. 17 1 18 2011-04-21 Dirk Pranke <dpranke@chromium.org> 2 19 -
trunk/Tools/Scripts/webkitpy/layout_tests/layout_package/manager_worker_broker.py
r83760 r84596 31 31 This module implements a message broker that connects the manager 32 32 (TestRunner2) to the workers: it provides a messaging abstraction and 33 message loops (building on top of message_broker 2), and handles starting33 message loops (building on top of message_broker), and handles starting 34 34 workers by launching threads and/or processes depending on the 35 35 requested configuration. … … 63 63 from webkitpy.common.system import stack_utils 64 64 from webkitpy.layout_tests import port 65 from webkitpy.layout_tests.layout_package import message_broker 265 from webkitpy.layout_tests.layout_package import message_broker 66 66 67 67 … … 92 92 port - handle to layout_tests/port object for port-specific stuff 93 93 options - optparse argument for command-line options 94 client - message_broker 2.BrokerClient implementation to dispatch94 client - message_broker.BrokerClient implementation to dispatch 95 95 replies to. 96 96 worker_class - type of workers to create. This class must implement … … 114 114 worker_model) 115 115 116 broker = message_broker 2.Broker(options, queue_class)116 broker = message_broker.Broker(options, queue_class) 117 117 return manager_class(broker, port, options, client, worker_class) 118 118 119 119 120 class AbstractWorker(message_broker 2.BrokerClient):120 class AbstractWorker(message_broker.BrokerClient): 121 121 def __init__(self, broker_connection, worker_number, options): 122 122 """The constructor should be used to do any simple initialization … … 146 146 147 147 148 class _ManagerConnection(message_broker 2.BrokerConnection):148 class _ManagerConnection(message_broker.BrokerConnection): 149 149 def __init__(self, broker, options, client, worker_class): 150 150 """Base initialization for all Manager objects. 151 151 152 152 Args: 153 broker: handle to the message_broker 2object153 broker: handle to the message_broker object 154 154 options: command line options object 155 155 client: callback object (the caller) 156 156 worker_class: class object to use to create workers. 157 157 """ 158 message_broker 2.BrokerConnection.__init__(self, broker, client,158 message_broker.BrokerConnection.__init__(self, broker, client, 159 159 MANAGER_TOPIC, ANY_WORKER_TOPIC) 160 160 self._options = options … … 211 211 212 212 213 class _WorkerConnection(message_broker 2.BrokerConnection):213 class _WorkerConnection(message_broker.BrokerConnection): 214 214 def __init__(self, broker, worker_class, worker_number, options): 215 215 self._client = worker_class(self, worker_number, options) 216 216 self.name = self._client.name() 217 message_broker 2.BrokerConnection.__init__(self, broker, self._client,218 217 message_broker.BrokerConnection.__init__(self, broker, self._client, 218 ANY_WORKER_TOPIC, MANAGER_TOPIC) 219 219 220 220 def cancel(self): -
trunk/Tools/Scripts/webkitpy/layout_tests/layout_package/manager_worker_broker_unittest.py
r83760 r84596 42 42 from webkitpy.layout_tests import port 43 43 from webkitpy.layout_tests.layout_package import manager_worker_broker 44 from webkitpy.layout_tests.layout_package import message_broker 244 from webkitpy.layout_tests.layout_package import message_broker 45 45 from webkitpy.layout_tests.layout_package import printing 46 46 -
trunk/Tools/Scripts/webkitpy/layout_tests/layout_package/message_broker_unittest.py
r84595 r84596 29 29 import unittest 30 30 31 from webkitpy.layout_tests.layout_package import message_broker 231 from webkitpy.layout_tests.layout_package import message_broker 32 32 33 33 # This file exists to test routines that aren't necessarily covered elsewhere; 34 # most of the testing of message_broker 2will be covered under the tests in34 # most of the testing of message_broker will be covered under the tests in 35 35 # the manager_worker_broker module. 36 36 … … 38 38 class MessageTest(unittest.TestCase): 39 39 def test__no_body(self): 40 msg = message_broker 2._Message('src', 'topic_name', 'message_name', None)40 msg = message_broker._Message('src', 'topic_name', 'message_name', None) 41 41 self.assertTrue(repr(msg)) 42 42 s = msg.dumps() 43 new_msg = message_broker 2._Message.loads(s)43 new_msg = message_broker._Message.loads(s) 44 44 self.assertEqual(new_msg.name, 'message_name') 45 45 self.assertEqual(new_msg.args, None) … … 48 48 49 49 def test__body(self): 50 msg = message_broker 2._Message('src', 'topic_name', 'message_name',50 msg = message_broker._Message('src', 'topic_name', 'message_name', 51 51 ('body', 0)) 52 52 self.assertTrue(repr(msg)) 53 53 s = msg.dumps() 54 new_msg = message_broker 2._Message.loads(s)54 new_msg = message_broker._Message.loads(s) 55 55 self.assertEqual(new_msg.name, 'message_name') 56 56 self.assertEqual(new_msg.args, ('body', 0)) … … 67 67 def test_brokerclient_is_abstract(self): 68 68 # Test that we can't create an instance directly. 69 self.assertRaises(NotImplementedError, message_broker 2.BrokerClient)69 self.assertRaises(NotImplementedError, message_broker.BrokerClient) 70 70 71 class TestClient(message_broker 2.BrokerClient):71 class TestClient(message_broker.BrokerClient): 72 72 def __init__(self): 73 73 pass
Note: See TracChangeset
for help on using the changeset viewer.