}
@Override
- public void onFailure(Throwable t) {
+ public void onFailure(Throwable throwable) {
LOG.error("Device transaction submit failed or submit took longer than {} {}!"
- + " Unlocking device.", timeout, timeUnit, t);
+ + " Unlocking device.", timeout, timeUnit, throwable);
afterClose();
}
}, scheduledExecutorService);
transactionManager.getDeviceTransaction(defaultDeviceId);
Assert.assertFalse(thirdDeviceTxFuture.isDone());
- Future<java.util.Optional<DeviceTransaction>> anotherDeviceTxFuture =
- transactionManager.getDeviceTransaction("another-id");
-
firstDeviceTx.put(defaultDatastore, defaultIid, defaultData);
Assert.assertFalse(secondDeviceTxFuture.isDone());
Assert.assertFalse(thirdDeviceTxFuture.isDone());
Assert.assertFalse(secondDeviceTxFuture.isDone());
Assert.assertFalse(thirdDeviceTxFuture.isDone());
+ Future<java.util.Optional<DeviceTransaction>> anotherDeviceTxFuture =
+ transactionManager.getDeviceTransaction("another-id");
Assert.assertTrue(anotherDeviceTxFuture.isDone());
anotherDeviceTxFuture.get().get().submit(defaultTimeout, defaultTimeUnit);
aend = new ServiceAEndBuilder(serviceReconfigureInput.getServiceAEnd()).build();
zend = new ServiceZEndBuilder(serviceReconfigureInput.getServiceZEnd()).build();
service.setServiceName(serviceReconfigureInput.getNewServiceName())
- .setAdministrativeState(State.OutOfService).setOperationalState(State.OutOfService)
- .setCommonId(serviceReconfigureInput.getCommonId())
- .setConnectionType(serviceReconfigureInput.getConnectionType())
- .setCustomer(serviceReconfigureInput.getCustomer())
- .setCustomerContact(serviceReconfigureInput.getCustomerContact())
- .setHardConstraints(serviceReconfigureInput.getHardConstraints())
- .setSoftConstraints(serviceReconfigureInput.getSoftConstraints())
- .setLifecycleState(LifecycleState.Planned).setServiceAEnd(aend).setServiceZEnd(zend)
- .setSdncRequestHeader(new SdncRequestHeaderBuilder()
- .setRequestId("reconfigure_" + serviceReconfigureInput.getNewServiceName())
- .setRpcAction(RpcActions.ServiceReconfigure)
- .build());
+ .setAdministrativeState(State.OutOfService).setOperationalState(State.OutOfService)
+ .setCommonId(serviceReconfigureInput.getCommonId())
+ .setConnectionType(serviceReconfigureInput.getConnectionType())
+ .setCustomer(serviceReconfigureInput.getCustomer())
+ .setCustomerContact(serviceReconfigureInput.getCustomerContact())
+ .setHardConstraints(serviceReconfigureInput.getHardConstraints())
+ .setSoftConstraints(serviceReconfigureInput.getSoftConstraints())
+ .setLifecycleState(LifecycleState.Planned).setServiceAEnd(aend).setServiceZEnd(zend)
+ .setSdncRequestHeader(new SdncRequestHeaderBuilder()
+ .setRequestId("reconfigure_" + serviceReconfigureInput.getNewServiceName())
+ .setRpcAction(RpcActions.ServiceReconfigure)
+ .build());
}
org.opendaylight.yang.gen.v1.http.org.transportpce.b.c._interface.service.types.rev170426.response