You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ode.apache.org by ka...@apache.org on 2009/03/05 00:25:31 UTC

svn commit: r750224 - in /ode/branches/APACHE_ODE_1.X: axis2/src/main/java/org/apache/ode/axis2/ bpel-epr/src/main/java/org/apache/ode/il/config/ bpel-runtime/src/main/java/org/apache/ode/bpel/engine/

Author: karthick
Date: Wed Mar  4 23:25:30 2009
New Revision: 750224

URL: http://svn.apache.org/viewvc?rev=750224&view=rev
Log:
Remove low free memory threshold checker.

Modified:
    ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java
    ode/branches/APACHE_ODE_1.X/bpel-epr/src/main/java/org/apache/ode/il/config/OdeConfigProperties.java
    ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java

Modified: ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java?rev=750224&r1=750223&r2=750224&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java (original)
+++ ode/branches/APACHE_ODE_1.X/axis2/src/main/java/org/apache/ode/axis2/ODEServer.java Wed Mar  4 23:25:30 2009
@@ -561,7 +561,6 @@
             _server.setDehydrationPolicy(dehy);
         }
         _server.setHydrationLazy(_odeConfig.isHydrationLazy());
-        _server.setLowFreeMemoryThreshold(_odeConfig.getLowFreeMemoryThreshold());
         _server.setConfigProperties(_odeConfig.getProperties());
         _server.init();
     }

Modified: ode/branches/APACHE_ODE_1.X/bpel-epr/src/main/java/org/apache/ode/il/config/OdeConfigProperties.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-epr/src/main/java/org/apache/ode/il/config/OdeConfigProperties.java?rev=750224&r1=750223&r2=750224&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-epr/src/main/java/org/apache/ode/il/config/OdeConfigProperties.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-epr/src/main/java/org/apache/ode/il/config/OdeConfigProperties.java Wed Mar  4 23:25:30 2009
@@ -86,8 +86,6 @@
     
     public static final String PROP_PROCESS_HYDRATION = "process.hydration";
     
-    public static final String PROP_LOW_FREE_MEMORY_THRESHOLD = "low.free.memory.threshold";
-    
     public static final String PROP_DAOCF = "dao.factory";
 
     private File _cfgFile;
@@ -265,10 +263,6 @@
     public boolean isDbLoggingEnabled() {
         return Boolean.valueOf(getProperty(OdeConfigProperties.PROP_DB_LOGGING, "false"));
     }
-    
-    public int getLowFreeMemoryThreshold() {
-    	return Integer.valueOf(getProperty(PROP_LOW_FREE_MEMORY_THRESHOLD, "10"));
-    }
 
 
     public String getProperty(String pname) {

Modified: ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java
URL: http://svn.apache.org/viewvc/ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java?rev=750224&r1=750223&r2=750224&view=diff
==============================================================================
--- ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java (original)
+++ ode/branches/APACHE_ODE_1.X/bpel-runtime/src/main/java/org/apache/ode/bpel/engine/BpelServerImpl.java Wed Mar  4 23:25:30 2009
@@ -90,7 +90,6 @@
     private Contexts _contexts = new Contexts();
     private DehydrationPolicy _dehydrationPolicy;
     private boolean _hydrationLazy;
-    private int _lowFreeMemoryThreshold;
     private Properties _configProperties;
     
     BpelEngineImpl _engine;
@@ -142,7 +141,6 @@
             _state = State.RUNNING;
             __log.info(__msgs.msgServerStarted());
             if (_dehydrationPolicy != null) new Thread(new ProcessDefReaper()).start();
-            if (_lowFreeMemoryThreshold != 0) new Thread(new FreeMemoryChecker()).start();
         } finally {
             _mngmtLock.writeLock().unlock();
         }
@@ -393,37 +391,6 @@
         getEngine().onScheduledJob(jobInfo);
     }
     
-    private class FreeMemoryChecker implements Runnable {
-    	Runtime runtime = Runtime.getRuntime();
-    	public void run() {
-            __log.debug("Starting free memory checker thread.");
-            long pollingTime = 60000;
-            try {
-                while (true) {
-                    Thread.sleep(pollingTime);
-                    double freeMemory = (double) runtime.freeMemory();
-                    double maxMemory = (double) runtime.maxMemory();
-                    if ((freeMemory / maxMemory) < (_lowFreeMemoryThreshold / 100)) {
-                		__log.info("You are running out of free memory!");
-                		__log.info("Please try to restart the server with a higher maximum Java heap size");
-                		__log.info("If you cannot increase the heap size, then please reduce your workload by:");
-                		__log.info("a) Waiting for active instances to complete before starting new ones");
-                		__log.info("b) Retiring low-priority processes that you don't plan on using");
-                    	if (_dehydrationPolicy == null) {
-                    		__log.info("Process dehydration is currently turned off");
-                    		__log.info("Restarting the server with process hydration turned on may help");
-                    	} else {
-                    		__log.info("Process dehydration is currently turned on");
-                    		__log.info("Configuring process hydration with a lower maximum age and count may help");
-                    	}
-                    }
-                }
-            } catch (InterruptedException e) {
-                __log.info(e);
-            }
-    	}
-    }
-    
     private class ProcessDefReaper implements Runnable {
         public void run() {
             __log.debug("Starting process definition reaper thread.");
@@ -510,11 +477,7 @@
 	}
 
 	public void setHydrationLazy(boolean hydrationLazy) {
-		_hydrationLazy = hydrationLazy;
-	}
-
-	public void setLowFreeMemoryThreshold(int lowFreeMemoryThreshold) {
-		_lowFreeMemoryThreshold = lowFreeMemoryThreshold;
+		this._hydrationLazy = hydrationLazy;
 	}
 
 }