fix timeout conflict between ec2 and walrus

eucalyptus · Feb 17, 2009 · be5bf26 · be5bf26
1 parent 7766d30
commit be5bf26
Show file tree

Hide file tree

Showing 3 changed files with 10 additions and 3 deletions.
diff --git a/clc/modules/core/src/edu/ucsb/eucalyptus/util/ReplyCoordinator.java b/clc/modules/core/src/edu/ucsb/eucalyptus/util/ReplyCoordinator.java
@@ -48,15 +48,22 @@ public class ReplyCoordinator {
   private static float MAP_BIN_AVG_THRESHOLD = 1.0f;
   private static long MAP_GET_WAIT_MS = 10;
   private static long MAP_SUBMIT_SLEEP_MS = MAP_GET_WAIT_MS;
-  private static long MAP_TIMEOUT_MS = 15000;
+  private long MAP_TIMEOUT_MS = 15000;
   private ConcurrentHashMap<String, EucalyptusMessage> replyMap;
   private ConcurrentHashMap<String,String> waitList;
 
   public ReplyCoordinator()
   {
+    this.MAP_TIMEOUT_MS = 15000;
     this.replyMap = new ConcurrentHashMap<String, EucalyptusMessage>( MAP_CAPACITY, MAP_BIN_AVG_THRESHOLD, MAP_NUM_CONCURRENT );
     this.waitList = new ConcurrentHashMap<String, String>( MAP_CAPACITY, MAP_BIN_AVG_THRESHOLD, MAP_NUM_CONCURRENT );
   }
+  public ReplyCoordinator( long user_timeout )
+  {
+    this();
+    this.MAP_TIMEOUT_MS = user_timeout;
+  }
+
 
   public void putMessage( EucalyptusMessage msg )
   {

diff --git a/clc/modules/interface/src/edu/ucsb/eucalyptus/ic/StorageReplyQueue.java b/clc/modules/interface/src/edu/ucsb/eucalyptus/ic/StorageReplyQueue.java
@@ -48,7 +48,7 @@ public class StorageReplyQueue {
 
     private static Logger LOG = Logger.getLogger( StorageReplyQueue.class );
 
-    private static ReplyCoordinator replies = new ReplyCoordinator();
+    private static ReplyCoordinator replies = new ReplyCoordinator( 3600000 );
 
     public void handle( EucalyptusMessage msg )
     {

diff --git a/clc/modules/interface/src/edu/ucsb/eucalyptus/ic/WalrusReplyQueue.java b/clc/modules/interface/src/edu/ucsb/eucalyptus/ic/WalrusReplyQueue.java
@@ -55,7 +55,7 @@ public class WalrusReplyQueue {
 
     private static Logger LOG = Logger.getLogger( WalrusReplyQueue.class );
 
-    private static ReplyCoordinator replies = new ReplyCoordinator();
+    private static ReplyCoordinator replies = new ReplyCoordinator( 3600000 );
 
     private static int SC_DECRYPTION_FAILED = 566;
     public void handle( EucalyptusMessage msg )