}
@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())
* @param DataBroker
* Access DataStore
*/
- private boolean initializePathDescriptionList(DataBroker db) {
+ private boolean initializePathDescriptionList(DataBroker dataBroker) {
Boolean result = true;
LOG.info("Preparing to initialize the PathDescription List");
- WriteTransaction transaction = db.newWriteOnlyTransaction();
+ WriteTransaction transaction = dataBroker.newWriteOnlyTransaction();
InstanceIdentifier<PathDescriptionList> iid = InstanceIdentifier.create(PathDescriptionList.class);
PathDescriptionList pathDescriptionList = new PathDescriptionListBuilder().build();
transaction.put(LogicalDatastoreType.OPERATIONAL, iid, pathDescriptionList);
* Access DataStore
* @return <code>true</code> if ok, <code>false</code> else
*/
- private boolean initializeServicePathList(DataBroker db) {
+ private boolean initializeServicePathList(DataBroker dataBroker) {
Boolean result = true;
LOG.info("Preparing to initialize the ServicePathList registry");
- WriteTransaction transaction = db.newWriteOnlyTransaction();
+ WriteTransaction transaction = dataBroker.newWriteOnlyTransaction();
InstanceIdentifier<ServicePathList> iid = InstanceIdentifier.create(ServicePathList.class);
ServicePathList servicePathList = new ServicePathListBuilder().build();
transaction.put(LogicalDatastoreType.OPERATIONAL, iid, servicePathList);