org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow.getTableId()方法的使用及代码示例

x33g5p2x  于2022-01-19 转载在 其他  
字(7.1k)|赞(0)|评价(0)|浏览(108)

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

Flow.getTableId介绍

暂无

代码示例

代码示例来源:origin: org.opendaylight.openflowplugin.applications/forwardingrules-manager

private static boolean tableIdValidationPrecondition (final TableKey tableKey, final Flow flow) {
  Preconditions.checkNotNull(tableKey, "TableKey can not be null or empty!");
  Preconditions.checkNotNull(flow, "Flow can not be null or empty!");
  if (! tableKey.getId().equals(flow.getTableId())) {
    LOG.warn("TableID in URI tableId={} and in palyload tableId={} is not same.",
        flow.getTableId(), tableKey.getId());
    return false;
  }
  return true;
}

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

private void notifyTaskIfRequired(BigInteger dpId, Flow flow) {
  FlowInfoKey flowKey = new FlowInfoKey(dpId, flow.getTableId(), flow.getMatch(), flow.getId().getValue());
  Runnable notifyTask = flowMap.remove(flowKey);
  if (notifyTask == null) {
    return;
  }
  executorService.execute(notifyTask);
}

代码示例来源:origin: org.opendaylight.openflowplugin.model/model-flow-service

