org.opendaylight.yangtools.yang.common.RpcResult.getResult()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(9.7k)|赞(0)|评价(0)|浏览(67)

本文整理了Java中org.opendaylight.yangtools.yang.common.RpcResult.getResult方法的一些代码示例,展示了RpcResult.getResult的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RpcResult.getResult方法的具体详情如下:
包路径:org.opendaylight.yangtools.yang.common.RpcResult
类名称:RpcResult
方法名:getResult

RpcResult.getResult介绍

[英]Returns the value result of the call or null if no result is available.
[中]返回调用的结果值,如果没有结果,则返回null。

代码示例

代码示例来源:origin: org.opendaylight.bgpcep/pcep-tunnel-provider

@Override
  public OperationResult apply(final RpcResult<AddLspOutput> input) {
    return input.getResult();
  }
});

代码示例来源:origin: org.opendaylight.bgpcep/pcep-tunnel-provider

@Override
  public OperationResult apply(final RpcResult<RemoveLspOutput> input) {
    return input.getResult();
  }
});

代码示例来源:origin: org.opendaylight.alto.ext/alto-spce-impl

private BigInteger getBandwidthByTp(String txTpId) {
  BigInteger availableBandwidth = null;
  AltoSpceGetTxBandwidthInput input = new AltoSpceGetTxBandwidthInputBuilder().setTpId(txTpId).build();
  Future<RpcResult<AltoSpceGetTxBandwidthOutput>> result = this.networkTrackerService.altoSpceGetTxBandwidth(input);
  try {
    AltoSpceGetTxBandwidthOutput output = result.get().getResult();
    availableBandwidth = output.getSpeed();
  } catch (InterruptedException | ExecutionException e) {
    return BigInteger.valueOf(0);
  }
  return availableBandwidth;
}

代码示例来源:origin: org.opendaylight.netide/shim

@Override
public void onSuccess(RpcResult<E> rpcReply) {
  if (rpcReply.isSuccessful()) {
    E result = rpcReply.getResult();
    sendOpenFlowMessageToCore(coreConnector, result, ofVersion, xId, datapathId, moduleId);
  } else {
    for (RpcError rpcError : rpcReply.getErrors()) {
      LOG.info("SHIM RELAY: error in communication with switch: {}", rpcError.getMessage());
    }
  }
}

代码示例来源:origin: org.opendaylight.mdsal/mdsal-binding2-dom-adapter

private DOMActionResult transform(final RpcResult<?> input) {
  if (input.isSuccessful()) {
    final Object inputData = input.getResult();
    if (inputData instanceof DataContainer) {
      return new SimpleDOMActionResult(codec.toNormalizedNodeOperationData((TreeNode) inputData),
        ImmutableList.of());
    } else {
      return new SimpleDOMActionResult(ImmutableList.of());
    }
  }
  return new SimpleDOMActionResult(input.getErrors());
}

代码示例来源:origin: org.opendaylight.openflowplugin/openflowplugin

@Override
public RpcResult<AddFlowOutput> apply(RpcResult<UpdateFlowOutput> input) {
  UpdateFlowOutput updateFlowOutput = input.getResult();
  AddFlowOutputBuilder addFlowOutput = new AddFlowOutputBuilder();
  addFlowOutput.setTransactionId(updateFlowOutput.getTransactionId());
  AddFlowOutput result = addFlowOutput.build();
  RpcResult<AddFlowOutput> rpcResult = assembleRpcResult(input, result);
  LOG.debug(MSG_ADD_FLOW_RPC);
  return rpcResult;
}

代码示例来源:origin: org.opendaylight.openflowplugin/openflowplugin

@Override
  public RpcResult<AddMeterOutput> apply(final RpcResult<UpdateMeterOutput> input) {
    UpdateMeterOutput updateMeterOutput = input.getResult();
    AddMeterOutputBuilder addMeterOutput = new AddMeterOutputBuilder();
    addMeterOutput.setTransactionId(updateMeterOutput.getTransactionId());
    AddMeterOutput result = addMeterOutput.build();
    RpcResult<AddMeterOutput> rpcResult = assembleRpcResult(input, result);
    LOG.debug("Returning the Add Meter RPC result to MD-SAL");
    return rpcResult;
  }
};

