accumulo-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From e..@apache.org
Subject svn commit: r1303976 - in /incubator/accumulo/branches/1.4: conf/examples/3GB/native-standalone/accumulo-site.xml conf/examples/3GB/standalone/accumulo-site.xml src/server/src/main/java/org/apache/accumulo/server/tabletserver/log/RemoteLogger.java
Date Thu, 22 Mar 2012 18:48:30 GMT
Author: ecn
Date: Thu Mar 22 18:48:29 2012
New Revision: 1303976

URL: http://svn.apache.org/viewvc?rev=1303976&view=rev
Log:
ACCUMULO-486 return logger connections to the transport pool

Modified:
    incubator/accumulo/branches/1.4/conf/examples/3GB/native-standalone/accumulo-site.xml
    incubator/accumulo/branches/1.4/conf/examples/3GB/standalone/accumulo-site.xml
    incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/log/RemoteLogger.java

Modified: incubator/accumulo/branches/1.4/conf/examples/3GB/native-standalone/accumulo-site.xml
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/conf/examples/3GB/native-standalone/accumulo-site.xml?rev=1303976&r1=1303975&r2=1303976&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/conf/examples/3GB/native-standalone/accumulo-site.xml
(original)
+++ incubator/accumulo/branches/1.4/conf/examples/3GB/native-standalone/accumulo-site.xml
Thu Mar 22 18:48:29 2012
@@ -61,7 +61,7 @@
     
     <property>
       <name>tserver.cache.index.size</name>
-      <value>100M</value>
+      <value>512M</value>
     </property>
     
     <property>

Modified: incubator/accumulo/branches/1.4/conf/examples/3GB/standalone/accumulo-site.xml
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/conf/examples/3GB/standalone/accumulo-site.xml?rev=1303976&r1=1303975&r2=1303976&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/conf/examples/3GB/standalone/accumulo-site.xml (original)
+++ incubator/accumulo/branches/1.4/conf/examples/3GB/standalone/accumulo-site.xml Thu Mar
22 18:48:29 2012
@@ -61,7 +61,7 @@
     
     <property>
       <name>tserver.cache.index.size</name>
-      <value>100M</value>
+      <value>512M</value>
     </property>
     
     <property>

Modified: incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/log/RemoteLogger.java
URL: http://svn.apache.org/viewvc/incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/log/RemoteLogger.java?rev=1303976&r1=1303975&r2=1303976&view=diff
==============================================================================
--- incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/log/RemoteLogger.java
(original)
+++ incubator/accumulo/branches/1.4/src/server/src/main/java/org/apache/accumulo/server/tabletserver/log/RemoteLogger.java
Thu Mar 22 18:48:29 2012
@@ -34,7 +34,6 @@ import org.apache.accumulo.server.conf.S
 import org.apache.accumulo.server.security.SecurityConstants;
 import org.apache.log4j.Logger;
 import org.apache.thrift.TException;
-import org.apache.thrift.TServiceClient;
 import org.apache.thrift.transport.TTransportException;
 
 /**
@@ -124,10 +123,12 @@ public class RemoteLogger {
   
   public synchronized void close() throws NoSuchLogIDException, LoggerClosedException, TException
{
     try {
-      client.close(null, logFile.id);
+      if (client != null)
+        client.close(null, logFile.id);
     } finally {
-      TServiceClient c = (TServiceClient) client;
-      c.getInputProtocol().getTransport().close();
+      MutationLogger.Iface tmp = client;
+      client = null;
+      ThriftUtil.returnClient(tmp);
     }
   }
   



Mime
View raw message