Revert "Fix statistics race condition on big flows"
[openflowplugin.git] / openflowplugin-impl / src / test / java / org / opendaylight / openflowplugin / impl / registry / group / DeviceGroupRegistryImplTest.java
1 /*
2  * Copyright (c) 2015 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
9 package org.opendaylight.openflowplugin.impl.registry.group;
10
11 import org.junit.Assert;
12 import org.junit.Before;
13 import org.junit.Test;
14 import org.opendaylight.yang.gen.v1.urn.opendaylight.group.types.rev131018.GroupId;
15
16 /**
17  * Test for {@link DeviceGroupRegistryImpl}.
18  */
19 public class DeviceGroupRegistryImplTest {
20
21     private GroupId groupId;
22     private GroupId groupId2;
23     private DeviceGroupRegistryImpl deviceGroupRegistry;
24
25     @Before
26     public void setUp() throws Exception {
27         deviceGroupRegistry = new DeviceGroupRegistryImpl();
28         groupId = new GroupId(42L);
29         groupId2 = new GroupId(84L);
30         Assert.assertEquals(0, deviceGroupRegistry.getAllGroupIds().size());
31         deviceGroupRegistry.store(groupId);
32         Assert.assertEquals(1, deviceGroupRegistry.getAllGroupIds().size());
33     }
34
35     @Test
36     public void testStore() throws Exception {
37         deviceGroupRegistry.store(groupId2);
38         Assert.assertEquals(2, deviceGroupRegistry.getAllGroupIds().size());
39     }
40
41     @Test
42     public void testRemoveMarked() throws Exception {
43         deviceGroupRegistry.markToBeremoved(groupId);
44         deviceGroupRegistry.removeMarked();
45         Assert.assertEquals(0, deviceGroupRegistry.getAllGroupIds().size());
46     }
47
48     @Test
49     public void testRemoveMarkedNegative() throws Exception {
50         deviceGroupRegistry.markToBeremoved(groupId2);
51         deviceGroupRegistry.removeMarked();
52         Assert.assertEquals(1, deviceGroupRegistry.getAllGroupIds().size());
53     }
54
55
56     @Test
57     public void testClose() throws Exception {
58         deviceGroupRegistry.markToBeremoved(groupId);
59         deviceGroupRegistry.close();
60
61         Assert.assertEquals(0, deviceGroupRegistry.getAllGroupIds().size());
62         deviceGroupRegistry.store(groupId);
63         Assert.assertEquals(1, deviceGroupRegistry.getAllGroupIds().size());
64         deviceGroupRegistry.removeMarked();
65         Assert.assertEquals(1, deviceGroupRegistry.getAllGroupIds().size());
66
67     }
68 }