openflowplugin-impl/src/main/java/org/opendaylight/openflowplugin/impl/configuration/OpenFlowProviderConfigImpl.java

   1 /*
   2  * Copyright (c) 2017 Pantheon Technologies s.r.o. 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 package org.opendaylight.openflowplugin.impl.configuration;
   9
  10 import org.opendaylight.openflowplugin.api.openflow.configuration.ConfigurationProperty;
  11 import org.opendaylight.openflowplugin.api.openflow.configuration.ConfigurationService;
  12 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.openflow.provider.config.rev160510.NonZeroUint16Type;
  13 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.openflow.provider.config.rev160510.NonZeroUint32Type;
  14 import org.opendaylight.yang.gen.v1.urn.opendaylight.params.xml.ns.yang.openflow.provider.config.rev160510.OpenflowProviderConfig;
  15 import org.opendaylight.yangtools.yang.binding.AbstractAugmentable;
  16 import org.opendaylight.yangtools.yang.common.Uint16;
  17 import org.opendaylight.yangtools.yang.common.Uint32;
  18
  19 // FIXME: Rename this to "ConfigurationOpenflowProviderConfig" or some such. OpenFlowProviderConfigImpl is taken as
  20 //        Builder-based (guaranteed to work).
  21 public class OpenFlowProviderConfigImpl extends AbstractAugmentable<OpenflowProviderConfig>
  22         implements OpenflowProviderConfig {
  23     private final ConfigurationService service;
  24
  25     public OpenFlowProviderConfigImpl(final ConfigurationService service) {
  26         this.service = service;
  27     }
  28
  29     @Override
  30     public NonZeroUint16Type getRpcRequestsQuota() {
  31         return new NonZeroUint16Type(service.<Uint16>getProperty(
  32             ConfigurationProperty.RPC_REQUESTS_QUOTA.toString(), Uint16::valueOf));
  33     }
  34
  35     @Override
  36     public Boolean getSwitchFeaturesMandatory() {
  37         return service.getProperty(ConfigurationProperty.SWITCH_FEATURES_MANDATORY.toString(), Boolean::valueOf);
  38     }
  39
  40     @Override
  41     public Uint32 getGlobalNotificationQuota() {
  42         return service.getProperty(ConfigurationProperty.GLOBAL_NOTIFICATION_QUOTA.toString(), Uint32::valueOf);
  43     }
  44
  45     @Override
  46     public Boolean getIsStatisticsPollingOn() {
  47         return service.getProperty(ConfigurationProperty.IS_STATISTICS_POLLING_ON.toString(), Boolean::valueOf);
  48     }
  49
  50     @Override
  51     public Boolean getIsTableStatisticsPollingOn() {
  52         return service.getProperty(ConfigurationProperty.IS_TABLE_STATISTICS_POLLING_ON.toString(), Boolean::valueOf);
  53     }
  54
  55     @Override
  56     public Boolean getIsFlowStatisticsPollingOn() {
  57         return service.getProperty(ConfigurationProperty.IS_FLOW_STATISTICS_POLLING_ON.toString(), Boolean::valueOf);
  58     }
  59
  60     @Override
  61     public Boolean getIsGroupStatisticsPollingOn() {
  62         return service.getProperty(ConfigurationProperty.IS_GROUP_STATISTICS_POLLING_ON.toString(), Boolean::valueOf);
  63     }
  64
  65     @Override
  66     public Boolean getIsMeterStatisticsPollingOn() {
  67         return service.getProperty(ConfigurationProperty.IS_METER_STATISTICS_POLLING_ON.toString(), Boolean::valueOf);
  68     }
  69
  70     @Override
  71     public Boolean getIsQueueStatisticsPollingOn() {
  72         return service.getProperty(ConfigurationProperty.IS_QUEUE_STATISTICS_POLLING_ON.toString(), Boolean::valueOf);
  73     }
  74
  75     @Override
  76     public Boolean getIsPortStatisticsPollingOn() {
  77         return service.getProperty(ConfigurationProperty.IS_PORT_STATISTICS_POLLING_ON.toString(), Boolean::valueOf);
  78     }
  79
  80     @Override
  81     public Boolean getIsStatisticsRpcEnabled() {
  82         return service.getProperty(ConfigurationProperty.IS_STATISTICS_RPC_ENABLED.toString(), Boolean::valueOf);
  83     }
  84
  85     @Override
  86     public NonZeroUint32Type getBarrierIntervalTimeoutLimit() {
  87         return new NonZeroUint32Type(service.<Uint32>getProperty(
  88             ConfigurationProperty.BARRIER_INTERVAL_TIMEOUT_LIMIT.toString(), Uint32::valueOf));
  89     }
  90
  91     @Override
  92     public NonZeroUint16Type getBarrierCountLimit() {
  93         return new NonZeroUint16Type(service.<Uint16>getProperty(
  94             ConfigurationProperty.BARRIER_COUNT_LIMIT.toString(), Uint16::valueOf));
  95     }
  96
  97     @Override
  98     public NonZeroUint32Type getEchoReplyTimeout() {
  99         return new NonZeroUint32Type(service.<Uint32>getProperty(
 100             ConfigurationProperty.ECHO_REPLY_TIMEOUT.toString(), Uint32::valueOf));
 101     }
 102
 103     @Override
 104     public Uint16 getThreadPoolMinThreads() {
 105         return service.<Uint16>getProperty(ConfigurationProperty.THREAD_POOL_MIN_THREADS.toString(), Uint16::valueOf);
 106     }
 107
 108     @Override
 109     public NonZeroUint16Type getThreadPoolMaxThreads() {
 110         return new NonZeroUint16Type(service.<Uint16>getProperty(
 111             ConfigurationProperty.THREAD_POOL_MAX_THREADS.toString(), Uint16::valueOf));
 112     }
 113
 114     @Override
 115     public Uint32 getThreadPoolTimeout() {
 116         return service.getProperty(ConfigurationProperty.THREAD_POOL_TIMEOUT.toString(), Uint32::valueOf);
 117     }
 118
 119     @Override
 120     public Boolean getEnableFlowRemovedNotification() {
 121         return service.getProperty(ConfigurationProperty.ENABLE_FLOW_REMOVED_NOTIFICATION.toString(), Boolean::valueOf);
 122     }
 123
 124     @Override
 125     public Boolean getSkipTableFeatures() {
 126         return service.getProperty(ConfigurationProperty.SKIP_TABLE_FEATURES.toString(), Boolean::valueOf);
 127     }
 128
 129     @Override
 130     public Boolean getEnableEqualRole() {
 131         return service.getProperty(ConfigurationProperty.ENABLE_EQUAL_ROLE.toString(), Boolean::valueOf);
 132     }
 133
 134     @Override
 135     public NonZeroUint32Type getBasicTimerDelay() {
 136         return new NonZeroUint32Type(service.<Uint32>getProperty(
 137             ConfigurationProperty.BASIC_TIMER_DELAY.toString(), Uint32::valueOf));
 138     }
 139
 140     @Override
 141     public NonZeroUint32Type getMaximumTimerDelay() {
 142         return new NonZeroUint32Type(service.<Uint32>getProperty(
 143             ConfigurationProperty.MAXIMUM_TIMER_DELAY.toString(), Uint32::valueOf));
 144     }
 145
 146     @Override
 147     public Boolean getUseSingleLayerSerialization() {
 148         return service.getProperty(ConfigurationProperty.USE_SINGLE_LAYER_SERIALIZATION.toString(), Boolean::valueOf);
 149     }
 150
 151     @Override
 152     public Uint16 getDeviceConnectionRateLimitPerMin() {
 153         return service.getProperty(
 154             ConfigurationProperty.DEVICE_CONNECTION_RATE_LIMIT_PER_MIN.toString(), Uint16::valueOf);
 155     }
 156
 157     @Override
 158     public Uint16 getDeviceConnectionHoldTimeInSeconds() {
 159         return service.getProperty(
 160             ConfigurationProperty.DEVICE_CONNECTION_HOLD_TIME_IN_SECONDS.toString(), Uint16::valueOf);
 161     }
 162
 163     @Override
 164     public NonZeroUint32Type getDeviceDatastoreRemovalDelay() {
 165         return new NonZeroUint32Type(service.<Uint32>getProperty(
 166             ConfigurationProperty.DEVICE_DATASTORE_REMOVAL_DELAY.toString(), Uint32::valueOf));
 167     }
 168 }