| | |
| | | |
| | | assertEquals(101, item.getTargetStationId()); |
| | | assertEquals("OUT", item.getDirection()); |
| | | assertEquals(Arrays.asList(102, 103), item.getUpstreamStationIds()); |
| | | assertEquals(Arrays.asList(102, 103), item.getDownstreamStationIds()); |
| | | assertEquals(Arrays.asList(102, 103), item.getAdjacentStationIds()); |
| | | assertEquals(Arrays.asList(), item.getUpstreamStationIds()); |
| | | assertEquals(Arrays.asList(), item.getDownstreamStationIds()); |
| | | assertEquals(Arrays.asList(101, 102, 103), item.getFlowStationIds()); |
| | | } |
| | | |
| | | @Test |
| | | void undirectedGraphOnlyPopulatesAdjacentAndFlowStations() { |
| | | FlowTopologySnapshotServiceImpl service = new FlowTopologySnapshotServiceImpl(); |
| | | StationFlowCapacity capacity = capacity(201, "IN", 4); |
| | | Map<Integer, List<Integer>> adjacency = new LinkedHashMap<>(); |
| | | adjacency.put(201, Arrays.asList(203, 202)); |
| | | |
| | | AutoTuneFlowTopologyItem item = service.buildTopologyItem( |
| | | capacity, |
| | | adjacency, |
| | | Arrays.asList(runtime(202, 1, 1, 0), runtime(203, 1, 0, 8001)) |
| | | ); |
| | | |
| | | assertEquals(Arrays.asList(202, 203), item.getAdjacentStationIds()); |
| | | assertEquals(Arrays.asList(), item.getUpstreamStationIds()); |
| | | assertEquals(Arrays.asList(), item.getDownstreamStationIds()); |
| | | assertEquals(Arrays.asList(201, 202, 203), item.getFlowStationIds()); |
| | | assertEquals(2, item.getOccupiedCount()); |
| | | } |
| | | |
| | | @Test |
| | | void calculateRuntimeCountsUsesOnlyAutoingLoadingAndTaskNo() { |
| | | FlowTopologySnapshotServiceImpl service = new FlowTopologySnapshotServiceImpl(); |
| | | List<AutoTuneStationRuntimeItem> runtimeItems = Arrays.asList( |