X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=pce%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Ftransportpce%2Fpce%2Fimpl%2FPceServiceRPCImpl.java;h=af68f19ae9ac64dca35ddab3daa494c2752ef12d;hb=26ae7f03806a3079dca25ec6e3285f2ba369c481;hp=6fb7ac8cae206334b8ecdc62e4f03fd33f245b7a;hpb=15f6ff30d3f8f562ed139d8855e12ffa35bedf95;p=transportpce.git diff --git a/pce/src/main/java/org/opendaylight/transportpce/pce/impl/PceServiceRPCImpl.java b/pce/src/main/java/org/opendaylight/transportpce/pce/impl/PceServiceRPCImpl.java old mode 100755 new mode 100644 index 6fb7ac8ca..af68f19ae --- a/pce/src/main/java/org/opendaylight/transportpce/pce/impl/PceServiceRPCImpl.java +++ b/pce/src/main/java/org/opendaylight/transportpce/pce/impl/PceServiceRPCImpl.java @@ -8,15 +8,15 @@ package org.opendaylight.transportpce.pce.impl; import com.google.common.util.concurrent.ListenableFuture; - import java.util.concurrent.ExecutionException; - import org.opendaylight.transportpce.pce.service.PathComputationService; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev171017.CancelResourceReserveInput; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev171017.CancelResourceReserveOutput; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev171017.PathComputationRequestInput; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev171017.PathComputationRequestOutput; -import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev171017.TransportpcePceService; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.CancelResourceReserveInput; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.CancelResourceReserveOutput; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.PathComputationRequestInput; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.PathComputationRequestOutput; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.PathComputationRerouteRequestInput; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.PathComputationRerouteRequestOutput; +import org.opendaylight.yang.gen.v1.http.org.opendaylight.transportpce.pce.rev220808.TransportpcePceService; import org.opendaylight.yangtools.yang.common.RpcResult; import org.opendaylight.yangtools.yang.common.RpcResultBuilder; import org.slf4j.Logger; @@ -48,18 +48,25 @@ public class PceServiceRPCImpl implements TransportpcePceService { return RpcResultBuilder.success(output).buildFuture(); } - @Override public ListenableFuture> pathComputationRequest(PathComputationRequestInput input) { LOG.info("RPC path computation request received"); + LOG.debug("input parameters are : input = {}", input); PathComputationRequestOutput output = null; try { output = this.pathComputationService.pathComputationRequest(input).get(); } catch (InterruptedException | ExecutionException e) { - LOG.error("RPC cancelResourceReserve failed !", e); + LOG.error("RPC path computation request failed !", e); } return RpcResultBuilder.success(output).buildFuture(); } + @Override + public ListenableFuture> + pathComputationRerouteRequest(PathComputationRerouteRequestInput input) { + LOG.info("RPC path computation reroute request received"); + LOG.debug("input parameters are : input = {}", input); + return null; + } }