removing some TODOs

Change-Id: Ic98c811573a1b37813993eedddec512ec85729f3

@@ -58,7 +58,6 @@ public class ElectionTest {
 
 
     private ControllerNode localControllerNode;
     private ControllerNode localControllerNode;
 
 
-    // TODO write cli command to get leader
 
 
     @Activate
     @Activate
     protected void activate() {
     protected void activate() {

@@ -174,7 +174,6 @@ public class FooComponent {
             //try {
             //try {
                 //Thread.sleep(5000);
                 //Thread.sleep(5000);
             //} catch (InterruptedException e) {
             //} catch (InterruptedException e) {
-                // TODO Auto-generated catch block
                 //e.printStackTrace();
                 //e.printStackTrace();
             //}
             //}
             log.info("Acquired Lock");
             log.info("Acquired Lock");

@@ -129,10 +129,6 @@ public class IntentMetrics implements IntentMetricsService,
     @Override
     @Override
     public void event(IntentEvent event) {
     public void event(IntentEvent event) {
         synchronized (lastEvents) {
         synchronized (lastEvents) {
-            //
-            // TODO: The processing below is incomplete: we don't have
-            // an event equivalent of "Withdraw Requested"
-            //
             switch (event.type()) {
             switch (event.type()) {
             case INSTALL_REQ:
             case INSTALL_REQ:
                 intentSubmittedEventMetric.eventReceived();
                 intentSubmittedEventMetric.eventReceived();
@@ -141,7 +137,7 @@ public class IntentMetrics implements IntentMetricsService,
                 intentInstalledEventMetric.eventReceived();
                 intentInstalledEventMetric.eventReceived();
                 break;
                 break;
             case FAILED:
             case FAILED:
-                // TODO: Just ignore?
+                // ignore
                 break;
                 break;
             case WITHDRAW_REQ:
             case WITHDRAW_REQ:
                 intentWithdrawRequestedEventMetric.eventReceived();
                 intentWithdrawRequestedEventMetric.eventReceived();

@@ -129,7 +129,7 @@ public class HostMobility {
                     }
                     }
                 }
                 }
             }
             }
-            //TODO: handle ip cleanup
+
             return flowRules;
             return flowRules;
         }
         }
 
 

@@ -364,7 +364,6 @@ public class OpticalConfigProvider extends AbstractProvider implements DevicePro
 
 
     @Override
     @Override
     public void roleChanged(DeviceId device, MastershipRole newRole) {
     public void roleChanged(DeviceId device, MastershipRole newRole) {
-        // TODO Auto-generated method stub.
     }
     }
 
 
     @Override
     @Override

@@ -36,7 +36,6 @@ class PktOptLink {
     }
     }
 
 
     public PktOptLink() {
     public PktOptLink() {
-        // TODO Auto-generated constructor stub
     }
     }
 
 
     public void setSrcNodeName(String name) {
     public void setSrcNodeName(String name) {

@@ -37,7 +37,6 @@ class WdmLink {
     }
     }
 
 
     public WdmLink() {
     public WdmLink() {
-        // TODO Auto-generated constructor stub
     }
     }
 
 
     public void setSrcNodeName(String name) {
     public void setSrcNodeName(String name) {

@@ -49,13 +49,11 @@ public class MetricsListCommand extends AbstractShellCommand {
     protected void execute() {
     protected void execute() {
         MetricsService metricsService = get(MetricsService.class);
         MetricsService metricsService = get(MetricsService.class);
 
 
-        // TODO support filter condition
         MetricFilter filter = MetricFilter.ALL;
         MetricFilter filter = MetricFilter.ALL;
 
 
         TreeMultimap<String, Metric> matched = listMetrics(metricsService, filter);
         TreeMultimap<String, Metric> matched = listMetrics(metricsService, filter);
         matched.asMap().forEach((name, metrics) -> {
         matched.asMap().forEach((name, metrics) -> {
             for (Metric metric : metrics) {
             for (Metric metric : metrics) {
-                // TODO JSON version
                 printMetric(name, metric);
                 printMetric(name, metric);
             }
             }
         });
         });

@@ -17,11 +17,11 @@ package org.onosproject.cli;
 
 
 import org.apache.karaf.shell.commands.Argument;
 import org.apache.karaf.shell.commands.Argument;
 import org.apache.karaf.shell.commands.Command;
 import org.apache.karaf.shell.commands.Command;
+import org.onlab.packet.IpAddress;
 import org.onosproject.cluster.ControllerNode;
 import org.onosproject.cluster.ControllerNode;
 import org.onosproject.cluster.DefaultControllerNode;
 import org.onosproject.cluster.DefaultControllerNode;
 import org.onosproject.cluster.NodeId;
 import org.onosproject.cluster.NodeId;
 import org.onosproject.store.service.DatabaseAdminService;
 import org.onosproject.store.service.DatabaseAdminService;
-import org.onlab.packet.IpAddress;
 
 
 /**
 /**
  * Adds a new controller cluster node.
  * Adds a new controller cluster node.
@@ -34,7 +34,6 @@ public class TabletAddCommand extends AbstractShellCommand {
               required = true, multiValued = false)
               required = true, multiValued = false)
     String nodeId = null;
     String nodeId = null;
 
 
-    // TODO context aware completer to get IP from ClusterService?
     @Argument(index = 1, name = "ip", description = "Node IP address",
     @Argument(index = 1, name = "ip", description = "Node IP address",
               required = true, multiValued = false)
               required = true, multiValued = false)
     String ip = null;
     String ip = null;

@@ -30,7 +30,6 @@ import org.onosproject.net.topology.TopologyService;
          description = "Lists summary of the current topology")
          description = "Lists summary of the current topology")
 public class TopologyCommand extends AbstractShellCommand {
 public class TopologyCommand extends AbstractShellCommand {
 
 
-    // TODO: format the time-stamp
     private static final String FMT =
     private static final String FMT =
             "time=%s, devices=%d, links=%d, clusters=%d, paths=%d";
             "time=%s, devices=%d, links=%d, clusters=%d, paths=%d";
 
 

@@ -51,7 +51,6 @@ public class DefaultEventSinkRegistry implements EventSinkRegistry {
     @Override
     @Override
     @SuppressWarnings("unchecked")
     @SuppressWarnings("unchecked")
     public <E extends Event> EventSink<E> getSink(Class<E> eventClass) {
     public <E extends Event> EventSink<E> getSink(Class<E> eventClass) {
-        // TODO: add implicit registration of descendant classes
         return (EventSink<E>) sinks.get(eventClass);
         return (EventSink<E>) sinks.get(eventClass);
     }
     }
 
 

@@ -296,7 +296,6 @@ public class MastershipManager
         @Override
         @Override
         public void event(ClusterEvent event) {
         public void event(ClusterEvent event) {
             switch (event.type()) {
             switch (event.type()) {
-                //FIXME: worry about addition when the time comes
                 case INSTANCE_ADDED:
                 case INSTANCE_ADDED:
                 case INSTANCE_ACTIVATED:
                 case INSTANCE_ACTIVATED:
                     clusterSize.incrementAndGet();
                     clusterSize.incrementAndGet();
@@ -341,14 +340,9 @@ public class MastershipManager
             if (clusterService.getNodes().size() > (clusterSize.intValue() / 2)) {
             if (clusterService.getNodes().size() > (clusterSize.intValue() / 2)) {
                 return true;
                 return true;
             }
             }
-//            else {
-                //FIXME: break tie for equal-sized clusters, by number of
-                //       connected switches, then masters, then nodeId hash
-                //       problem is, how do we get at channel info cleanly here?
-                //       Also, what's the time hit for a distributed store look-up
-                //       versus channel re-negotiation? bet on the latter being worse.
-
-//            }
+
+             //FIXME: break tie for equal-sized clusters,
+
             return false;
             return false;
         }
         }
 
 

@@ -81,7 +81,6 @@ public class CoreManager implements CoreService {
 
 
     @Override
     @Override
     public IdGenerator getIdGenerator(String topic) {
     public IdGenerator getIdGenerator(String topic) {
-        // FIXME this should be created lazily (once per topic)
         IdBlockAllocator allocator = new StoreBasedIdBlockAllocator(topic, idBlockStore);
         IdBlockAllocator allocator = new StoreBasedIdBlockAllocator(topic, idBlockStore);
         return new BlockAllocatorBasedIdGenerator(allocator);
         return new BlockAllocatorBasedIdGenerator(allocator);
     }
     }

@@ -26,8 +26,6 @@ import org.projectfloodlight.openflow.types.OFPort;
  */
  */
 public interface OpenFlowPacketContext {
 public interface OpenFlowPacketContext {
 
 
-    //TODO: may want to support sending packet out other switches than
-    // the one it came in on.
     /**
     /**
      * Blocks further responses (ie. send() calls) on this
      * Blocks further responses (ie. send() calls) on this
      * packet in event.
      * packet in event.

@@ -275,8 +275,8 @@ public abstract class AbstractOpenFlowSwitch implements OpenFlowSwitchDriver {
                 this.transitionToEqualSwitch();
                 this.transitionToEqualSwitch();
             }
             }
         }  else {
         }  else {
+            log.warn("Failed to set role for {}", this.getStringId());
             return;
             return;
-            //TODO: tell people that we failed.
         }
         }
     }
     }
 
 

@@ -81,13 +81,9 @@ public class OpenflowControllerAdapter implements OpenFlowController {
 
 
     @Override
     @Override
     public void addEventListener(OpenFlowEventListener listener) {
     public void addEventListener(OpenFlowEventListener listener) {
-        // TODO Auto-generated method stub
-
     }
     }
 
 
     @Override
     @Override
     public void removeEventListener(OpenFlowEventListener listener) {
     public void removeEventListener(OpenFlowEventListener listener) {
-        // TODO Auto-generated method stub
-
     }
     }
 }
 }

@@ -137,7 +137,6 @@ public class OFOpticalSwitchImplLINC13 extends AbstractOpenFlowSwitch {
         }
         }
     }
     }
 
 
-    //Todo
     public void processOFPortStatus(OFCircuitPortStatus ps) {
     public void processOFPortStatus(OFCircuitPortStatus ps) {
         log.debug("LINC-OE ..OF Port Status :", ps);
         log.debug("LINC-OE ..OF Port Status :", ps);
 
 

@@ -672,9 +672,7 @@ public class OFSwitchImplCPqD13 extends AbstractOpenFlowSwitch {
             subnetIps.add("10.0.3.0");
             subnetIps.add("10.0.3.0");
             subnetIps.add("10.0.1.0");
             subnetIps.add("10.0.1.0");
         }
         }
-        // TODO needed?
-        //if (getId() == 0x2) {
-        //}
+
         if (getId() == 0x3) {
         if (getId() == 0x3) {
             subnetIps.add("7.7.7.0");
             subnetIps.add("7.7.7.0");
         }
         }
@@ -740,9 +738,6 @@ public class OFSwitchImplCPqD13 extends AbstractOpenFlowSwitch {
             hostNextHopIps.add(new RouteEntry("10.0.2.1", 4, "00:00:00:00:02:01"));
             hostNextHopIps.add(new RouteEntry("10.0.2.1", 4, "00:00:00:00:02:01"));
             hostNextHopIps.add(new RouteEntry("10.0.3.1", 5, "00:00:00:00:03:01"));
             hostNextHopIps.add(new RouteEntry("10.0.3.1", 5, "00:00:00:00:03:01"));
         }
         }
-        // TODO needed?
-        //if (getId() == 0x2) {
-        //}
         if (getId() == 0x3) {
         if (getId() == 0x3) {
             hostNextHopIps.add(new RouteEntry("7.7.7.7", 1, "00:00:07:07:07:07"));
             hostNextHopIps.add(new RouteEntry("7.7.7.7", 1, "00:00:07:07:07:07"));
         }
         }

@@ -152,7 +152,7 @@ public class LLDPLinkProvider extends AbstractProvider implements LinkProvider {
             }
             }
             synchronized (discoverers) {
             synchronized (discoverers) {
                 if (!discoverers.containsKey(deviceId)) {
                 if (!discoverers.containsKey(deviceId)) {
-                    // TODO: ideally, should never reach here
+                    // ideally, should never reach here
                     log.debug("Device mastership changed ({}) {}",
                     log.debug("Device mastership changed ({}) {}",
                             event.type(), deviceId);
                             event.type(), deviceId);
                     discoverers.put(deviceId, new LinkDiscovery(device,
                     discoverers.put(deviceId, new LinkDiscovery(device,
@@ -220,7 +220,7 @@ public class LLDPLinkProvider extends AbstractProvider implements LinkProvider {
                     ConnectPoint point = new ConnectPoint(deviceId,
                     ConnectPoint point = new ConnectPoint(deviceId,
                                                           port.number());
                                                           port.number());
                     providerService.linksVanished(point);
                     providerService.linksVanished(point);
-                    // TODO: Don't we need to removePort from ld?
+
                     break;
                     break;
                 case DEVICE_REMOVED:
                 case DEVICE_REMOVED:
                 case DEVICE_SUSPENDED:
                 case DEVICE_SUSPENDED:

@@ -344,7 +344,6 @@ public class LinkDiscovery implements TimerTask {
     }
     }
 
 
     private void sendProbes(Long portNumber) {
     private void sendProbes(Long portNumber) {
-        // TODO: should have suppression port configuration, not by type
         if (device.type() != Device.Type.ROADM) {
         if (device.type() != Device.Type.ROADM) {
             log.trace("Sending probes out to {}@{}", portNumber, device.id());
             log.trace("Sending probes out to {}@{}", portNumber, device.id());
             OutboundPacket pkt = this.createOutBoundLLDP(portNumber);
             OutboundPacket pkt = this.createOutBoundLLDP(portNumber);

@@ -271,8 +271,6 @@ public class LLDPLinkProviderTest {
 
 
         @Override
         @Override
         public void linkVanished(LinkDescription linkDescription) {
         public void linkVanished(LinkDescription linkDescription) {
-            // TODO Auto-generated method stub
-
         }
         }
 
 
         @Override
         @Override

@@ -137,18 +137,6 @@ public class OpenFlowDeviceProvider extends AbstractProvider implements DevicePr
             providerService.deviceDisconnected(deviceId);
             providerService.deviceDisconnected(deviceId);
         } else {
         } else {
             LOG.trace("Confirmed device {} connection", deviceId);
             LOG.trace("Confirmed device {} connection", deviceId);
-            // FIXME require something like below to match javadoc description
-            // but this starts infinite loop with current DeviceManager
-//            final ChassisId cId = new ChassisId(dpid.value());
-//            final Type deviceType = device.type();
-//            DeviceDescription description =
-//                    new DefaultDeviceDescription(deviceId.uri(), deviceType,
-//                                                 sw.manfacturerDescription(),
-//                                                 sw.hardwareDescription(),
-//                                                 sw.softwareDescription(),
-//                                                 sw.serialNumber(),
-//                                                 cId);
-//            providerService.deviceConnected(deviceId, description);
         }
         }
 
 
         // Prompt an update of port information. We can use any XID for this.
         // Prompt an update of port information. We can use any XID for this.
@@ -165,16 +153,6 @@ public class OpenFlowDeviceProvider extends AbstractProvider implements DevicePr
         }
         }
     }
     }
 
 
-    // Checks if the OF channel is connected.
-    //private boolean checkChannel(Device device, OpenFlowSwitch sw) {
-    // FIXME if possible, we might want this to be part of
-    // OpenFlowSwitch interface so the driver interface isn't misused.
-    //    if (sw == null || !((OpenFlowSwitchDriver) sw).isConnected()) {
-    //      return false;
-    //      }
-    //    return true;
-    // }
-
     @Override
     @Override
     public void roleChanged(DeviceId deviceId, MastershipRole newRole) {
     public void roleChanged(DeviceId deviceId, MastershipRole newRole) {
         switch (newRole) {
         switch (newRole) {

@@ -114,7 +114,7 @@ public class OpenFlowDeviceProviderTest {
 
 
     @Test
     @Test
     public void triggerProbe() {
     public void triggerProbe() {
-        // TODO
+
     }
     }
 
 
     @Test
     @Test

@@ -186,7 +186,6 @@ public class FlowEntryBuilder {
                 }
                 }
                 break;
                 break;
             case SET_FIELD:
             case SET_FIELD:
-                // TODO handle 1.3 set field actions correctly
                 break;
                 break;
             case SET_TP_DST:
             case SET_TP_DST:
             case SET_TP_SRC:
             case SET_TP_SRC:

@@ -78,7 +78,7 @@ public class FlowModBuilderVer10 extends FlowModBuilder {
 
 
         long cookie = flowRule().id().value();
         long cookie = flowRule().id().value();
 
 
-        //TODO: what to do without bufferid? do we assume that there will be a pktout as well?
+
         OFFlowAdd fm = factory().buildFlowAdd()
         OFFlowAdd fm = factory().buildFlowAdd()
                 .setXid(xid)
                 .setXid(xid)
                 .setCookie(U64.of(cookie))
                 .setCookie(U64.of(cookie))
@@ -99,7 +99,7 @@ public class FlowModBuilderVer10 extends FlowModBuilder {
 
 
         long cookie = flowRule().id().value();
         long cookie = flowRule().id().value();
 
 
-        //TODO: what to do without bufferid? do we assume that there will be a pktout as well?
+
         OFFlowMod fm = factory().buildFlowModify()
         OFFlowMod fm = factory().buildFlowModify()
                 .setXid(xid)
                 .setXid(xid)
                 .setCookie(U64.of(cookie))
                 .setCookie(U64.of(cookie))

@@ -93,7 +93,7 @@ public class FlowModBuilderVer13 extends FlowModBuilder {
 
 
         long cookie = flowRule().id().value();
         long cookie = flowRule().id().value();
 
 
-        //TODO: what to do without bufferid? do we assume that there will be a pktout as well?
+
         OFFlowAdd fm = factory().buildFlowAdd()
         OFFlowAdd fm = factory().buildFlowAdd()
                 .setXid(xid)
                 .setXid(xid)
                 .setCookie(U64.of(cookie))
                 .setCookie(U64.of(cookie))
@@ -117,7 +117,7 @@ public class FlowModBuilderVer13 extends FlowModBuilder {
 
 
         long cookie = flowRule().id().value();
         long cookie = flowRule().id().value();
 
 
-        //TODO: what to do without bufferid? do we assume that there will be a pktout as well?
+
         OFFlowMod fm = factory().buildFlowModify()
         OFFlowMod fm = factory().buildFlowModify()
                 .setXid(xid)
                 .setXid(xid)
                 .setCookie(U64.of(cookie))
                 .setCookie(U64.of(cookie))
@@ -145,8 +145,6 @@ public class FlowModBuilderVer13 extends FlowModBuilder {
                 .setXid(xid)
                 .setXid(xid)
                 .setCookie(U64.of(cookie))
                 .setCookie(U64.of(cookie))
                 .setBufferId(OFBufferId.NO_BUFFER)
                 .setBufferId(OFBufferId.NO_BUFFER)
-                //.setActions(actions) //FIXME do we want to send actions in flowdel?
-                //.setInstructions(Collections.singletonList(writeActions))
                 .setMatch(match)
                 .setMatch(match)
                 .setFlags(Collections.singleton(OFFlowModFlags.SEND_FLOW_REM))
                 .setFlags(Collections.singleton(OFFlowModFlags.SEND_FLOW_REM))
                 .setPriority(flowRule().priority())
                 .setPriority(flowRule().priority())

@@ -142,7 +142,6 @@ public class OpenFlowHostProvider extends AbstractProvider implements HostProvid
 
 
             }
             }
 
 
-            // TODO: Use DHCP packets as well later...
         }
         }
 
 
     }
     }

@@ -258,8 +258,6 @@ public class OpenFlowLinkProviderTest {
 
 
         @Override
         @Override
         public void linkVanished(LinkDescription linkDescription) {
         public void linkVanished(LinkDescription linkDescription) {
-            // TODO Auto-generated method stub
-
         }
         }
 
 
         @Override
         @Override

@@ -111,7 +111,6 @@ implements MutableGraph<V, E> {
 
 
     @Override
     @Override
     public void removeVertex(V vertex) {
     public void removeVertex(V vertex) {
-        // TODO Auto-generated method stub
         if (vertexes != null && edges != null) {
         if (vertexes != null && edges != null) {
             if (vertexes.contains(vertex)) {
             if (vertexes.contains(vertex)) {
                 vertexes.remove(vertex);
                 vertexes.remove(vertex);
@@ -149,7 +148,6 @@ implements MutableGraph<V, E> {
 
 
     @Override
     @Override
     public Graph<V, E> toImmutable() {
     public Graph<V, E> toImmutable() {
-        // TODO Auto-generated method stub
         return null;
         return null;
     }
     }
 
 

@@ -118,9 +118,7 @@ public abstract class BasePacket implements IPacket {
         } catch (final Exception e) {
         } catch (final Exception e) {
             throw new RuntimeException("Could not clone packet");
             throw new RuntimeException("Could not clone packet");
         }
         }
-        // TODO: we are using serialize()/deserialize() to perform the
-        // cloning. Not the most efficient way but simple. We can revisit
-        // if we hit performance problems.
+
         final byte[] data = this.serialize();
         final byte[] data = this.serialize();
         pkt.deserialize(this.serialize(), 0, data.length);
         pkt.deserialize(this.serialize(), 0, data.length);
         pkt.setParent(this.parent);
         pkt.setParent(this.parent);

@@ -19,7 +19,6 @@ package org.onlab.packet;
  * The class representing a network device chassisId.
  * The class representing a network device chassisId.
  * This class is immutable.
  * This class is immutable.
  */
  */
-// TODO: Move this to a reasonable place.
 public final class ChassisId {
 public final class ChassisId {
 
 
     private static final long UNKNOWN = 0;
     private static final long UNKNOWN = 0;

@@ -262,7 +262,6 @@ public class IpAddress implements Comparable<IpAddress> {
      */
      */
     public static IpAddress makeMaskedAddress(final IpAddress address,
     public static IpAddress makeMaskedAddress(final IpAddress address,
                                               int prefixLength) {
                                               int prefixLength) {
-        // TODO: The code below should go away and replaced with generics
         if (address instanceof Ip4Address) {
         if (address instanceof Ip4Address) {
             Ip4Address ip4a = (Ip4Address) address;
             Ip4Address ip4a = (Ip4Address) address;
             return Ip4Address.makeMaskedAddress(ip4a, prefixLength);
             return Ip4Address.makeMaskedAddress(ip4a, prefixLength);

@@ -86,7 +86,6 @@ public class NettyMessagingService implements MessagingService {
 
 
     private void initEventLoopGroup() {
     private void initEventLoopGroup() {
         // try Epoll first and if that does work, use nio.
         // try Epoll first and if that does work, use nio.
-        // TODO: make this configurable.
         try {
         try {
             clientGroup = new EpollEventLoopGroup();
             clientGroup = new EpollEventLoopGroup();
             serverGroup = new EpollEventLoopGroup();
             serverGroup = new EpollEventLoopGroup();
@@ -107,11 +106,9 @@ public class NettyMessagingService implements MessagingService {
     }
     }
 
 
     public NettyMessagingService() {
     public NettyMessagingService() {
-        // TODO: Default port should be configurable.
         this(8080);
         this(8080);
     }
     }
 
 
-    // FIXME: Constructor should not throw exceptions.
     public NettyMessagingService(int port) {
     public NettyMessagingService(int port) {
         try {
         try {
             localEp = new Endpoint(java.net.InetAddress.getLocalHost().getHostName(), port);
             localEp = new Endpoint(java.net.InetAddress.getLocalHost().getHostName(), port);
@@ -193,7 +190,6 @@ public class NettyMessagingService implements MessagingService {
 
 
     @Override
     @Override
     public void registerHandler(String type, MessageHandler handler) {
     public void registerHandler(String type, MessageHandler handler) {
-        // TODO: Is this the right semantics for handler registration?
         handlers.putIfAbsent(type, handler);
         handlers.putIfAbsent(type, handler);
     }
     }
 
 
@@ -210,7 +206,6 @@ public class NettyMessagingService implements MessagingService {
         ServerBootstrap b = new ServerBootstrap();
         ServerBootstrap b = new ServerBootstrap();
         b.option(ChannelOption.WRITE_BUFFER_HIGH_WATER_MARK, 32 * 1024);
         b.option(ChannelOption.WRITE_BUFFER_HIGH_WATER_MARK, 32 * 1024);
         b.option(ChannelOption.WRITE_BUFFER_LOW_WATER_MARK, 8 * 1024);
         b.option(ChannelOption.WRITE_BUFFER_LOW_WATER_MARK, 8 * 1024);
-        // TODO: Need JVM options to configure PooledByteBufAllocator.
         b.option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT);
         b.option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT);
         b.group(serverGroup, clientGroup)
         b.group(serverGroup, clientGroup)
             .channel(serverChannelClass)
             .channel(serverChannelClass)

@@ -19,7 +19,7 @@ package org.onlab.thirdparty;
 /**
 /**
  * Empty class required to get the onlab-thirdparty module to build properly.
  * Empty class required to get the onlab-thirdparty module to build properly.
  *
  *
- * TODO Figure out how to remove this.
+ * NOTE Required for shade plugin to operate.
  */
  */
 public class OnlabThirdparty {
 public class OnlabThirdparty {
 
 

@@ -54,7 +54,6 @@ import org.onosproject.net.intent.MultiPointToSinglePointIntent;
 import org.onosproject.net.link.LinkEvent;
 import org.onosproject.net.link.LinkEvent;
 import org.onosproject.net.link.LinkListener;
 import org.onosproject.net.link.LinkListener;
 import org.onlab.osgi.ServiceDirectory;
 import org.onlab.osgi.ServiceDirectory;
-import org.onlab.packet.Ethernet;
 
 
 import java.io.IOException;
 import java.io.IOException;
 import java.util.ArrayList;
 import java.util.ArrayList;
@@ -369,7 +368,6 @@ public class TopologyViewWebSocket
 
 
         // FIXME: clearly, this is not enough
         // FIXME: clearly, this is not enough
         TrafficSelector selector = DefaultTrafficSelector.builder()
         TrafficSelector selector = DefaultTrafficSelector.builder()
-                .matchEthType(Ethernet.TYPE_IPV4)
                 .matchEthDst(dstHost.mac()).build();
                 .matchEthDst(dstHost.mac()).build();
         TrafficTreatment treatment = DefaultTrafficTreatment.builder().build();
         TrafficTreatment treatment = DefaultTrafficTreatment.builder().build();