- @Override
- public final ListenableFuture<RpcResult<CancelResourceReserveOutput>>
- cancelResourceReserve(CancelResourceReserveInput input) {
- LOG.info("RPC cancelResourceReserve request received");
- try {
- return RpcResultBuilder
- .success(
- this.pathComputationService.cancelResourceReserve(input).get())
- .buildFuture();
- } catch (InterruptedException | ExecutionException e) {
- LOG.error("RPC cancelResourceReserve failed !", e);
- return RpcResultBuilder.success((CancelResourceReserveOutput) null).buildFuture();
- }
- }
-
- @Override
- public final ListenableFuture<RpcResult<PathComputationRequestOutput>>
- pathComputationRequest(PathComputationRequestInput input) {
- LOG.info("RPC path computation request received");
- LOG.debug("input parameters are : input = {}", input);
- try {
- return RpcResultBuilder
- .success(
- this.pathComputationService.pathComputationRequest(input).get())
- .buildFuture();
- } catch (InterruptedException | ExecutionException e) {
- LOG.error("RPC path computation request failed !", e);
- }
- return RpcResultBuilder.success((PathComputationRequestOutput) null).buildFuture();
- }
-
- @Override
- public final ListenableFuture<RpcResult<PathComputationRerouteRequestOutput>> pathComputationRerouteRequest(
- PathComputationRerouteRequestInput input) {
- LOG.info("RPC path computation reroute request received");
- LOG.debug("input parameters are : input = {}", input);
- try {
- return RpcResultBuilder
- .success(
- this.pathComputationService.pathComputationRerouteRequest(input).get())
- .buildFuture();
- } catch (InterruptedException | ExecutionException e) {
- LOG.error("RPC path computation request failed !", e);
- return RpcResultBuilder.success((PathComputationRerouteRequestOutput) null).buildFuture();
- }
- }
-