adding device specific counters for meter ids in
the meter service.
Change-Id: I38d38a0a85024927f5a74013b2b4d9efa9b32d22
diff --git a/incubator/net/src/test/java/org/onosproject/incubator/net/meter/impl/MeterManagerTest.java b/incubator/net/src/test/java/org/onosproject/incubator/net/meter/impl/MeterManagerTest.java
index e0c0c86..76caebc 100644
--- a/incubator/net/src/test/java/org/onosproject/incubator/net/meter/impl/MeterManagerTest.java
+++ b/incubator/net/src/test/java/org/onosproject/incubator/net/meter/impl/MeterManagerTest.java
@@ -130,7 +130,7 @@
m2 = DefaultMeter.builder()
.forDevice(did("2"))
.fromApp(APP_ID)
- .withId(MeterId.meterId(2))
+ .withId(MeterId.meterId(1))
.withUnit(Meter.Unit.KB_PER_SEC)
.withBands(Collections.singletonList(band))
.build();
@@ -167,7 +167,7 @@
assertTrue("The meter was not added", manager.getAllMeters().size() == 1);
- assertThat(manager.getMeter(MeterId.meterId(1)), is(m1));
+ assertThat(manager.getMeter(did("1"), MeterId.meterId(1)), is(m1));
}
@Test
@@ -175,7 +175,7 @@
manager.submit(m1Request.add());
manager.withdraw(m1Request.remove(), m1.id());
- assertThat(manager.getMeter(MeterId.meterId(1)).state(),
+ assertThat(manager.getMeter(did("1"), MeterId.meterId(1)).state(),
is(MeterState.PENDING_REMOVE));
providerService.pushMeterMetrics(m1.deviceId(), Collections.emptyList());
@@ -184,7 +184,16 @@
}
+ @Test
+ public void testMultipleDevice() {
+ manager.submit(m1Request.add());
+ manager.submit(m2Request.add());
+ assertTrue("The meters were not added", manager.getAllMeters().size() == 2);
+
+ assertThat(manager.getMeter(did("1"), MeterId.meterId(1)), is(m1));
+ assertThat(manager.getMeter(did("2"), MeterId.meterId(1)), is(m2));
+ }
public class TestApplicationId extends DefaultApplicationId {
public TestApplicationId(int id, String name) {