代码示例来源:origin: org.opendaylight.openflowplugin/openflowplugin

@Override
public RpcResult<RemoveFlowOutput> apply(RpcResult<UpdateFlowOutput> input) {
  UpdateFlowOutput updateFlowOutput = input.getResult();
  RemoveFlowOutputBuilder removeFlowOutput = new RemoveFlowOutputBuilder();
  removeFlowOutput.setTransactionId(updateFlowOutput.getTransactionId());
  RemoveFlowOutput result = removeFlowOutput.build();
  RpcResult<RemoveFlowOutput> rpcResult = assembleRpcResult(input, result);
  LOG.debug("Returning the Remove Flow RPC result to MD-SAL");
  return rpcResult;
}

代码示例来源:origin: org.opendaylight.openflowplugin/openflowplugin

@Override
  public RpcResult<RemoveMeterOutput> apply(final RpcResult<UpdateMeterOutput> input) {
    UpdateMeterOutput updateMeterOutput = input.getResult();
    RemoveMeterOutputBuilder removeMeterOutput = new RemoveMeterOutputBuilder();
    removeMeterOutput.setTransactionId(updateMeterOutput.getTransactionId());
    RemoveMeterOutput result = removeMeterOutput.build();
    RpcResult<RemoveMeterOutput> rpcResult = assembleRpcResult(input, result);
    LOG.debug("Returning the Remove Meter RPC result to MD-SAL");
    return rpcResult;
  }
};

代码示例来源:origin: org.opendaylight.openflowplugin/openflowplugin

@Override
public RpcResult<RemoveGroupOutput> apply(RpcResult<UpdateGroupOutput> input) {
  UpdateGroupOutput updateGroupOutput = input.getResult();
  RemoveGroupOutputBuilder removeGroupOutput = new RemoveGroupOutputBuilder();
  removeGroupOutput.setTransactionId(updateGroupOutput.getTransactionId());
  RemoveGroupOutput result = removeGroupOutput.build();
  RpcResult<RemoveGroupOutput> rpcResult = assembleRpcResult(input, result);
  LOG.debug("Returning the Remove Group RPC result to MD-SAL");
  return rpcResult;
}

代码示例来源:origin: org.opendaylight.yangtools/yang-common

/**
 * Returns a builder from another RpcResult.
 *
 * @param other the other RpcResult.
 */
public static <T> RpcResultBuilder<T> from(final RpcResult<T> other) {
  return new RpcResultBuilder<>(other.isSuccessful(), other.getResult())
                         .withRpcErrors(other.getErrors());
}

代码示例来源:origin: org.opendaylight.controller/sal-netconf-connector

@Override
  public DOMRpcResult apply(final RpcResult<NetconfMessage> input) {
    if (input.isSuccessful()) {
      return transformer.toRpcResult(input.getResult(), type);
    } else {
      // TODO check whether the listener sets errors properly
      return new DefaultDOMRpcResult(input.getErrors());
    }
  }
});

代码示例来源:origin: org.opendaylight.ocpplugin/ocpplugin-impl

@Override
public void onSuccess(final RpcResult<org.opendaylight.yang.gen.v1.urn.opendaylight.ocp.protocol.rev150811.GetStateOutput> result) {
  org.opendaylight.yang.gen.v1.urn.opendaylight.ocp.protocol.rev150811.GetStateOutput output = result.getResult();
  GetStateOutputBuilder builder = new GetStateOutputBuilder();
  builder.setObj(output.getObj());
  builder.setResult(output.getResult());
  RpcResultBuilder<GetStateOutput> rpcResultBuilder = RpcResultBuilder.success(builder);
  finalFuture.set(rpcResultBuilder.build());
}

代码示例来源:origin: org.opendaylight.ocpplugin/ocpplugin-impl

@Override
public void onSuccess(final RpcResult<org.opendaylight.yang.gen.v1.urn.opendaylight.ocp.protocol.rev150811.GetParamOutput> result) {
  org.opendaylight.yang.gen.v1.urn.opendaylight.ocp.protocol.rev150811.GetParamOutput output = result.getResult();
  GetParamOutputBuilder builder = new GetParamOutputBuilder();
  builder.setObj(output.getObj());
  builder.setResult(output.getResult());
  RpcResultBuilder<GetParamOutput> rpcResultBuilder = RpcResultBuilder.success(builder);
  finalFuture.set(rpcResultBuilder.build());
}

