Code Review
/
lispflowmapping.git
/ blobdiff
commit
grep
author
committer
pickaxe
?
search:
re
summary
|
shortlog
|
log
|
commit
|
commitdiff
|
review
|
tree
raw
|
inline
| side by side
Create and switch to a concurrent version of LispSouthboundStats
[lispflowmapping.git]
/
mappingservice
/
southbound
/
src
/
test
/
java
/
org
/
opendaylight
/
lispflowmapping
/
southbound
/
LispSouthboundRpcTest.java
diff --git
a/mappingservice/southbound/src/test/java/org/opendaylight/lispflowmapping/southbound/LispSouthboundRpcTest.java
b/mappingservice/southbound/src/test/java/org/opendaylight/lispflowmapping/southbound/LispSouthboundRpcTest.java
index 976cb76d76ba2aba01eead417c936d5ac446f4ff..3f6213d4bc44415c2f7e9e92e7b5775bf69f425d 100644
(file)
--- a/
mappingservice/southbound/src/test/java/org/opendaylight/lispflowmapping/southbound/LispSouthboundRpcTest.java
+++ b/
mappingservice/southbound/src/test/java/org/opendaylight/lispflowmapping/southbound/LispSouthboundRpcTest.java
@@
-182,7
+182,7
@@
public class LispSouthboundRpcTest {
*/
@Test
public void getStatsTest() throws ExecutionException, InterruptedException {
*/
@Test
public void getStatsTest() throws ExecutionException, InterruptedException {
- final
LispSouthboundStats stats = new
LispSouthboundStats();
+ final
ConcurrentLispSouthboundStats stats = new Concurrent
LispSouthboundStats();
incrementAll(stats);
Mockito.when(lispSouthboundPlugin.getStats()).thenReturn(stats);
incrementAll(stats);
Mockito.when(lispSouthboundPlugin.getStats()).thenReturn(stats);
@@
-220,7
+220,7
@@
public class LispSouthboundRpcTest {
*/
@Test
public void resetStatsTest() throws ExecutionException, InterruptedException {
*/
@Test
public void resetStatsTest() throws ExecutionException, InterruptedException {
- final
LispSouthboundStats stats = new
LispSouthboundStats();
+ final
ConcurrentLispSouthboundStats stats = new Concurrent
LispSouthboundStats();
incrementAll(stats);
Mockito.when(lispSouthboundPlugin.getStats()).thenReturn(stats);
incrementAll(stats);
Mockito.when(lispSouthboundPlugin.getStats()).thenReturn(stats);
@@
-267,7
+267,7
@@
public class LispSouthboundRpcTest {
.setMappingRecordItem(Lists.newArrayList(getDefaultMappingRecordItem()));
}
.setMappingRecordItem(Lists.newArrayList(getDefaultMappingRecordItem()));
}
- private static void incrementAll(LispSouthboundStats stats) {
+ private static void incrementAll(
Concurrent
LispSouthboundStats stats) {
for (MessageType type : MessageType.values()) {
stats.incrementRx(type.getIntValue());
}
for (MessageType type : MessageType.values()) {
stats.incrementRx(type.getIntValue());
}