hbase-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From st...@apache.org
Subject svn commit: r1099694 - in /hbase/branches/0.90: CHANGES.txt src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java
Date Thu, 05 May 2011 06:06:05 GMT
Author: stack
Date: Thu May  5 06:06:05 2011
New Revision: 1099694

URL: http://svn.apache.org/viewvc?rev=1099694&view=rev
Log:
HBASE-3813 Change RPC callQueue size from "handlerCount * MAX_QUEUE_SIZE_PER_HANDLER;"; stopgap
fix for now

Modified:
    hbase/branches/0.90/CHANGES.txt
    hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java

Modified: hbase/branches/0.90/CHANGES.txt
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/CHANGES.txt?rev=1099694&r1=1099693&r2=1099694&view=diff
==============================================================================
--- hbase/branches/0.90/CHANGES.txt (original)
+++ hbase/branches/0.90/CHANGES.txt Thu May  5 06:06:05 2011
@@ -57,6 +57,8 @@ Release 0.90.3 - Unreleased
    HBASE-3805  Log RegionState that are processed too late in the master
    HBASE-3695  Some improvements to Hbck to test the entire region chain
                in Meta and provide better error reporting (Marc Limotte)
+   HBASE-3813  Change RPC callQueue size from 'handlerCount *
+               MAX_QUEUE_SIZE_PER_HANDLER;'
 
   TASK
    HBASE-3748  Add rolling of thrift/rest daemons to graceful_stop.sh script

Modified: hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java
URL: http://svn.apache.org/viewvc/hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java?rev=1099694&r1=1099693&r2=1099694&view=diff
==============================================================================
--- hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java (original)
+++ hbase/branches/0.90/src/main/java/org/apache/hadoop/hbase/ipc/HBaseServer.java Thu May
 5 06:06:05 2011
@@ -90,7 +90,7 @@ public abstract class HBaseServer {
   /**
    * How many calls/handler are allowed in the queue.
    */
-  private static final int MAX_QUEUE_SIZE_PER_HANDLER = 100;
+  private static final int DEFAULT_MAX_QUEUE_SIZE_PER_HANDLER = 10;
 
   private static final String WARN_RESPONSE_SIZE =
       "hbase.ipc.warn.response.size";
@@ -1147,7 +1147,9 @@ public abstract class HBaseServer {
     this.handlerCount = handlerCount;
     this.priorityHandlerCount = priorityHandlerCount;
     this.socketSendBufferSize = 0;
-    this.maxQueueSize = handlerCount * MAX_QUEUE_SIZE_PER_HANDLER;
+    this.maxQueueSize =
+      this.conf.getInt("ipc.server.max.queue.size",
+        handlerCount * DEFAULT_MAX_QUEUE_SIZE_PER_HANDLER);
      this.readThreads = conf.getInt(
         "ipc.server.read.threadpool.size",
         10);



Mime
View raw message