2 * Copyright (c) 2017 Pantheon Technologies s.r.o. 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.openflowplugin.impl.configuration;
11 import static org.junit.Assert.assertEquals;
12 import static org.junit.Assert.assertNotEquals;
13 import static org.mockito.ArgumentMatchers.any;
14 import static org.mockito.Mockito.times;
15 import static org.mockito.Mockito.verify;
16 import static org.mockito.Mockito.when;
18 import com.google.common.collect.ImmutableMap;
19 import java.util.Hashtable;
21 import org.junit.Before;
22 import org.junit.Test;
23 import org.junit.runner.RunWith;
24 import org.mockito.Mock;
25 import org.mockito.runners.MockitoJUnitRunner;
26 import org.opendaylight.openflowplugin.api.openflow.configuration.ConfigurationListener;
27 import org.opendaylight.openflowplugin.api.openflow.configuration.ConfigurationProperty;
28 import org.opendaylight.openflowplugin.api.openflow.configuration.ConfigurationService;
29 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.openflow.provider.config.rev160510.NonZeroUint16Type;
30 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.openflow.provider.config.rev160510.NonZeroUint32Type;
31 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.openflow.provider.config.rev160510.OpenflowProviderConfig;
32 import org.opendaylight.yangtools.yang.common.Uint16;
33 import org.opendaylight.yangtools.yang.common.Uint32;
35 @RunWith(MockitoJUnitRunner.class)
36 public class ConfigurationServiceFactoryImplTest {
37 private static final int CONFIG_PROP_COUNT = 24;
38 private static final boolean IS_STATISTICS_POLLING_ON = true;
39 private static final int BARRIER_COUNT_LIMIT = 2000;
40 private static final long BARRIER_INTERVAL_TIMEOUT_LIMIT = 3000;
41 private static final long ECHO_REPLY_TIMEOUT = 4000;
42 private static final boolean ENABLE_FLOW_REMOVED_NOTIFICATION = true;
43 private static final boolean SKIP_TABLE_FEATURES = true;
44 private static final long BASIC_TIMER_DELAY = 2690;
45 private static final long MAXIMUM_TIMER_DELAY = 3679;
46 private static final boolean SWITCH_FEATURES_MANDATORY = false;
47 private static final boolean IS_STATISTICS_RPC_ENABLED = false;
48 private static final boolean USE_SINGLE_LAYER_SERIALIZATION = true;
49 private static final int RPC_REQUESTS_QUOTA = 2500;
50 private static final Uint32 GLOBAL_NOTIFICATION_QUOTA = Uint32.valueOf(9000);
51 private static final Uint16 THREAD_POOL_MIN_THREADS = Uint16.valueOf(3);
52 private static final int THREAD_POOL_MIN_THREADS_UPDATE = 4;
53 private static final int THREAD_POOL_MAX_THREADS = 1000;
54 private static final Uint32 THREAD_POOL_TIMEOUT = Uint32.valueOf(60);
55 private static final Uint16 DEVICE_CONNECTION_RATE_LIMIT_PER_MIN = Uint16.ZERO;
56 private static final Uint16 DEVICE_CONNECTION_HOLD_TIME_IN_SECONDS = Uint16.valueOf(60);
59 private OpenflowProviderConfig config;
62 private ConfigurationListener configurationListener;
64 private ConfigurationService configurationService;
68 when(config.isIsStatisticsPollingOn()).thenReturn(IS_STATISTICS_POLLING_ON);
69 when(config.isIsFlowStatisticsPollingOn()).thenReturn(IS_STATISTICS_POLLING_ON);
70 when(config.isIsTableStatisticsPollingOn()).thenReturn(IS_STATISTICS_POLLING_ON);
71 when(config.isIsFlowStatisticsPollingOn()).thenReturn(IS_STATISTICS_POLLING_ON);
72 when(config.isIsGroupStatisticsPollingOn()).thenReturn(IS_STATISTICS_POLLING_ON);
73 when(config.isIsMeterStatisticsPollingOn()).thenReturn(IS_STATISTICS_POLLING_ON);
74 when(config.isIsQueueStatisticsPollingOn()).thenReturn(IS_STATISTICS_POLLING_ON);
75 when(config.isIsPortStatisticsPollingOn()).thenReturn(IS_STATISTICS_POLLING_ON);
76 when(config.getBarrierCountLimit()).thenReturn(new NonZeroUint16Type(BARRIER_COUNT_LIMIT));
77 when(config.getBarrierIntervalTimeoutLimit()).thenReturn(new NonZeroUint32Type(BARRIER_INTERVAL_TIMEOUT_LIMIT));
78 when(config.getEchoReplyTimeout()).thenReturn(new NonZeroUint32Type(ECHO_REPLY_TIMEOUT));
79 when(config.isEnableFlowRemovedNotification()).thenReturn(ENABLE_FLOW_REMOVED_NOTIFICATION);
80 when(config.isSkipTableFeatures()).thenReturn(SKIP_TABLE_FEATURES);
81 when(config.getBasicTimerDelay()).thenReturn(new NonZeroUint32Type(BASIC_TIMER_DELAY));
82 when(config.getMaximumTimerDelay()).thenReturn(new NonZeroUint32Type(MAXIMUM_TIMER_DELAY));
83 when(config.isSwitchFeaturesMandatory()).thenReturn(SWITCH_FEATURES_MANDATORY);
84 when(config.isIsStatisticsRpcEnabled()).thenReturn(IS_STATISTICS_RPC_ENABLED);
85 when(config.isUseSingleLayerSerialization()).thenReturn(USE_SINGLE_LAYER_SERIALIZATION);
86 when(config.getRpcRequestsQuota()).thenReturn(new NonZeroUint16Type(RPC_REQUESTS_QUOTA));
87 when(config.getGlobalNotificationQuota()).thenReturn(GLOBAL_NOTIFICATION_QUOTA);
88 when(config.getThreadPoolMinThreads()).thenReturn(THREAD_POOL_MIN_THREADS);
89 when(config.getThreadPoolMaxThreads()).thenReturn(new NonZeroUint16Type(THREAD_POOL_MAX_THREADS));
90 when(config.getThreadPoolTimeout()).thenReturn(THREAD_POOL_TIMEOUT);
91 when(config.getDeviceConnectionRateLimitPerMin()).thenReturn(DEVICE_CONNECTION_RATE_LIMIT_PER_MIN);
92 when(config.getDeviceConnectionHoldTimeInSeconds()).thenReturn(DEVICE_CONNECTION_HOLD_TIME_IN_SECONDS);
94 final Map<String, String> properties = new Hashtable<>();
95 properties.put(ConfigurationProperty.IS_STATISTICS_POLLING_ON.toString(),
96 Boolean.toString(IS_STATISTICS_POLLING_ON));
98 configurationService = new ConfigurationServiceFactoryImpl().newInstance(config);
99 configurationService.update(properties);
103 public void update() {
104 final int tpMinThreads = configurationService
105 .getProperty(ConfigurationProperty.THREAD_POOL_MIN_THREADS.toString(), Integer::valueOf);
107 configurationService.update(ImmutableMap
108 .<String, String>builder()
109 .put(ConfigurationProperty.THREAD_POOL_MIN_THREADS.toString(), String
110 .valueOf(THREAD_POOL_MIN_THREADS_UPDATE))
113 final int tpMinThreadsNew = configurationService
114 .getProperty(ConfigurationProperty.THREAD_POOL_MIN_THREADS.toString(), Integer::valueOf);
116 assertNotEquals(tpMinThreadsNew, tpMinThreads);
117 assertEquals(tpMinThreadsNew, THREAD_POOL_MIN_THREADS_UPDATE);
121 public void getProperty() {
122 final int tpMaxThreads = configurationService
123 .getProperty(ConfigurationProperty.THREAD_POOL_MAX_THREADS.toString(), Integer::valueOf);
125 assertEquals(THREAD_POOL_MAX_THREADS, tpMaxThreads);
129 public void registerListener() {
130 configurationService.registerListener(configurationListener);
131 verify(configurationListener, times(CONFIG_PROP_COUNT)).onPropertyChanged(any(), any());
134 @Test(expected = NumberFormatException.class)
135 public void close() throws Exception {
136 configurationService.close();
137 configurationService.getProperty(ConfigurationProperty.THREAD_POOL_MAX_THREADS.toString(), Integer::valueOf);