4 class MasterCommunicator(_Communicator):
7 def __init__(self, master_addr, lock):
8 _Communicator.__init__(self)
9 self._master_addr = master_addr
10 self._connect_to_master()
13 def _connect_to_master(self):
14 host, port, identifier = self._master_addr
15 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM)
16 s.settimeout(self.connect_timeout)
17 s.connect((host, port))
26 _Communicator._send(self, obj)