Spaces:
Running on Zero
Running on Zero
File size: 2,513 Bytes
f234112 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 75 76 77 78 79 80 81 82 83 84 85 86 87 88 89 90 91 92 93 94 95 96 97 98 99 100 101 102 103 104 | import traci
from integration.sumo_topology_adapter import SUMOTopologyAdapter
from integration.sumo_phase_adapter import SUMOPhaseAdapter
from integration.sumo_conflict_adapter import SUMOConflictAdapter
from integration.phase_generator import PhaseGenerator
SUMO_CMD = [
"sumo",
"-c",
"simulation/configs/corridor.sumocfg"
]
def print_generated_phases(junction_id, phases):
print()
print("=" * 70)
print(f"GENERATED PHASES: {junction_id}")
print("=" * 70)
print()
print(f"Total generated phases: {len(phases)}")
for index, phase in enumerate(phases):
print()
print(f"Phase {index}")
print(f" {phase}")
try:
traci.start(SUMO_CMD)
# ------------------------------------------------------------
# Create adapters
# ------------------------------------------------------------
topology_adapter = SUMOTopologyAdapter()
phase_adapter = SUMOPhaseAdapter()
conflict_adapter = SUMOConflictAdapter(
phase_adapter
)
# ------------------------------------------------------------
# Discover topology
# ------------------------------------------------------------
topologies = (
topology_adapter
.discover_all_junctions()
)
# ------------------------------------------------------------
# Test A0, B0 and C0
# ------------------------------------------------------------
for junction_id in ["A0", "B0", "C0"]:
topology = topologies[junction_id]
# --------------------------------------------------------
# Build conflict graph
# --------------------------------------------------------
conflict_graph = (
conflict_adapter
.build_conflict_graph(
junction_id,
topology,
topology_adapter.sumo_metadata
)
)
# --------------------------------------------------------
# Generate maximal phases
# --------------------------------------------------------
generator = PhaseGenerator(
conflict_graph
)
phases = (
generator
.generate_maximal_phases()
)
# --------------------------------------------------------
# Print results
# --------------------------------------------------------
print_generated_phases(
junction_id,
phases
)
finally:
traci.close() |