public void writeConfigCommandReattemptTest() {
doThrow(new IllegalStateException()).when(command).execute(rwTx);
- final boolean result = GbpNetconfTransaction.write(dataBroker, command, (byte)5);
+ final boolean result = GbpNetconfTransaction.netconfSyncedWrite(dataBroker, command, (byte) 5);
verify(dataBroker, times(6)).newReadWriteTransaction();
assertFalse(result);
}
doNothing().when(command).execute(rwTx);
when(future.get()).thenReturn(null);
- final boolean result = GbpNetconfTransaction.write(dataBroker, command, (byte)5);
+ final boolean result = GbpNetconfTransaction.netconfSyncedWrite(dataBroker, command, (byte)5);
verify(dataBroker, times(1)).newReadWriteTransaction();
assertTrue(result);
}
public void writeDataReattemptTest() {
doThrow(new IllegalStateException()).when(rwTx).put(LogicalDatastoreType.CONFIGURATION, nodeIid, node, true);
- final boolean result = GbpNetconfTransaction.write(dataBroker, nodeIid, node, (byte)5);
+ final boolean result = GbpNetconfTransaction.netconfSyncedWrite(dataBroker, nodeIid, node, (byte) 5);
verify(dataBroker, times(6)).newReadWriteTransaction();
assertFalse(result);
}
doNothing().when(rwTx).put(LogicalDatastoreType.CONFIGURATION, nodeIid, node, true);
when(future.get()).thenReturn(null);
- final boolean result = GbpNetconfTransaction.write(dataBroker, nodeIid, node, (byte)5);
+ final boolean result = GbpNetconfTransaction.netconfSyncedWrite(dataBroker, nodeIid, node, (byte) 5);
verify(dataBroker, times(1)).newReadWriteTransaction();
assertTrue(result);
}
when(futureInterface.get()).thenReturn(Optional.absent());
doThrow(new IllegalStateException()).when(command).execute(rwTx);
- final boolean result = GbpNetconfTransaction.deleteIfExists(dataBroker, command, (byte)5);
+ final boolean result = GbpNetconfTransaction.netconfSyncedDelete(dataBroker, command, (byte)5);
verify(dataBroker, times(1)).newReadOnlyTransaction();
assertTrue(result);
}
.setKey(new InterfaceKey(INTERFACE_KEY)).build()));
doThrow(new IllegalStateException()).when(command).execute(rwTx);
- final boolean result = GbpNetconfTransaction.deleteIfExists(dataBroker, command, (byte)5);
+ final boolean result = GbpNetconfTransaction.netconfSyncedDelete(dataBroker, command, (byte)5);
verify(dataBroker, times(6)).newReadWriteTransaction();
assertFalse(result);
}
doNothing().when(command).execute(rwTx);
when(future.get()).thenReturn(null);
- final boolean result = GbpNetconfTransaction.deleteIfExists(dataBroker, command, (byte)5);
+ final boolean result = GbpNetconfTransaction.netconfSyncedDelete(dataBroker, command, (byte)5);
verify(dataBroker, times(1)).newReadWriteTransaction();
assertTrue(result);
}
when(futureNode.get()).thenReturn(Optional.absent());
doThrow(new IllegalStateException()).when(command).execute(rwTx);
- final boolean result = GbpNetconfTransaction.deleteIfExists(dataBroker, nodeIid, (byte)5);
+ final boolean result = GbpNetconfTransaction.netconfSyncedDelete(dataBroker, nodeIid, (byte)5);
verify(dataBroker, times(1)).newReadOnlyTransaction();
assertTrue(result);
}
.setKey(new NodeKey(new NodeId(NODE_ID))).build()));
doThrow(new IllegalStateException()).when(rwTx).delete(LogicalDatastoreType.CONFIGURATION, nodeIid);
- final boolean result = GbpNetconfTransaction.deleteIfExists(dataBroker, nodeIid, (byte)5);
+ final boolean result = GbpNetconfTransaction.netconfSyncedDelete(dataBroker, nodeIid, (byte)5);
verify(dataBroker, times(6)).newReadWriteTransaction();
assertFalse(result);
}
doNothing().when(rwTx).delete(LogicalDatastoreType.CONFIGURATION, nodeIid);
when(future.get()).thenReturn(null);
- final boolean result = GbpNetconfTransaction.deleteIfExists(dataBroker, nodeIid, (byte)5);
+ final boolean result = GbpNetconfTransaction.netconfSyncedDelete(dataBroker, nodeIid, (byte)5);
verify(dataBroker, times(1)).newReadWriteTransaction();
assertTrue(result);
}
-}
\ No newline at end of file
+}