|
|
|
|
|
|
atexit.register(self._close) |
|
|
|
self.port = base_port + worker_id |
|
|
|
self._buffer_size = 12000 |
|
|
|
self._version_ = "API-5" |
|
|
|
self._version_ = "API-6" |
|
|
|
self._loaded = False # If true, this means the environment was successfully loaded |
|
|
|
self.proc1 = None # The process that is started. If None, no process was started |
|
|
|
self.communicator = self.get_communicator(worker_id, base_port) |
|
|
|