return "";
}
long count = netconfNode.getAvailableCapabilities().getAvailableCapability().stream()
- .filter(cp -> (cp.getCapability() != null) && cp.getCapability().contains(ORG_OPENROADM_DEVICE)).count();
+ .filter(cp -> (cp.getCapability() != null) && cp.getCapability().contains(ORG_OPENROADM_DEVICE)).count();
if (count < 1) {
LOG.trace("The node {} has not capabilities of OpenROADMDevice", node);
return "";
return new Query();
}
- public final static class Query {
+ public static final class Query {
private String sql;
private String schema;
* @return Result of the request
*/
@Override
- public ListenableFuture<RpcResult<ServicePowerTurndownOutput>> servicePowerTurndown(ServicePowerTurndownInput input) {
+ public ListenableFuture<RpcResult<ServicePowerTurndownOutput>>
+ servicePowerTurndown(ServicePowerTurndownInput input) {
return RpcResultBuilder.success(this.olmPowerService.servicePowerTurndown(input)).buildFuture();
}
* @return Result of the request
*/
@Override
- public ListenableFuture<RpcResult<CalculateSpanlossBaseOutput>> calculateSpanlossBase(CalculateSpanlossBaseInput input) {
+ public ListenableFuture<RpcResult<CalculateSpanlossBaseOutput>>
+ calculateSpanlossBase(CalculateSpanlossBaseInput input) {
return RpcResultBuilder.success(this.olmPowerService.calculateSpanlossBase(input)).buildFuture();
}
public ListenableFuture<RpcResult<ServicePowerResetOutput>> servicePowerReset(ServicePowerResetInput input) {
return RpcResultBuilder.success(this.olmPowerService.servicePowerReset(input)).buildFuture();
}
-}
\ No newline at end of file
+}
Mapping portMapping = mappingObjectOptional.get();
Optional<Interface> interfaceOpt;
try {
- interfaceOpt = this.openRoadmInterfaces.getInterface(nodeId, portMapping.getSupportingOts());
+ interfaceOpt =
+ this.openRoadmInterfaces.getInterface(nodeId, portMapping.getSupportingOts());
} catch (OpenRoadmInterfaceException ex) {
LOG.error("Failed to get interface {} from node {}!", portMapping.getSupportingOts(),
nodeId, ex);
if (nodeInterfaceOpt.isPresent()) {
InterfaceBuilder intfBuilder = new InterfaceBuilder(nodeInterfaceOpt.get());
intfBuilder.setAdministrativeState(AdminStates.OutOfService);
- Future<Optional<DeviceTransaction>> deviceTxFuture = this.deviceTransactionManager.getDeviceTransaction(nodeId);
+ Future<Optional<DeviceTransaction>> deviceTxFuture =
+ this.deviceTransactionManager.getDeviceTransaction(nodeId);
DeviceTransaction deviceTx;
try {
Optional<DeviceTransaction> deviceTxOpt = deviceTxFuture.get();
org.opendaylight.yang.gen.v1.http.org.openroadm.optical.channel.interfaces.rev161014
.Interface1.class, new Interface1Builder().setOch(ochBuilder.build()).build());
- Future<Optional<DeviceTransaction>> deviceTxFuture = this.deviceTransactionManager.getDeviceTransaction(nodeId);
+ Future<Optional<DeviceTransaction>> deviceTxFuture =
+ this.deviceTransactionManager.getDeviceTransaction(nodeId);
DeviceTransaction deviceTx;
try {
Optional<DeviceTransaction> deviceTxOpt = deviceTxFuture.get();
}
@Override
- public ListenableFuture<RpcResult<CancelResourceReserveOutput>> cancelResourceReserve(CancelResourceReserveInput input) {
+ public ListenableFuture<RpcResult<CancelResourceReserveOutput>>
+ cancelResourceReserve(CancelResourceReserveInput input) {
LOG.info("RPC cancelResourceReserve request received");
return RpcResultBuilder.success(this.pathComputationService.cancelResourceReserve(input)).buildFuture();
}
@Override
- public ListenableFuture<RpcResult<PathComputationRequestOutput>> pathComputationRequest(PathComputationRequestInput input) {
+ public ListenableFuture<RpcResult<PathComputationRequestOutput>>
+ pathComputationRequest(PathComputationRequestInput input) {
LOG.info("RPC path computation request received");
return RpcResultBuilder.success(this.pathComputationService.pathComputationRequest(input)).buildFuture();
}
}
@Override
- public ListenableFuture<RpcResult<CancelResourceReserveOutput>> cancelResourceReserve(CancelResourceReserveInput input) {
+ public ListenableFuture<RpcResult<CancelResourceReserveOutput>>
+ cancelResourceReserve(CancelResourceReserveInput input) {
// TODO Auto-generated method stub
return null;
}
}
@Override
- public ListenableFuture<RpcResult<PathComputationRequestOutput>> pathComputationRequest(PathComputationRequestInput input) {
+ public ListenableFuture<RpcResult<PathComputationRequestOutput>>
+ pathComputationRequest(PathComputationRequestInput input) {
// TODO Auto-generated method stub
return null;
}
return null;
}
- @Override public ListenableFuture<RpcResult<ServicePowerResetOutput>> servicePowerReset(ServicePowerResetInput input) {
+ @Override public ListenableFuture<RpcResult<ServicePowerResetOutput>>
+ servicePowerReset(ServicePowerResetInput input) {
return null;
}
- @Override public ListenableFuture<RpcResult<ServicePowerSetupOutput>> servicePowerSetup(ServicePowerSetupInput input) {
+ @Override public ListenableFuture<RpcResult<ServicePowerSetupOutput>>
+ servicePowerSetup(ServicePowerSetupInput input) {
return RpcResultBuilder.success(new ServicePowerSetupOutputBuilder().build()).buildFuture();
}
}
}
@Override
- public ListenableFuture<RpcResult<EquipmentNotificationOutput>> equipmentNotification(EquipmentNotificationInput input) {
+ public ListenableFuture<RpcResult<EquipmentNotificationOutput>>
+ equipmentNotification(EquipmentNotificationInput input) {
// TODO Auto-generated method stub
return null;
}
@Override
- public ListenableFuture<RpcResult<ServiceRerouteConfirmOutput>> serviceRerouteConfirm(ServiceRerouteConfirmInput input) {
+ public ListenableFuture<RpcResult<ServiceRerouteConfirmOutput>>
+ serviceRerouteConfirm(ServiceRerouteConfirmInput input) {
// TODO Auto-generated method stub
return null;
}
}
@Override
- public ListenableFuture<RpcResult<NetworkReOptimizationOutput>> networkReOptimization(NetworkReOptimizationInput input) {
+ public ListenableFuture<RpcResult<NetworkReOptimizationOutput>>
+ networkReOptimization(NetworkReOptimizationInput input) {
// TODO Auto-generated method stub
return null;
}
* @return BindingNormalizedNodeCodecRegistry the resulting binding registry
*/
private BindingNormalizedNodeCodecRegistry createBindingRegistry() {
- BindingRuntimeContext bindingContext = BindingRuntimeContext.create(this.moduleInfoBackedCntxt, this.schemaContext);
+ BindingRuntimeContext bindingContext =
+ BindingRuntimeContext.create(this.moduleInfoBackedCntxt, this.schemaContext);
BindingNormalizedNodeCodecRegistry bindingNormalizedNodeCodecRegistry =
new BindingNormalizedNodeCodecRegistry(
StreamWriterGenerator.create(JavassistUtils.forClassPool(ClassPool.getDefault())));
}
@Override
- public ListenableFuture<RpcResult<CancelResourceReserveOutput>> cancelResourceReserve(CancelResourceReserveInput input) {
+ public ListenableFuture<RpcResult<CancelResourceReserveOutput>>
+ cancelResourceReserve(CancelResourceReserveInput input) {
LOG.info("RPC cancelResourceReserve request received");
String message = "";
String responseCode = "";
}
@Override
- public ListenableFuture<RpcResult<PathComputationRequestOutput>> pathComputationRequest(PathComputationRequestInput input) {
+ public ListenableFuture<RpcResult<PathComputationRequestOutput>>
+ pathComputationRequest(PathComputationRequestInput input) {
LOG.info("RPC pathcomputation request received");
String message = "";
String responseCode = "";
.setNotificationType(ServicePathNotificationTypes.PathComputationRequest)
.setServiceName(input.getServiceName()).setStatus(RpcStatusEx.Successful)
.setStatusMessage(this.message);
- StubpceImpl.this.pathDescriptionBuilder = StubpceImpl.this.sendingPCE.getPathDescription();
+ StubpceImpl.this.pathDescriptionBuilder =
+ StubpceImpl.this.sendingPCE.getPathDescription();
if (StubpceImpl.this.pathDescriptionBuilder != null) {
PathDescription pathDescription = new org.opendaylight.yang.gen.v1.http.org
- .transportpce.b.c._interface.servicepath.rev170426.service.path
- .rpc.result.PathDescriptionBuilder()
- .setAToZDirection(StubpceImpl.this.pathDescriptionBuilder.getAToZDirection())
- .setZToADirection(StubpceImpl.this.pathDescriptionBuilder.getZToADirection())
- .build();
+ .transportpce.b.c._interface.servicepath.rev170426.service.path
+ .rpc.result.PathDescriptionBuilder()
+ .setAToZDirection(
+ StubpceImpl.this.pathDescriptionBuilder.getAToZDirection())
+ .setZToADirection(
+ StubpceImpl.this.pathDescriptionBuilder.getZToADirection())
+ .build();
tmp.setPathDescription(new PathDescriptionBuilder()
.setAToZDirection(pathDescription.getAToZDirection())
.setZToADirection(pathDescription.getZToADirection())