return false;
if (!Objects.equals(_tableId, other.getTableId())) {
  return false;

代码示例来源:origin: org.opendaylight.groupbasedpolicy/ofoverlay-renderer

return false;
if (!Objects.equals(a.getTableId(), b.getTableId())) {
  return false;

代码示例来源:origin: org.opendaylight.groupbasedpolicy/ofoverlay-renderer

private static InstanceIdentifier<Flow> createFlowIid(Flow flow, InstanceIdentifier<Node> nodeIid) {
  return nodeIid.builder()
    .augmentation(FlowCapableNode.class)
    .child(Table.class, new TableKey(flow.getTableId()))
    .child(Flow.class, new FlowKey(flow.getId()))
    .build();
}

代码示例来源:origin: org.opendaylight.netvirt/openstack.net-virt-providers

private static InstanceIdentifier<Flow> createFlowIid(Flow flow, InstanceIdentifier<Node> nodeIid) {
  return nodeIid.builder()
    .augmentation(FlowCapableNode.class)
    .child(Table.class, new TableKey(flow.getTableId()))
    .child(Flow.class, new FlowKey(flow.getId()))
    .build();
}

代码示例来源:origin: org.opendaylight.groupbasedpolicy/ofoverlay-renderer

result = prime * result + ((flow.getOutPort() == null) ? 0 : flow.getOutPort().hashCode());
result = prime * result + ((flow.getPriority() == null) ? 0 : flow.getPriority().hashCode());
result = prime * result + ((flow.getTableId() == null) ? 0 : flow.getTableId().hashCode());
result = prime * result + ((flow.isBarrier() == null) ? 0 : flow.isBarrier().hashCode());
result = prime * result + ((flow.isInstallHw() == null) ? 0 : flow.isInstallHw().hashCode());

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

.child(Table.class, new TableKey(flow.getTableId())).child(Flow.class, flowKey).build();
if (addOrRemove == NwConstants.ADD_FLOW) {
  tx.put(LogicalDatastoreType.CONFIGURATION, flowInstanceId,flow, true);

代码示例来源:origin: org.opendaylight.openflowplugin.legacy/sal-compatibility

private static final InstanceIdentifier<org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow> flowPath(
    final org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow, final NodeKey nodeKey) {
  return InstanceIdentifier.builder(Nodes.class)
      .child(org.opendaylight.yang.gen.v1.urn.opendaylight.inventory.rev130819.nodes.Node.class, nodeKey)
      .augmentation(FlowCapableNode.class)
      .child(Table.class, new TableKey(flow.getTableId()))
      .child(org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow.class, new FlowKey(flow.getId()))
      .toInstance();
}

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

.child(Table.class, new TableKey(flow.getTableId())).child(Flow.class, flowKey).build();

代码示例来源:origin: org.opendaylight.didm/didm-tools-utils

/**
* This utility method deletes the flows as per the match.
* @param flowService reference of SalFlowService.
* @param flows Collection of flows to be deleted.
* @param node Flows to be deleted from the node.
*/
public static void deleteFlows(SalFlowService flowService,
  Collection<org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow> flows,
  InstanceIdentifier<Node> node) {
  for(org.opendaylight.yang.gen.v1.urn.opendaylight.flow.inventory.rev130819.tables.table.Flow flow : flows) {
     RemoveFlowInputBuilder inputBuilder = new RemoveFlowInputBuilder()
                        .setMatch(flow.getMatch())
                        .setTableId(flow.getTableId())
                        .setNode(new NodeRef(node));
     flowService.removeFlow(inputBuilder.build());
  }
}

代码示例来源:origin: org.opendaylight.openflowplugin.legacy/sal-compatibility

return false;
if (statsFlow.getTableId() == null) {
  if (storedFlow.getTableId() != null) {
    return false;
} else if(!statsFlow.getTableId().equals(storedFlow.getTableId())) {
  return false;

代码示例来源:origin: org.opendaylight.openflowplugin.model/model-flow-service

this._outPort = base.getOutPort();
this._priority = base.getPriority();
this._tableId = base.getTableId();
this._barrier = base.isBarrier();
this._installHw = base.isInstallHw();

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

public CheckedFuture<Void,TransactionCommitFailedException> removeFlowNew(BigInteger dpnId, Flow flowEntity) {
  s_logger.debug("Remove flow {}",flowEntity);
  Node nodeDpn = buildDpnNode(dpnId);
  FlowKey flowKey = new FlowKey(new FlowId(flowEntity.getId()));
  InstanceIdentifier<Flow> flowInstanceId = InstanceIdentifier.builder(Nodes.class)
        .child(Node.class, nodeDpn.getKey()).augmentation(FlowCapableNode.class)
        .child(Table.class, new TableKey(flowEntity.getTableId())).child(Flow.class, flowKey).build();
  WriteTransaction  modification = m_dataBroker.newWriteOnlyTransaction();
  modification.delete(LogicalDatastoreType.CONFIGURATION,flowInstanceId );
  return modification.submit();
}

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

InstanceIdentifier<Flow> flowInstanceId = InstanceIdentifier.builder(Nodes.class)
    .child(Node.class, nodeDpn.getKey()).augmentation(FlowCapableNode.class)
    .child(Table.class, new TableKey(flow.getTableId())).child(Flow.class, flowKey).build();

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

InstanceIdentifier<Flow> flowInstanceId = InstanceIdentifier.builder(Nodes.class)
    .child(Node.class, nodeDpn.getKey()).augmentation(FlowCapableNode.class)
    .child(Table.class, new TableKey(flow.getTableId())).child(Flow.class, flowKey).build();
Runnable notifyTask = new NotifyTask();
FlowInfoKey flowInfoKey = new FlowInfoKey(dpId, tableId, matches, flowId);

代码示例来源:origin: org.opendaylight.didm/didm-tools-utils

NodeConnectorRef nodeConnectorRef = new NodeConnectorRef(node);
TableKey flowTableKey = new TableKey(flow.getTableId());

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

public CheckedFuture<Void,TransactionCommitFailedException> installFlow(BigInteger dpId, Flow flow) {
  FlowKey flowKey = new FlowKey( new FlowId(flow.getId()) );
  Node nodeDpn = buildDpnNode(dpId);
  InstanceIdentifier<Flow> flowInstanceId = InstanceIdentifier.builder(Nodes.class)
      .child(Node.class, nodeDpn.getKey()).augmentation(FlowCapableNode.class)
      .child(Table.class, new TableKey(flow.getTableId())).child(Flow.class,flowKey).build();
  WriteTransaction modification = m_dataBroker.newWriteOnlyTransaction();
  modification.put(LogicalDatastoreType.CONFIGURATION, flowInstanceId, flow, true);
  return modification.submit();
}

相关文章