Ooops... missed a few comments when merging Aaron's change. Sorry about that.
Change-Id: I9a4e2aac928b276f38777deeb144f80e68ff5fca
diff --git a/apps/reactive-routing/src/main/java/org/onosproject/reactive/routing/SdnIpReactiveRouting.java b/apps/reactive-routing/src/main/java/org/onosproject/reactive/routing/SdnIpReactiveRouting.java
index fedfbbb..e818b41 100644
--- a/apps/reactive-routing/src/main/java/org/onosproject/reactive/routing/SdnIpReactiveRouting.java
+++ b/apps/reactive-routing/src/main/java/org/onosproject/reactive/routing/SdnIpReactiveRouting.java
@@ -84,8 +84,7 @@
@Activate
public void activate() {
appId = coreService.registerApplication(APP_NAME);
- packetService.addProcessor(processor,
- PacketProcessor.ADVISOR_MAX + 2);
+ packetService.addProcessor(processor, PacketProcessor.ADVISOR_MAX + 2);
requestIntercepts();
log.info("SDN-IP Reactive Routing Started");
}
@@ -105,11 +104,9 @@
//TODO: to support IPv6 later
TrafficSelector.Builder selector = DefaultTrafficSelector.builder();
selector.matchEthType(TYPE_IPV4);
- packetService.requestPackets(selector.build(),
- REACTIVE, appId);
+ packetService.requestPackets(selector.build(), REACTIVE, appId);
selector.matchEthType(TYPE_ARP);
- packetService.requestPackets(selector.build(),
- REACTIVE, appId);
+ packetService.requestPackets(selector.build(), REACTIVE, appId);
}
/**
@@ -118,12 +115,10 @@
private void withdrawIntercepts() {
TrafficSelector.Builder selector = DefaultTrafficSelector.builder();
selector.matchEthType(TYPE_IPV4);
- packetService.requestPackets(selector.build(),
- REACTIVE, appId);
+ packetService.cancelPackets(selector.build(), REACTIVE, appId);
selector = DefaultTrafficSelector.builder();
selector.matchEthType(TYPE_ARP);
- packetService.requestPackets(selector.build(),
- REACTIVE, appId);
+ packetService.cancelPackets(selector.build(), REACTIVE, appId);
}
private class ReactiveRoutingProcessor implements PacketProcessor {