2 * Copyright (c) 2015 Inocybe and others. All rights reserved.
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
9 package org.opendaylight.ovsdb.openstack.netvirt.impl;
11 import static org.junit.Assume.*;
12 import static org.junit.Assert.assertEquals;
13 import static org.junit.Assert.assertNotEquals;
14 import static org.junit.Assert.assertNull;
15 import static org.mockito.Mockito.mock;
16 import static org.mockito.Mockito.when;
18 import java.lang.reflect.Field;
19 import java.util.Random;
20 import java.util.concurrent.BlockingQueue;
22 import org.junit.Before;
23 import org.junit.Test;
24 import org.junit.runner.RunWith;
25 import org.mockito.InjectMocks;
26 import org.mockito.Mock;
27 import org.opendaylight.ovsdb.openstack.netvirt.AbstractEvent;
28 import org.opendaylight.ovsdb.openstack.netvirt.AbstractHandler;
29 import org.opendaylight.ovsdb.openstack.netvirt.api.Constants;
30 import org.opendaylight.ovsdb.utils.servicehelper.ServiceHelper;
31 import org.osgi.framework.ServiceReference;
32 import org.powermock.core.classloader.annotations.PrepareForTest;
33 import org.powermock.modules.junit4.PowerMockRunner;
36 * Unit test for {@link EventDispatcherImpl}
38 @RunWith(PowerMockRunner.class)
39 @PrepareForTest(ServiceHelper.class)
40 public class EventDispatcherImplTest {
42 @InjectMocks private EventDispatcherImpl eventDispatcherImpl;
44 @Mock private AbstractHandler handler;
45 @Mock private ServiceReference<?> ref;
47 private AbstractEvent.HandlerType handlerTypeObject = AbstractEvent.HandlerType.NEUTRON_FLOATING_IP;
51 Random r = new Random();
53 eventDispatcherImpl.start();
55 when(ref.getProperty(org.osgi.framework.Constants.SERVICE_ID)).thenReturn(r.nextLong());
56 when(ref.getProperty(Constants.EVENT_HANDLER_TYPE_PROPERTY)).thenReturn(handlerTypeObject);
60 * Test methods {@link EventDispatcherImpl#eventHandlerRemoved(ServiceReference)}
61 * and {@link EventDispatcherImpl#eventHandlerAdded(ServiceReference, AbstractHandler)}
64 public void testHandlerAddedAndRemoved() throws Exception{
65 AbstractHandler[] handlers = ( AbstractHandler[]) getField("handlers");
67 assertNotEquals("Error, handler should be null", handlers[handlerTypeObject.ordinal()], handler);
69 eventDispatcherImpl.eventHandlerAdded(ref, handler);
71 assertEquals("Error, did not return the added handler", handlers[handlerTypeObject.ordinal()], handler);
73 eventDispatcherImpl.eventHandlerRemoved(ref);
75 assertNull("Error, handler should be null as it has just been removed", handlers[handlerTypeObject.ordinal()]);
79 * Test method {@link EventDispatcherImpl#enqueueEvent(AbstractEvent)}
81 @SuppressWarnings("unchecked")
83 public void testEnqueueEvent() throws Exception{
84 BlockingQueue<AbstractEvent> events = (BlockingQueue<AbstractEvent>) getField("events");
86 assertEquals("Error, did not return the expected size, nothing has been added yet", 0, events.size());
88 eventDispatcherImpl.enqueueEvent(mock(AbstractEvent.class));
89 eventDispatcherImpl.enqueueEvent(mock(AbstractEvent.class));
90 eventDispatcherImpl.enqueueEvent(mock(AbstractEvent.class));
91 eventDispatcherImpl.enqueueEvent(mock(AbstractEvent.class));
93 assumeTrue("Error, did not return the expected size", 4 == events.size());
96 private Object getField(String fieldName) throws Exception {
97 Field field = EventDispatcherImpl.class.getDeclaredField(fieldName);
98 field.setAccessible(true);
99 return field.get(eventDispatcherImpl);