import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertTrue;
import static org.junit.Assert.fail;
+
import com.google.common.collect.Lists;
import com.google.common.util.concurrent.Uninterruptibles;
import java.util.Collections;
reset(expChangeEventCount);
}
- public void reset(int expChangeEventCount) {
- changeLatch = new CountDownLatch(expChangeEventCount);
- this.expChangeEventCount = expChangeEventCount;
+ public void reset(int newExpChangeEventCount) {
+ changeLatch = new CountDownLatch(newExpChangeEventCount);
+ this.expChangeEventCount = newExpChangeEventCount;
changeList.clear();
}
public void waitForChangeEvents(YangInstanceIdentifier... expPaths) {
boolean done = Uninterruptibles.awaitUninterruptibly(changeLatch, 5, TimeUnit.SECONDS);
- if(!done) {
+ if (!done) {
fail(String.format("Missing change notifications. Expected: %d. Actual: %d",
- expChangeEventCount, (expChangeEventCount - changeLatch.getCount())));
+ expChangeEventCount, expChangeEventCount - changeLatch.getCount()));
}
- for(int i = 0; i < expPaths.length; i++) {
+ for (int i = 0; i < expPaths.length; i++) {
Map<YangInstanceIdentifier, NormalizedNode<?, ?>> createdData = changeList.get(i).getCreatedData();
- assertTrue(String.format("Change %d does not contain %s. Actual: %s", (i+1), expPaths[i], createdData),
+ assertTrue(String.format("Change %d does not contain %s. Actual: %s", i + 1, expPaths[i], createdData),
createdData.containsKey(expPaths[i]));
}
}
- public NormalizedNode<?, ?> getCreatedData(int i, YangInstanceIdentifier path) {
- return changeList.get(i).getCreatedData().get(path);
+ public NormalizedNode<?, ?> getCreatedData(int num, YangInstanceIdentifier path) {
+ return changeList.get(num).getCreatedData().get(path);
}
- public void verifyCreatedData(int i, YangInstanceIdentifier path) {
- Map<YangInstanceIdentifier, NormalizedNode<?, ?>> createdData = changeList.get(i).getCreatedData();
+ public void verifyCreatedData(int num, YangInstanceIdentifier path) {
+ Map<YangInstanceIdentifier, NormalizedNode<?, ?>> createdData = changeList.get(num).getCreatedData();
assertTrue(path + " not present in " + createdData.keySet(), createdData.get(path) != null);
}
assertEquals(assertMsg, expChangeEventCount, changeList.size());
}
- public void verifyNoCreatedData(int i, YangInstanceIdentifier path) {
- Map<YangInstanceIdentifier, NormalizedNode<?, ?>> createdData = changeList.get(i).getCreatedData();
+ public void verifyNoCreatedData(int num, YangInstanceIdentifier path) {
+ Map<YangInstanceIdentifier, NormalizedNode<?, ?>> createdData = changeList.get(num).getCreatedData();
assertTrue("Unexpected " + path + " present in createdData", createdData.get(path) == null);
}
}