From 37e3081b2f24b95c41a8bb156f281e4a59336d13 Mon Sep 17 00:00:00 2001 From: eugenevinitsky Date: Fri, 8 Jun 2018 20:21:58 -0700 Subject: [PATCH] moved port method --- flow/envs/base_env.py | 3 +++ flow/utils/rllib.py | 4 ---- 2 files changed, 3 insertions(+), 4 deletions(-) diff --git a/flow/envs/base_env.py b/flow/envs/base_env.py index 2c9a8982..7842ede1 100755 --- a/flow/envs/base_env.py +++ b/flow/envs/base_env.py @@ -71,6 +71,9 @@ def __init__(self, env_params, sumo_params, scenario): self.env_params = env_params self.scenario = scenario self.sumo_params = sumo_params + time_stamp = ''.join(str(time.time()).split('.')) + time.sleep(8.0 * int(time_stamp[-6:]) / 1e6) + self.sumo_params.port = sumolib.miscutils.getFreeSocketPort() self.vehicles = scenario.vehicles self.traffic_lights = scenario.traffic_lights # time_counter: number of steps taken since the start of a rollout diff --git a/flow/utils/rllib.py b/flow/utils/rllib.py index aae4e0e0..7c4477b1 100644 --- a/flow/utils/rllib.py +++ b/flow/utils/rllib.py @@ -95,10 +95,6 @@ def create_env(*_): ) sumo_params = deepcopy(params['sumo']) - if sumo_params.port is None: - time_stamp = ''.join(str(time.time()).split('.')) - time.sleep(2.0 * int(time_stamp[-6:]) / 1e6) - sumo_params.port = sumolib.miscutils.getFreeSocketPort() register( id=env_name,