[sctp] push by amit.bha...@gmail.com - FIXED ISSUE-7 SCTP stack now persist the properties on 2014-06-23 06:18 GMT

[sctp]

Revision: 22acc54ffe78
Author:   amit.bhay...@gmail.com <amit.bhay...@gmail.com>
Date:     Mon Jun 23 06:18:05 2014 UTC
Log:      FIXED ISSUE-7 SCTP stack now persist the properties
http://code.google.com/p/sctp/source/detail?r=22acc54ffe78

Modified:
 /sctp-impl/src/main/java/org/mobicents/protocols/sctp/ManagementImpl.java

=======================================
---  
/sctp-impl/src/main/java/org/mobicents/protocols/sctp/ManagementImpl.java	 
Thu May  9 11:11:33 2013 UTC
+++  
/sctp-impl/src/main/java/org/mobicents/protocols/sctp/ManagementImpl.java	 
Mon Jun 23 06:18:05 2014 UTC
@@ -65,6 +65,10 @@

        private static final String SERVERS = "servers";
        private static final String ASSOCIATIONS = "associations";
+
+    private static final String CONNECT_DELAY_PROP = "connectdelay";
+    private static final String SINGLE_THREAD_PROP = "singlethread";
+    private static final String WORKER_THREADS_PROP = "workerthreads";

        private final TextBuilder persistFile = TextBuilder.newInstance();

@@ -90,7 +94,7 @@

        private int workerThreads = DEFAULT_IO_THREADS;

-       private boolean singleThread = false;
+       private boolean singleThread = true;

        private int workerThreadCount = 0;

@@ -98,7 +102,7 @@
        // closed and attempt will be made to open again
        private int maxIOErrors = 3;

-       private int connectDelay = 30000;
+       private int connectDelay = 5000;

        private ExecutorService[] executorServices = null;

@@ -145,6 +149,8 @@
         */
        public void setConnectDelay(int connectDelay) {
                this.connectDelay = connectDelay;
+
+               this.store();
        }

        /**
@@ -164,6 +170,7 @@
                }
                this.workerThreads = workerThreads;

+               this.store();
        }

        /**
@@ -197,6 +204,8 @@
         */
        public void setSingleThread(boolean singleThread) {
                this.singleThread = singleThread;
+
+               this.store();
        }

        public ServerListener getServerListener() {
@@ -381,6 +390,16 @@
                try {
 			reader = XMLObjectReader.newInstance(new  
FileInputStream(persistFile.toString()));
                        reader.setBinding(binding);
+
+            try {
+                this.connectDelay = reader.read(CONNECT_DELAY_PROP,  
Integer.class);
+                this.workerThreads = reader.read(WORKER_THREADS_PROP,  
Integer.class);
+                this.singleThread = reader.read(SINGLE_THREAD_PROP,  
Boolean.class);
+            } catch (java.lang.NullPointerException npe) {
+                // ignore.
+                // For backward compatibility we can ignore if these  
values are not defined
+            }
+
                        this.servers = reader.read(SERVERS, FastList.class);

 			for (FastList.Node<Server> n = this.servers.head(), end =  
this.servers.tail(); (n = n.getNext()) != end;) {
@@ -414,6 +433,11 @@
                        // Enables cross-references.
                        // writer.setReferenceResolver(new 
XMLReferenceResolver());
                        writer.setIndentation(TAB_INDENT);
+
+            writer.write(this.connectDelay, CONNECT_DELAY_PROP,  
Integer.class);
+            writer.write(this.workerThreads, WORKER_THREADS_PROP,  
Integer.class);
+            writer.write(this.singleThread, SINGLE_THREAD_PROP,  
Boolean.class);
+
                        writer.write(this.servers, SERVERS, FastList.class);
                        writer.write(this.associations, ASSOCIATIONS, 
AssociationMap.class);

--

--- 
You received this message because you are subscribed to the Google Groups "mobicents-commits" group.
To unsubscribe from this group and stop receiving emails from it, send an email 
to mobicents-commits+unsubscr...@googlegroups.com.
For more options, visit https://groups.google.com/d/optout.