+++ /dev/null
-/*
- * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.
- *
- * This program and the accompanying materials are made available under the
- * terms of the Eclipse Public License v1.0 which accompanies this distribution,
- * and is available at http://www.eclipse.org/legal/epl-v10.html
- */
-package org.opendaylight.controller.protocol_plugins.stub.internal;
-
-import java.net.InetAddress;
-import java.net.UnknownHostException;
-import java.util.ArrayList;
-import java.util.List;
-
-import org.opendaylight.controller.sal.action.Action;
-import org.opendaylight.controller.sal.action.Controller;
-import org.opendaylight.controller.sal.action.Drop;
-import org.opendaylight.controller.sal.action.Flood;
-import org.opendaylight.controller.sal.action.FloodAll;
-import org.opendaylight.controller.sal.action.HwPath;
-import org.opendaylight.controller.sal.action.Loopback;
-import org.opendaylight.controller.sal.action.Output;
-import org.opendaylight.controller.sal.action.PopVlan;
-import org.opendaylight.controller.sal.action.PushVlan;
-import org.opendaylight.controller.sal.action.SetDlDst;
-import org.opendaylight.controller.sal.action.SetDlSrc;
-import org.opendaylight.controller.sal.action.SetDlType;
-import org.opendaylight.controller.sal.action.SetNwDst;
-import org.opendaylight.controller.sal.action.SetNwSrc;
-import org.opendaylight.controller.sal.action.SetNwTos;
-import org.opendaylight.controller.sal.action.SetTpDst;
-import org.opendaylight.controller.sal.action.SetTpSrc;
-import org.opendaylight.controller.sal.action.SetVlanCfi;
-import org.opendaylight.controller.sal.action.SetVlanId;
-import org.opendaylight.controller.sal.action.SetVlanPcp;
-import org.opendaylight.controller.sal.action.SwPath;
-import org.opendaylight.controller.sal.core.ConstructionException;
-import org.opendaylight.controller.sal.core.Node;
-import org.opendaylight.controller.sal.core.NodeConnector;
-import org.opendaylight.controller.sal.core.NodeTable;
-import org.opendaylight.controller.sal.flowprogrammer.Flow;
-import org.opendaylight.controller.sal.match.Match;
-import org.opendaylight.controller.sal.match.MatchType;
-import org.opendaylight.controller.sal.reader.FlowOnNode;
-import org.opendaylight.controller.sal.reader.IPluginInReadService;
-import org.opendaylight.controller.sal.reader.NodeConnectorStatistics;
-import org.opendaylight.controller.sal.reader.NodeDescription;
-import org.opendaylight.controller.sal.reader.NodeTableStatistics;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-/**
- * Stub Implementation for IPluginInReadService used by SAL
- *
- *
- */
-public class ReadService implements IPluginInReadService {
- private static final Logger logger = LoggerFactory
- .getLogger(ReadService.class);
-
- /**
- * Function called by the dependency manager when all the required
- * dependencies are satisfied
- *
- */
- void init() {
- }
-
- /**
- * Function called by the dependency manager when at least one dependency
- * become unsatisfied or when the component is shutting down because for
- * example bundle is being stopped.
- *
- */
- void destroy() {
- }
-
- /**
- * Function called by dependency manager after "init ()" is called and after
- * the services provided by the class are registered in the service registry
- *
- */
- void start() {
- }
-
- /**
- * Function called by the dependency manager before the services exported by
- * the component are unregistered, this will be followed by a "destroy ()"
- * calls
- *
- */
- void stop() {
- }
-
- @Override
- public FlowOnNode readFlow(Node node, Flow flow, boolean cached) {
- FlowOnNode fn1 = new FlowOnNode(flow);
- fn1.setByteCount(100);
- fn1.setDurationNanoseconds(400);
- fn1.setDurationSeconds(40);
- fn1.setTableId((byte) 0x1);
- fn1.setPacketCount(200);
- return fn1;
- }
-
- @Override
- public List<FlowOnNode> readAllFlow(Node node, boolean cached) {
-
- ArrayList<FlowOnNode> list = new ArrayList<FlowOnNode>();
- ArrayList<Action> actionList = new ArrayList<Action>();
- actionList.add(new Drop()); //IT assumes this is first element
- actionList.add(new Loopback());
- actionList.add(new Flood());
- actionList.add(new FloodAll());
- actionList.add(new Controller());
- actionList.add(new SwPath());
- actionList.add(new HwPath());
- try {
- actionList.add(new Output(new NodeConnector("STUB", 0xCAFE, node)));
- } catch (ConstructionException e) {
-
- }
- byte dst[] = { (byte) 1, (byte) 2, (byte) 3, (byte) 4, (byte) 5 };
- byte src[] = { (byte) 5, (byte) 4, (byte) 3, (byte) 2, (byte) 1 };
- actionList.add(new SetDlSrc(src));
- actionList.add(new SetDlDst(dst));
- actionList.add(new SetDlType(10));
-
- actionList.add(new SetVlanId(2));
- actionList.add(new SetVlanPcp(3));
- actionList.add(new SetVlanCfi(1));
-
- actionList.add(new PopVlan());
- actionList.add(new PushVlan(0x8100, 1, 1, 1234));
-
- try {
- actionList.add(new SetNwSrc(InetAddress.getByName("2.2.2.2")));
- actionList.add(new SetNwDst(InetAddress.getByName("1.1.1.1")));
- } catch (UnknownHostException e) {
-
- }
- actionList.add(new SetNwTos(0x10));
- actionList.add(new SetTpSrc(4201));
- actionList.add(new SetTpDst(8080));
-
- short priority = 3500; //IT assumes this value
- for (Action a : actionList) {
- Flow flow = new Flow();
- Match match = new Match();
- try {
- match.setField(MatchType.NW_DST,
- InetAddress.getByName("1.1.1.1"));
- } catch (UnknownHostException e) {
-
- }
- flow.setMatch(match);
- List<Action> actions = new ArrayList<Action>();
- actions.add(a);
- flow.setActions(actions);
- flow.setPriority(priority++);
- flow.setIdleTimeout((short) 1000);
- flow.setHardTimeout((short) 2000);
- flow.setId(12345);
-
- FlowOnNode fn1 = new FlowOnNode(flow);
- fn1.setByteCount(100);
- fn1.setDurationNanoseconds(400);
- fn1.setDurationSeconds(40);
- fn1.setTableId((byte) 0x1);
- fn1.setPacketCount(200);
-
- list.add(fn1);
- }
- return list;
- }
-
- @Override
- public NodeDescription readDescription(Node node, boolean cached) {
- NodeDescription desc = new NodeDescription();
- desc.setDescription("This is a sample node description");
- desc.setHardware("stub hardware");
- desc.setSoftware("stub software");
- desc.setSerialNumber("123");
- desc.setManufacturer("opendaylight");
- return desc;
- }
-
- @Override
- public NodeConnectorStatistics readNodeConnector(NodeConnector connector,
- boolean cached) {
- NodeConnectorStatistics stats = new NodeConnectorStatistics();
- stats.setNodeConnector(connector);
- stats.setCollisionCount(4);
- stats.setReceiveByteCount(1000);
- stats.setReceiveCRCErrorCount(1);
- stats.setReceiveDropCount(2);
- stats.setReceiveErrorCount(3);
- stats.setReceiveFrameErrorCount(5);
- stats.setReceiveOverRunErrorCount(6);
- stats.setReceivePacketCount(250);
- stats.setTransmitByteCount(5000);
- stats.setTransmitDropCount(50);
- stats.setTransmitErrorCount(10);
- stats.setTransmitPacketCount(500);
-
- return stats;
- }
-
- @Override
- public List<NodeConnectorStatistics> readAllNodeConnector(Node node,
- boolean cached) {
- NodeConnectorStatistics stats = new NodeConnectorStatistics();
- try {
- NodeConnector nc = new NodeConnector("STUB", 0xCAFE, node);
- stats.setNodeConnector(nc);
- } catch (ConstructionException e) {
- // couldn't create nodeconnector.
- }
- stats.setCollisionCount(4);
- stats.setReceiveByteCount(1000);
- stats.setReceiveCRCErrorCount(1);
- stats.setReceiveDropCount(2);
- stats.setReceiveErrorCount(3);
- stats.setReceiveFrameErrorCount(5);
- stats.setReceiveOverRunErrorCount(6);
- stats.setReceivePacketCount(250);
- stats.setTransmitByteCount(5000);
- stats.setTransmitDropCount(50);
- stats.setTransmitErrorCount(10);
- stats.setTransmitPacketCount(500);
-
- List<NodeConnectorStatistics> result = new ArrayList<NodeConnectorStatistics>();
- result.add(stats);
- return result;
- }
-
- @Override
- public long getTransmitRate(NodeConnector connector) {
- return 100;
- }
-
- @Override
- public NodeTableStatistics readNodeTable(NodeTable table, boolean b) {
- NodeTableStatistics stats = new NodeTableStatistics();
- stats.setNodeTable(table);
- stats.setActiveCount(4);
- stats.setLookupCount(4);
- stats.setMatchedCount(4);
-
- return stats;
- }
-
- @Override
- public List<NodeTableStatistics> readAllNodeTable(Node node, boolean cached) {
- NodeTableStatistics stats = new NodeTableStatistics();
- try {
- NodeTable nt = new NodeTable(NodeTable.NodeTableIDType.OPENFLOW, Byte.valueOf("10"), node);
- stats.setNodeTable(nt);
- } catch (ConstructionException e) {
- // couldn't create nodetable.
- }
-
- stats.setActiveCount(4);
- stats.setLookupCount(4);
- stats.setMatchedCount(4);
-
- List<NodeTableStatistics> result = new ArrayList<NodeTableStatistics>();
- result.add(stats);
- return result;
- }
-}
Code Review / controller.git / blobdiff