代码示例来源:origin: org.opendaylight.ocpplugin/ocpplugin-impl

@Override
public void onSuccess(final RpcResult<org.opendaylight.yang.gen.v1.urn.opendaylight.ocp.protocol.rev150811.GetFaultOutput> result) {
  org.opendaylight.yang.gen.v1.urn.opendaylight.ocp.protocol.rev150811.GetFaultOutput output = result.getResult();
  GetFaultOutputBuilder builder = new GetFaultOutputBuilder();
  builder.setObj(output.getObj());
  builder.setResult(output.getResult());
  RpcResultBuilder<GetFaultOutput> rpcResultBuilder = RpcResultBuilder.success(builder);
  finalFuture.set(rpcResultBuilder.build());
}

代码示例来源:origin: org.opendaylight.controller/sal-binding-broker-impl

private DOMRpcResult transform(final RpcResult<?> input) {
  if (input.isSuccessful()) {
    final Object inputData = input.getResult();
    if (inputData instanceof DataContainer) {
      return new DefaultDOMRpcResult(codec.toNormalizedNodeRpcData((DataContainer) inputData));
    } else {
      return new DefaultDOMRpcResult((NormalizedNode<?, ?>) null);
    }
  }
  return new DefaultDOMRpcResult(input.getErrors());
}

代码示例来源:origin: org.opendaylight.mdsal/mdsal-binding-dom-adapter

private DOMRpcResult transform(final RpcResult<?> input) {
    if (input.isSuccessful()) {
      final Object inputData = input.getResult();
      if (inputData instanceof DataContainer) {
        return new DefaultDOMRpcResult(codec.toNormalizedNodeRpcData((DataContainer) inputData));
      }

      return new DefaultDOMRpcResult((NormalizedNode<?, ?>) null);
    }
    return new DefaultDOMRpcResult(input.getErrors());
  }
}

代码示例来源:origin: org.opendaylight.mdsal/mdsal-binding2-dom-adapter

private DOMRpcResult transform(final RpcResult<?> input) {
  if (input.isSuccessful()) {
    final Object inputData = input.getResult();
    if (inputData instanceof DataContainer) {
      return new DefaultDOMRpcResult(codec.toNormalizedNodeOperationData((TreeNode) inputData));
    } else {
      return new DefaultDOMRpcResult((NormalizedNode<?, ?>) null);
    }
  }
  return new DefaultDOMRpcResult(input.getErrors());
}

代码示例来源:origin: org.opendaylight.ocpplugin/ocpplugin-impl

@Override
public void onSuccess(final RpcResult<org.opendaylight.yang.gen.v1.urn.opendaylight.ocp.protocol.rev150811.CreateObjOutput> result) {
  org.opendaylight.yang.gen.v1.urn.opendaylight.ocp.protocol.rev150811.CreateObjOutput output = result.getResult();
  CreateObjOutputBuilder builder = new CreateObjOutputBuilder();
  builder.setObjId(output.getObjId());                
  builder.setParam(output.getParam());
  builder.setGlobResult(output.getGlobResult());
  RpcResultBuilder<CreateObjOutput> rpcResultBuilder = RpcResultBuilder.success(builder);
  finalFuture.set(rpcResultBuilder.build());
}

代码示例来源:origin: org.opendaylight.ocpplugin/ocpplugin-impl

@Override
public void onSuccess(final RpcResult<org.opendaylight.yang.gen.v1.urn.opendaylight.ocp.protocol.rev150811.ModifyStateOutput> result) {
  org.opendaylight.yang.gen.v1.urn.opendaylight.ocp.protocol.rev150811.ModifyStateOutput output = result.getResult();
  ModifyStateOutputBuilder builder = new ModifyStateOutputBuilder();
  builder.setObjId(output.getObjId());
  builder.setStateType(output.getStateType());
  builder.setStateValue(output.getStateValue());
  builder.setResult(output.getResult());
  RpcResultBuilder<ModifyStateOutput> rpcResultBuilder = RpcResultBuilder.success(builder);
  finalFuture.set(rpcResultBuilder.build());
}

相关文章

微信公众号

最新文章

更多