drop-test/src/main/java/org/opendaylight/openflowplugin/outputtest/OutputTestCommandProvider.java

   1 /*
   2  * Copyright (c) 2013 Cisco Systems, Inc. and others.  All rights reserved.
   3  *
   4  * This program and the accompanying materials are made available under the
   5  * terms of the Eclipse Public License v1.0 which accompanies this distribution,
   6  * and is available at http://www.eclipse.org/legal/epl-v10.html
   7  */
   8 package org.opendaylight.openflowplugin.outputtest;
   9
  10 import java.util.ArrayList;
  11 import java.util.List;
  12
  13 import org.apache.commons.lang.ArrayUtils;
  14 import org.eclipse.osgi.framework.console.CommandInterpreter;
  15 import org.eclipse.osgi.framework.console.CommandProvider;
  16 import org.opendaylight.controller.sal.binding.api.BindingAwareBroker.ProviderContext;
  17 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.PacketProcessingService;
  18 import org.opendaylight.yang.gen.v1.urn.opendaylight.packet.service.rev130709.TransmitPacketInput;
  19 import org.osgi.framework.BundleContext;
  20 import org.slf4j.Logger;
  21 import org.slf4j.LoggerFactory;
  22
  23 public class OutputTestCommandProvider implements CommandProvider {
  24
  25     private PacketProcessingService packetProcessingService;
  26     private ProviderContext pc;
  27     private BundleContext ctx;
  28     private boolean sessionInitiated = false;
  29     private static Logger LOG = LoggerFactory.getLogger(OutputTestCommandProvider.class);
  30
  31     public OutputTestCommandProvider(BundleContext ctx) {
  32         this.ctx = ctx;
  33     }
  34
  35     public void onSessionInitiated(ProviderContext session) {
  36         pc = session;
  37         packetProcessingService = session
  38                 .getRpcService(PacketProcessingService.class);
  39         ctx.registerService(CommandProvider.class.getName(), this, null);
  40         this.sessionInitiated = true;
  41     }
  42
  43     public void _sendOutputMsg(CommandInterpreter ci) {
  44         /* Sending package OUT */
  45         LOG.info("SendOutMsg");
  46         if (sessionInitiated) {
  47             String inNodeKey = ci.nextArgument();
  48
  49 //          String resultOfPingFlow = OutputTestUtil.makePingFlowForNode(inNodeKey, pc);
  50 //          ci.println(resultOfPingFlow);
  51
  52             TransmitPacketInput input = OutputTestUtil.buildTransmitInputPacket(
  53                                 inNodeKey,
  54                                 new String("sendOutputMsg_TEST").getBytes(),
  55                                 "0xfffffffd", // port
  56                                 "0");
  57
  58             packetProcessingService.transmitPacket(input);
  59         } else {
  60             ci.println("Session not initiated, try again in a few seconds");
  61         }
  62     }
  63
  64     public void _sendOutTopologyMsg(CommandInterpreter ci) {
  65         /* Sending package OUT */
  66         LOG.info("SendOutTopologyMsg");
  67
  68
  69     }
  70
  71     @Override
  72     public String getHelp() {
  73         StringBuilder strBuf = new StringBuilder("-------------- OUT Package ----------\n")
  74                 .append(" sendOutputMsg command + nodeId as param sends empty package out \n ");
  75         return strBuf.toString();
  76     }
  77 }