Fix for wipe-out please command ONOS-4653

Change-Id: I26c841f2d67bc915b7e02e6d1e792a7e2d9ea329

@@ -21,11 +21,18 @@ import org.onosproject.net.Device;
 import org.onosproject.net.Host;
 import org.onosproject.net.Host;
 import org.onosproject.net.Link;
 import org.onosproject.net.Link;
 import org.onosproject.net.device.DeviceAdminService;
 import org.onosproject.net.device.DeviceAdminService;
+import org.onosproject.net.flow.FlowRuleService;
+import org.onosproject.net.group.GroupService;
 import org.onosproject.net.host.HostAdminService;
 import org.onosproject.net.host.HostAdminService;
 import org.onosproject.net.intent.Intent;
 import org.onosproject.net.intent.Intent;
 import org.onosproject.net.intent.IntentService;
 import org.onosproject.net.intent.IntentService;
 import org.onosproject.net.intent.IntentState;
 import org.onosproject.net.intent.IntentState;
 import org.onosproject.net.link.LinkAdminService;
 import org.onosproject.net.link.LinkAdminService;
+import java.util.EnumSet;
+import java.util.concurrent.CountDownLatch;
+import java.util.concurrent.TimeUnit;
+import static org.onosproject.net.intent.IntentState.FAILED;
+import static org.onosproject.net.intent.IntentState.WITHDRAWN;
 
 
 /**
 /**
  * Wipes-out the entire network information base, i.e. devices, links, hosts, intents.
  * Wipes-out the entire network information base, i.e. devices, links, hosts, intents.
@@ -35,7 +42,7 @@ import org.onosproject.net.link.LinkAdminService;
 public class WipeOutCommand extends ClustersListCommand {
 public class WipeOutCommand extends ClustersListCommand {
 
 
     private static final String PLEASE = "please";
     private static final String PLEASE = "please";
-
+    private static final EnumSet<IntentState> CAN_PURGE = EnumSet.of(WITHDRAWN, FAILED);
     @Argument(index = 0, name = "please", description = "Confirmation phrase",
     @Argument(index = 0, name = "please", description = "Confirmation phrase",
             required = false, multiValued = false)
             required = false, multiValued = false)
     String please = null;
     String please = null;
@@ -49,6 +56,8 @@ public class WipeOutCommand extends ClustersListCommand {
 
 
         wipeOutIntents();
         wipeOutIntents();
         wipeOutHosts();
         wipeOutHosts();
+        wipeOutFlows();
+        wipeOutGroups();
         wipeOutDevices();
         wipeOutDevices();
         wipeOutLinks();
         wipeOutLinks();
     }
     }
@@ -56,13 +65,40 @@ public class WipeOutCommand extends ClustersListCommand {
     private void wipeOutIntents() {
     private void wipeOutIntents() {
         print("Wiping intents");
         print("Wiping intents");
         IntentService intentService = get(IntentService.class);
         IntentService intentService = get(IntentService.class);
+        final CountDownLatch withdrawLatch;
+        withdrawLatch = new CountDownLatch(1);
         for (Intent intent : intentService.getIntents()) {
         for (Intent intent : intentService.getIntents()) {
             if (intentService.getIntentState(intent.key()) != IntentState.WITHDRAWN) {
             if (intentService.getIntentState(intent.key()) != IntentState.WITHDRAWN) {
                 intentService.withdraw(intent);
                 intentService.withdraw(intent);
+                try { // wait for withdraw event
+                    withdrawLatch.await(5, TimeUnit.SECONDS);
+                } catch (InterruptedException e) {
+                    print("Timed out waiting for intent {} withdraw");
+                }
             }
             }
+                if (CAN_PURGE.contains(intentService.getIntentState(intent.key()))) {
                     intentService.purge(intent);
                     intentService.purge(intent);
                 }
                 }
             }
             }
+        }
+
+    private void wipeOutFlows() {
+        print("Wiping Flows");
+        FlowRuleService flowRuleService = get(FlowRuleService.class);
+        DeviceAdminService deviceAdminService = get(DeviceAdminService.class);
+        for (Device device : deviceAdminService.getDevices()) {
+            flowRuleService.purgeFlowRules(device.id());
+        }
+    }
+
+    private void wipeOutGroups() {
+        print("Wiping groups");
+        GroupService groupService = get(GroupService.class);
+        DeviceAdminService deviceAdminService = get(DeviceAdminService.class);
+        for (Device device : deviceAdminService.getDevices()) {
+            groupService.purgeGroupEntries(device.id());
+        }
+    }
 
 
     private void wipeOutHosts() {
     private void wipeOutHosts() {
         print("Wiping hosts");
         print("Wiping hosts");

@@ -61,6 +61,12 @@ public interface FlowRuleService
     void applyFlowRules(FlowRule... flowRules);
     void applyFlowRules(FlowRule... flowRules);
 
 
     /**
     /**
+     * Purges all the flow rules on the specified device.
+     * @param deviceId device identifier
+     */
+    void purgeFlowRules(DeviceId deviceId);
+
+    /**
      * Removes the specified flow rules from their respective devices. If the
      * Removes the specified flow rules from their respective devices. If the
      * device is not presently connected to the controller, these flow will
      * device is not presently connected to the controller, these flow will
      * be removed once the device reconnects.
      * be removed once the device reconnects.

@@ -107,6 +107,12 @@ public interface GroupService
                                 ApplicationId appId);
                                 ApplicationId appId);
 
 
     /**
     /**
+     * Purges all the group entries on the specified device.
+     * @param deviceId device identifier
+     */
+    void purgeGroupEntries(DeviceId deviceId);
+
+    /**
      * Deletes a group associated to an application cookie.
      * Deletes a group associated to an application cookie.
      * GROUP_DELETED or GROUP_DELETE_FAILED notifications would be
      * GROUP_DELETED or GROUP_DELETE_FAILED notifications would be
      * provided along with cookie depending on the result of the
      * provided along with cookie depending on the result of the

@@ -38,6 +38,10 @@ public class FlowRuleServiceAdapter implements FlowRuleService {
     }
     }
 
 
     @Override
     @Override
+    public void purgeFlowRules(DeviceId deviceId){
+    }
+
+    @Override
     public void removeFlowRules(FlowRule... flowRules) {
     public void removeFlowRules(FlowRule... flowRules) {
     }
     }
 
 

@@ -244,6 +244,12 @@ public class FlowRuleManager
     }
     }
 
 
     @Override
     @Override
+    public void purgeFlowRules(DeviceId deviceId) {
+        checkPermission(FLOWRULE_WRITE);
+        store.purgeFlowRule(deviceId);
+    }
+
+    @Override
     public void removeFlowRules(FlowRule... flowRules) {
     public void removeFlowRules(FlowRule... flowRules) {
         checkPermission(FLOWRULE_WRITE);
         checkPermission(FLOWRULE_WRITE);
 
 

@@ -224,6 +224,13 @@ public class GroupManager
                                      newCookie);
                                      newCookie);
     }
     }
 
 
+    @Override
+    public void purgeGroupEntries(DeviceId deviceId) {
+        checkPermission(GROUP_WRITE);
+        store.purgeGroupEntry(deviceId);
+    }
+
+
     /**
     /**
      * Delete a group associated to an application cookie.
      * Delete a group associated to an application cookie.
      * GROUP_DELETED or GROUP_DELETE_FAILED notifications would be
      * GROUP_DELETED or GROUP_DELETE_FAILED notifications would be

@@ -260,6 +260,22 @@ public class FlowRuleManagerTest {
     }
     }
 
 
     @Test
     @Test
+    public void purgeFlowRules() {
+        FlowRule f1 = addFlowRule(1);
+        FlowRule f2 = addFlowRule(2);
+        FlowRule f3 = addFlowRule(3);
+        assertEquals("3 rules should exist", 3, flowCount());
+        FlowEntry fe1 = new DefaultFlowEntry(f1);
+        FlowEntry fe2 = new DefaultFlowEntry(f2);
+        FlowEntry fe3 = new DefaultFlowEntry(f3);
+        providerService.pushFlowMetrics(DID, ImmutableList.of(fe1, fe2, fe3));
+        validateEvents(RULE_ADD_REQUESTED, RULE_ADD_REQUESTED, RULE_ADD_REQUESTED,
+                RULE_ADDED, RULE_ADDED, RULE_ADDED);
+        mgr.purgeFlowRules(DID);
+        assertEquals("0 rule should exist", 0, flowCount());
+    }
+
+    @Test
     public void removeFlowRules() {
     public void removeFlowRules() {
         FlowRule f1 = addFlowRule(1);
         FlowRule f1 = addFlowRule(1);
         FlowRule f2 = addFlowRule(2);
         FlowRule f2 = addFlowRule(2);

@@ -188,6 +188,21 @@ public class GroupManagerTest {
     }
     }
 
 
     /**
     /**
+     * Tests group Purge Operation.
+     */
+    @Test
+    public void testPurgeGroups() {
+        //Test Group creation before AUDIT process
+        testGroupCreationBeforeAudit(DID);
+        programmableTestCleanUp();
+        testAuditWithExtraneousMissingGroups(DID);
+        // Test group add bucket operations
+        testAddBuckets(DID);
+        // Test group Purge operations
+        testPurgeGroupEntry(DID);
+    }
+
+    /**
      * Tests group bucket modifications (additions and deletions) and
      * Tests group bucket modifications (additions and deletions) and
      * Tests group deletion.
      * Tests group deletion.
      */
      */
@@ -507,6 +522,13 @@ public class GroupManagerTest {
         internalListener.validateEvent(Collections.singletonList(GroupEvent.Type.GROUP_UPDATED));
         internalListener.validateEvent(Collections.singletonList(GroupEvent.Type.GROUP_UPDATED));
     }
     }
 
 
+    // Test purge group entry operations
+    private void testPurgeGroupEntry(DeviceId deviceId) {
+        assertEquals(1, Iterables.size(groupService.getGroups(deviceId, appId)));
+        groupService.purgeGroupEntries(deviceId);
+        assertEquals(0, Iterables.size(groupService.getGroups(deviceId, appId)));
+    }
+
     // Test group remove operations
     // Test group remove operations
     private void testRemoveGroup(DeviceId deviceId) {
     private void testRemoveGroup(DeviceId deviceId) {
         GroupKey currKey = new DefaultGroupKey("group1RemoveBuckets".getBytes());
         GroupKey currKey = new DefaultGroupKey("group1RemoveBuckets".getBytes());