commit 85b2d9c4a78bf710517f7c2b4e6443e7470871eb
author onurka <onur.kalinagac@netsia.com> Tue Jan 19 22:49:19 2021 +0300
committer onurka <onur.kalinagac@netsia.com> Wed Feb 10 02:38:04 2021 +0300
tree 136bbd76781a29e1d6e0d5ac37888aef558b2ccd
parent 37e8341a25020770afbf32a5b794cf27047691df

IgmpProxy performance improvements

Change-Id: I0364437ca934253cadb62981e84dd240eee9d0c9

app/src/main/java/org/opencord/igmpproxy/impl/IgmpproxyConfig.java

diff --git a/app/src/main/java/org/opencord/igmpproxy/impl/IgmpproxyConfig.java b/app/src/main/java/org/opencord/igmpproxy/impl/IgmpproxyConfig.java
index 6d8591a..e2db2ff 100644
--- a/app/src/main/java/org/opencord/igmpproxy/impl/IgmpproxyConfig.java
+++ b/app/src/main/java/org/opencord/igmpproxy/impl/IgmpproxyConfig.java
@@ -32,6 +32,7 @@
     protected static final String DEFAULT_LAST_QUERY_COUNT = "2";
     protected static final String DEFAULT_IGMP_COS = "7";
     protected static final String DEFAULT_UNI_IGMP_COS = "7";
+    protected static final String DEFAULT_NUMBER_OF_IGMP_REPORT_PROCESSOR_THREADS = "20";
     protected static final Boolean DEFAULT_FAST_LEAVE = false;
     protected static final Boolean DEFAULT_PERIODIC_QUERY = true;
     protected static final String DEFAULT_WITH_RA_UPLINK = "true";
@@ -61,12 +62,13 @@
     private static final String ENABLE_IGMP_PROVISIONING = "enableIgmpProvisioning";
     private static final String IGMP_ON_POD_BASIS = "igmpOnPodBasis";
     private static final String OUTGOING_IGMP_WITH_V3 = "outgoingIgmpWithV3";
+    private static final String NUMBER_OF_IGMP_REPORT_PROCESSOR_THREADS = "numberOfIgmpReportProcessorThreads";
 
     /**
      * Gets the value of a string property, protecting for an empty
      * JSON object.
      *
-     * @param name name of the property
+     * @param name         name of the property
      * @param defaultValue default value if none has been specified
      * @return String value if one os found, default value otherwise
      */
@@ -212,7 +214,7 @@
             return DEFAULT_IGMP_PROVISIONING_SUPPORT;
         }
         return Boolean.parseBoolean(getStringProperty(ENABLE_IGMP_PROVISIONING,
-                                                      DEFAULT_IGMP_PROVISIONING_SUPPORT.toString()));
+                DEFAULT_IGMP_PROVISIONING_SUPPORT.toString()));
     }
 
     public boolean igmpOnPodBasis() {
@@ -220,7 +222,7 @@
             return DEFAULT_IGMP_ON_POD_BASIS;
         }
         return Boolean.parseBoolean(getStringProperty(IGMP_ON_POD_BASIS,
-                                                      DEFAULT_IGMP_ON_POD_BASIS.toString()));
+                DEFAULT_IGMP_ON_POD_BASIS.toString()));
     }
 
     public Boolean outgoingIgmpWithV3() {
@@ -229,4 +231,9 @@
         }
         return Boolean.parseBoolean(getStringProperty(OUTGOING_IGMP_WITH_V3, DEFAULT_OUTGOING_IGMP_WITH_V3.toString()));
     }
-}
+
+    public int numberOfIgmpReportProcessorThreads() {
+        return Integer.parseInt(getStringProperty(NUMBER_OF_IGMP_REPORT_PROCESSOR_THREADS,
+                DEFAULT_NUMBER_OF_IGMP_REPORT_PROCESSOR_THREADS));
+    }
+}
\ No newline at end of file