本文整理了Java中org.opendaylight.yangtools.yang.common.RpcResult.getResult
方法的一些代码示例,展示了RpcResult.getResult
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。RpcResult.getResult
方法的具体详情如下:
包路径:org.opendaylight.yangtools.yang.common.RpcResult
类名称: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());
}
内容来源于网络,如有侵权,请联系作者删除!