CVS update of gotm/src/java/org/objectweb/gotm/lib/context (2 files)

[Romain Rouvoy <rouvoy@xxxxxxxxxxxxxxxxxxxxxxxxx>]

    Date: Monday, August 8, 2005 @ 15:38:16
  Author: rouvoy
    Path: /cvsroot/gotm/gotm/src/java/org/objectweb/gotm/lib/context

Modified: CommitProtocolAwareness.java ContextAwarenessImpl.java

* Updating Resource Manager component,
* Improving Logging Provider component,
* Adding Context Awareness component.


------------------------------+
 CommitProtocolAwareness.java |   22 ++++++++++------------
 ContextAwarenessImpl.java    |    8 ++++----
 2 files changed, 14 insertions(+), 16 deletions(-)


Index: 
gotm/src/java/org/objectweb/gotm/lib/context/CommitProtocolAwareness.java
diff -u 
gotm/src/java/org/objectweb/gotm/lib/context/CommitProtocolAwareness.java:1.1 
gotm/src/java/org/objectweb/gotm/lib/context/CommitProtocolAwareness.java:1.2
--- 
gotm/src/java/org/objectweb/gotm/lib/context/CommitProtocolAwareness.java:1.1 
      Fri Aug  5 17:06:29 2005
+++ gotm/src/java/org/objectweb/gotm/lib/context/CommitProtocolAwareness.java 
  Mon Aug  8 15:38:16 2005
@@ -23,7 +23,7 @@
 Contributor(s): .
 
 ---------------------------------------------------------------------
-$Id: CommitProtocolAwareness.java,v 1.1 2005/08/05 15:06:29 rouvoy Exp $
+$Id: CommitProtocolAwareness.java,v 1.2 2005/08/08 13:38:16 rouvoy Exp $
 ====================================================================*/
 package org.objectweb.gotm.lib.context;
 
@@ -40,16 +40,14 @@
 /**
  * @author <a href="mailto:Romain.Rouvoy@xxxxxxx";>Romain Rouvoy</a>
  * @created 3 août 2005
- * @modified $Date: 2005/08/05 15:06:29 $
- * @version $Revision: 1.1 $
+ * @modified $Date: 2005/08/08 13:38:16 $
+ * @version $Revision: 1.2 $
  * @fractal.itf 
  */
 public class CommitProtocolAwareness
         extends ContextAwarenessImpl {
     /** <code>WINDOW</code> size of the window of visibility. */
-    public static final int WINDOW = 40;
-    /** <code>WARM</code> warm up. */
-    public static final int WARM = 40 ;
+    public static final int WINDOW = 25;
     
     private final Map conf2pc = new HashMap();
     private final Map conf2pcpc = new HashMap();
@@ -91,24 +89,24 @@
      * @see 
org.objectweb.gotm.lib.context.ContextAwarenessImpl#getConfiguration(java.util.LinkedList)
      */
     protected Map getConfiguration(LinkedList topics) {
-        if (topics.size()<WARM) {
+        if (topics.size()<WINDOW) {
             System.out.println("[T="+topics.size()+"]==> No adaptatation 
during warm up!");
             return null;
         }
         int commit = count(topics,TransactionStatusCommitted.status);
         int abort = count(topics,TransactionStatusRolledBack.status);
         int dec = (100*commit)/(commit+abort);
-        if (dec <= 62 && current!=conf2pcpa) {
-            System.out.println("[T="+topics.size()+"]==> Switching to the 
2PCPA commit protocol ("+dec+"<=62)("+(commit)+"|"+(commit+abort)+")...");
+        if (dec <= 55 && current!=conf2pcpa) {
+            System.out.println("[T="+topics.size()+"]==> Switching to the 
2PCPA commit protocol 
(commit="+dec+"%<=55%)("+(commit)+"|"+(commit+abort)+")...");
             this.current = conf2pcpa;
             return conf2pcpa;
         }
-        if (dec >= 47 && current!=conf2pcpc) {
-            System.out.println("[T="+topics.size()+"]==> Switching to the 
2PCPC commit protocol ("+dec+">=47)("+(commit)+"|"+(commit+abort)+")...");
+        if (dec > 55 && current!=conf2pcpc) {
+            System.out.println("[T="+topics.size()+"]==> Switching to the 
2PCPC commit protocol 
(commit="+dec+"%>=55%)("+(commit)+"|"+(commit+abort)+")...");
             this.current = conf2pcpc;
             return conf2pcpc;
         }
-        System.out.println("[T="+topics.size()+"]==> No adaptation is 
required ("+dec+")("+(commit)+"|"+(commit+abort)+")");
+        System.out.println("[T="+topics.size()+"]==> No adaptation is 
required (commit="+dec+"%)("+(commit)+"|"+(commit+abort)+")");
         return null;
     }
 }
Index: gotm/src/java/org/objectweb/gotm/lib/context/ContextAwarenessImpl.java
diff -u 
gotm/src/java/org/objectweb/gotm/lib/context/ContextAwarenessImpl.java:1.1 
gotm/src/java/org/objectweb/gotm/lib/context/ContextAwarenessImpl.java:1.2
--- 
gotm/src/java/org/objectweb/gotm/lib/context/ContextAwarenessImpl.java:1.1  
Fri Aug  5 17:06:29 2005
+++ gotm/src/java/org/objectweb/gotm/lib/context/ContextAwarenessImpl.java    
  Mon Aug  8 15:38:16 2005
@@ -23,7 +23,7 @@
 Contributor(s): .
 
 ---------------------------------------------------------------------
-$Id: ContextAwarenessImpl.java,v 1.1 2005/08/05 15:06:29 rouvoy Exp $
+$Id: ContextAwarenessImpl.java,v 1.2 2005/08/08 13:38:16 rouvoy Exp $
 ====================================================================*/
 package org.objectweb.gotm.lib.context;
 
@@ -37,8 +37,8 @@
 /**
  * @author <a href="mailto:Romain.Rouvoy@xxxxxxx";>Romain Rouvoy</a>
  * @created 3 août 2005
- * @modified $Date: 2005/08/05 15:06:29 $
- * @version $Revision: 1.1 $
+ * @modified $Date: 2005/08/08 13:38:16 $
+ * @version $Revision: 1.2 $
  * @fractal.itf name="configurable" role="client" 
signature="org.objectweb.gotm.lib.context.Configurable"
  */
 public abstract class ContextAwarenessImpl
@@ -46,7 +46,7 @@
 implements PublishFeature, ContextAwareness
 {
     /** <code>REFRESH</code> . */
-    public static final int REFRESH = 20 ;
+    public static final int REFRESH = 5 ;
     
     private final int refresh = REFRESH ;
     private LinkedList occurrences = new LinkedList();