[infinispan-commits] Infinispan SVN: r1815 - in trunk/client/hotrod-client/src: main/java/org/infinispan/client/hotrod/impl and 4 other directories.

infinispan-commits at lists.jboss.org infinispan-commits at lists.jboss.org
Tue May 18 12:33:53 EDT 2010


Author: mircea.markus
Date: 2010-05-18 12:33:51 -0400 (Tue, 18 May 2010)
New Revision: 1815

Modified:
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/RemoteCacheManager.java
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/HotRodMarshaller.java
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/RemoteCacheImpl.java
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/SerializationMarshaller.java
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodConstants.java
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodOperations.java
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodOperationsHelper.java
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodOperationsImpl.java
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientDecoder.java
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientEncoder.java
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientPipelaneFactory.java
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/NettyTransport.java
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/tcp/TransportObjectFactory.java
   trunk/client/hotrod-client/src/test/resources/log4j.xml
Log:
renamed Hotrod to HotRod for consistency sake

Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/RemoteCacheManager.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/RemoteCacheManager.java	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/RemoteCacheManager.java	2010-05-18 16:33:51 UTC (rev 1815)
@@ -1,10 +1,10 @@
 package org.infinispan.client.hotrod;
 
 import org.infinispan.client.hotrod.exceptions.HotRodClientException;
+import org.infinispan.client.hotrod.impl.HotRodMarshaller;
 import org.infinispan.client.hotrod.impl.async.DefaultAsyncExecutorFactory;
-import org.infinispan.client.hotrod.impl.protocol.HotrodOperations;
-import org.infinispan.client.hotrod.impl.protocol.HotrodOperationsImpl;
-import org.infinispan.client.hotrod.impl.HotrodMarshaller;
+import org.infinispan.client.hotrod.impl.protocol.HotRodOperations;
+import org.infinispan.client.hotrod.impl.protocol.HotRodOperationsImpl;
 import org.infinispan.client.hotrod.impl.RemoteCacheImpl;
 import org.infinispan.client.hotrod.impl.SerializationMarshaller;
 import org.infinispan.client.hotrod.impl.transport.TransportFactory;
@@ -331,9 +331,9 @@
    }
 
    private <K, V> void startRemoteCache(RemoteCacheImpl<K, V> result) {
-      HotrodMarshaller marshaller = (HotrodMarshaller) VHelper.newInstance(hotrodMarshaller);
-      HotrodOperations hotrodOperations = new HotrodOperationsImpl(result.getName(), transportFactory, topologyId);
-      result.init(hotrodOperations, marshaller, asyncExecutorService);
+      HotRodMarshaller marshaller = (HotRodMarshaller) VHelper.newInstance(hotrodMarshaller);
+      HotRodOperations hotRodOperations = new HotRodOperationsImpl(result.getName(), transportFactory, topologyId);
+      result.init(hotRodOperations, marshaller, asyncExecutorService);
    }
 
    private Set<InetSocketAddress> getStaticConfiguredServers(String servers) {

Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/HotRodMarshaller.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/HotRodMarshaller.java	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/HotRodMarshaller.java	2010-05-18 16:33:51 UTC (rev 1815)
@@ -6,7 +6,7 @@
  * @author Mircea.Markus at jboss.com
  * @since 4.1
  */
-public interface HotrodMarshaller {
+public interface HotRodMarshaller {
 
    byte[] marshallObject(Object toMarshall);
 

Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/RemoteCacheImpl.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/RemoteCacheImpl.java	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/RemoteCacheImpl.java	2010-05-18 16:33:51 UTC (rev 1815)
@@ -8,7 +8,7 @@
 import org.infinispan.client.hotrod.VersionedValue;
 import org.infinispan.client.hotrod.exceptions.RemoteCacheManagerNotStartedException;
 import org.infinispan.client.hotrod.impl.async.NotifyingFutureImpl;
-import org.infinispan.client.hotrod.impl.protocol.HotrodOperations;
+import org.infinispan.client.hotrod.impl.protocol.HotRodOperations;
 import org.infinispan.util.concurrent.NotifyingFuture;
 import org.infinispan.util.logging.Log;
 import org.infinispan.util.logging.LogFactory;
@@ -30,8 +30,8 @@
    private static final Flag[] FORCE_RETURN_VALUE = {Flag.FORCE_RETURN_VALUE};
 
    private ThreadLocal<Flag[]> flagsMap = new ThreadLocal<Flag[]>();
-   private HotrodOperations operations;
-   private HotrodMarshaller marshaller;
+   private HotRodOperations operations;
+   private HotRodMarshaller marshaller;
    private final String name;
    private final RemoteCacheManager remoteCacheManager;
    private volatile ExecutorService executorService;
@@ -43,7 +43,7 @@
       this.remoteCacheManager = rcm;
    }
 
-   public void init(HotrodOperations operations, HotrodMarshaller marshaller, ExecutorService executorService) {
+   public void init(HotRodOperations operations, HotRodMarshaller marshaller, ExecutorService executorService) {
       this.operations = operations;
       this.marshaller = marshaller;
       this.executorService = executorService;

Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/SerializationMarshaller.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/SerializationMarshaller.java	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/SerializationMarshaller.java	2010-05-18 16:33:51 UTC (rev 1815)
@@ -17,7 +17,7 @@
  * @author Mircea.Markus at jboss.com
  * @since 4.1
  */
-public class SerializationMarshaller implements HotrodMarshaller {
+public class SerializationMarshaller implements HotRodMarshaller {
 
    private static Log log = LogFactory.getLog(SerializationMarshaller.class);
 

Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodConstants.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodConstants.java	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodConstants.java	2010-05-18 16:33:51 UTC (rev 1815)
@@ -6,7 +6,7 @@
  * @author Mircea.Markus at jboss.com
  * @since 4.1
  */
-public interface HotrodConstants {
+public interface HotRodConstants {
 
    public static final short REQUEST_MAGIC = 0xA0;
    public static final short RESPONSE_MAGIC = 0xA1;

Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodOperations.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodOperations.java	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodOperations.java	2010-05-18 16:33:51 UTC (rev 1815)
@@ -15,7 +15,7 @@
  * @author Mircea.Markus at jboss.com
  * @since 4.1
  */
-public interface HotrodOperations {
+public interface HotRodOperations {
 
    public byte[] get(byte[] key, Flag... flags);
 

Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodOperationsHelper.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodOperationsHelper.java	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodOperationsHelper.java	2010-05-18 16:33:51 UTC (rev 1815)
@@ -4,7 +4,7 @@
 import org.infinispan.client.hotrod.exceptions.HotRodClientException;
 import org.infinispan.client.hotrod.exceptions.InvalidResponseException;
 import org.infinispan.client.hotrod.exceptions.HotRodTimeoutException;
-import org.infinispan.client.hotrod.impl.protocol.HotrodConstants;
+import org.infinispan.client.hotrod.impl.protocol.HotRodConstants;
 import org.infinispan.client.hotrod.impl.transport.Transport;
 import org.infinispan.util.logging.Log;
 import org.infinispan.util.logging.LogFactory;
@@ -21,15 +21,15 @@
  * @since 4.1
  */
 public class HotRodOperationsHelper {
-   static Log log = LogFactory.getLog(HotrodOperationsImpl.class);
+   static Log log = LogFactory.getLog(HotRodOperationsImpl.class);
    static final AtomicLong MSG_ID = new AtomicLong();
-   final static byte CLIENT_INTELLIGENCE = HotrodConstants.CLIENT_INTELLIGENCE_HASH_DISTRIBUTION_AWARE;
+   final static byte CLIENT_INTELLIGENCE = HotRodConstants.CLIENT_INTELLIGENCE_HASH_DISTRIBUTION_AWARE;
 
    public static long writeHeader(Transport transport, short operationCode, String cacheName, AtomicInteger topologyId, Flag... flags) {
-      transport.writeByte(HotrodConstants.REQUEST_MAGIC);
+      transport.writeByte(HotRodConstants.REQUEST_MAGIC);
       long messageId = MSG_ID.incrementAndGet();
       transport.writeVLong(messageId);
-      transport.writeByte(HotrodConstants.HOTROD_VERSION);
+      transport.writeByte(HotRodConstants.HOTROD_VERSION);
       transport.writeByte(operationCode);
       transport.writeArray(cacheName.getBytes());
 
@@ -53,8 +53,8 @@
     */
    public static short readHeaderAndValidate(Transport transport, long messageId, short opRespCode, AtomicInteger topologyId) {
       short magic = transport.readByte();
-      if (magic != HotrodConstants.RESPONSE_MAGIC) {
-         String message = "Invalid magic number. Expected " + Integer.toHexString(HotrodConstants.RESPONSE_MAGIC) + " and received " + Integer.toHexString(magic);
+      if (magic != HotRodConstants.RESPONSE_MAGIC) {
+         String message = "Invalid magic number. Expected " + Integer.toHexString(HotRodConstants.RESPONSE_MAGIC) + " and received " + Integer.toHexString(magic);
          log.error(message);
          throw new InvalidResponseException(message);
       }
@@ -69,7 +69,7 @@
       }
       short receivedOpCode = transport.readByte();
       if (receivedOpCode != opRespCode) {
-         if (receivedOpCode == HotrodConstants.ERROR_RESPONSE) {
+         if (receivedOpCode == HotRodConstants.ERROR_RESPONSE) {
             checkForErrorsInResponseStatus(transport.readByte(), messageId, transport);
             throw new IllegalStateException("Error expected! (i.e. exception in the prev statement)");
          }
@@ -131,26 +131,26 @@
          log.trace("Received operation status: " + status);
       }
       switch ((int) status) {
-         case HotrodConstants.INVALID_MAGIC_OR_MESSAGE_ID_STATUS:
-         case HotrodConstants.REQUEST_PARSING_ERROR_STATUS:
-         case HotrodConstants.UNKNOWN_COMMAND_STATUS:
-         case HotrodConstants.SERVER_ERROR_STATUS:
-         case HotrodConstants.UNKNOWN_VERSION_STATUS: {
+         case HotRodConstants.INVALID_MAGIC_OR_MESSAGE_ID_STATUS:
+         case HotRodConstants.REQUEST_PARSING_ERROR_STATUS:
+         case HotRodConstants.UNKNOWN_COMMAND_STATUS:
+         case HotRodConstants.SERVER_ERROR_STATUS:
+         case HotRodConstants.UNKNOWN_VERSION_STATUS: {
             String msgFromServer = transport.readString();
             if (log.isWarnEnabled()) {
                log.warn("Error status received from the server:" + msgFromServer + " for message id " + messageId);
             }
             throw new HotRodClientException(msgFromServer, messageId, status);
          }
-         case HotrodConstants.COMMAND_TIMEOUT_STATUS: {
+         case HotRodConstants.COMMAND_TIMEOUT_STATUS: {
             if (log.isTraceEnabled()) {
                log.trace("timeout message received from the server");
             }
             throw new HotRodTimeoutException();
          }
-         case HotrodConstants.NO_ERROR_STATUS:
-         case HotrodConstants.KEY_DOES_NOT_EXIST_STATUS:
-         case HotrodConstants.NOT_PUT_REMOVED_REPLACED_STATUS: {
+         case HotRodConstants.NO_ERROR_STATUS:
+         case HotRodConstants.KEY_DOES_NOT_EXIST_STATUS:
+         case HotRodConstants.NOT_PUT_REMOVED_REPLACED_STATUS: {
             //don't do anything, these are correct responses
             break;
          }

Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodOperationsImpl.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodOperationsImpl.java	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodOperationsImpl.java	2010-05-18 16:33:51 UTC (rev 1815)
@@ -5,7 +5,7 @@
 import org.infinispan.client.hotrod.exceptions.TransportException;
 import org.infinispan.client.hotrod.impl.BinaryVersionedValue;
 import org.infinispan.client.hotrod.impl.VersionedOperationResponse;
-import org.infinispan.client.hotrod.impl.protocol.HotrodConstants;
+import org.infinispan.client.hotrod.impl.protocol.HotRodConstants;
 import org.infinispan.client.hotrod.impl.transport.Transport;
 import org.infinispan.client.hotrod.impl.transport.TransportFactory;
 import org.infinispan.util.logging.Log;
@@ -20,15 +20,15 @@
  * @author Mircea.Markus at jboss.com
  * @since 4.1
  */
-public class HotrodOperationsImpl implements HotrodOperations, HotrodConstants {
+public class HotRodOperationsImpl implements HotRodOperations, HotRodConstants {
 
-   private static Log log = LogFactory.getLog(HotrodOperationsImpl.class);
+   private static Log log = LogFactory.getLog(HotRodOperationsImpl.class);
 
    private final String cacheName;
    private TransportFactory transportFactory;
    private final AtomicInteger topologyId;
 
-   public HotrodOperationsImpl(String cacheName, TransportFactory transportFactory, AtomicInteger topologyId) {
+   public HotRodOperationsImpl(String cacheName, TransportFactory transportFactory, AtomicInteger topologyId) {
       this.cacheName = cacheName; //todo add charset here
       this.transportFactory = transportFactory;
       this.topologyId = topologyId;
@@ -228,7 +228,7 @@
          transport = transportFactory.getTransport();
          // 1) write header
          long messageId = HotRodOperationsHelper.writeHeader(transport, PING_REQUEST, cacheName, topologyId);
-         short respStatus = HotRodOperationsHelper.readHeaderAndValidate(transport, messageId, HotrodConstants.PING_RESPONSE, topologyId);
+         short respStatus = HotRodOperationsHelper.readHeaderAndValidate(transport, messageId, HotRodConstants.PING_RESPONSE, topologyId);
          if (respStatus == NO_ERROR_STATUS) {
             return true;
          }

Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientDecoder.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientDecoder.java	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientDecoder.java	2010-05-18 16:33:51 UTC (rev 1815)
@@ -12,7 +12,7 @@
  * @author Mircea.Markus at jboss.com
  * @since 4.1
  */
-public class HotrodClientDecoder extends FrameDecoder {
+public class HotRodClientDecoder extends FrameDecoder {
 
    private final ChannelBuffer buffer = ChannelBuffers.dynamicBuffer();
    private final InputStreamAdapter isa = new InputStreamAdapter(buffer);

Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientEncoder.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientEncoder.java	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientEncoder.java	2010-05-18 16:33:51 UTC (rev 1815)
@@ -14,7 +14,7 @@
  * @author Mircea.Markus at jboss.com
  * @since 4.1
  */
-public class HotrodClientEncoder extends OneToOneEncoder {
+public class HotRodClientEncoder extends OneToOneEncoder {
 
    private OutputStreamAdapter osa = new OutputStreamAdapter();
 

Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientPipelaneFactory.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientPipelaneFactory.java	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/HotRodClientPipelaneFactory.java	2010-05-18 16:33:51 UTC (rev 1815)
@@ -6,21 +6,18 @@
 import org.jboss.netty.channel.ChannelPipeline;
 import org.jboss.netty.channel.ChannelPipelineFactory;
 import org.jboss.netty.channel.DefaultChannelPipeline;
-import org.jboss.netty.handler.codec.http.HttpRequestEncoder;
-import org.jboss.netty.handler.codec.http.HttpResponseDecoder;
-import static org.jboss.netty.channel.Channels.*;
 
 /**
  * @author Mircea.Markus at jboss.com
  * @since 4.1
  */
-public class HotrodClientPipelaneFactory implements ChannelPipelineFactory {
+public class HotRodClientPipelaneFactory implements ChannelPipelineFactory {
 
-   private static Log log = LogFactory.getLog(HotrodClientPipelaneFactory.class);
+   private static Log log = LogFactory.getLog(HotRodClientPipelaneFactory.class);
 
-   private HotrodClientDecoder decoder;
+   private HotRodClientDecoder decoder;
 
-   public HotrodClientPipelaneFactory(HotrodClientDecoder decoder) {
+   public HotRodClientPipelaneFactory(HotRodClientDecoder decoder) {
       this.decoder = decoder;
    }
 
@@ -34,7 +31,7 @@
          }
       };
       pipeline.addLast("decoder", decoder);
-      pipeline.addLast("encoder", new HotrodClientEncoder());
+      pipeline.addLast("encoder", new HotRodClientEncoder());
       return pipeline;
    }
 }

Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/NettyTransport.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/NettyTransport.java	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/netty/NettyTransport.java	2010-05-18 16:33:51 UTC (rev 1815)
@@ -25,7 +25,7 @@
    private Channel channel;
    private ChannelFuture lastWrite;
 
-   private HotrodClientDecoder decoder = new HotrodClientDecoder();
+   private HotRodClientDecoder decoder = new HotRodClientDecoder();
 
    public NettyTransport(InetSocketAddress serverAddress, TransportFactory transportFactory) {
       super(transportFactory);
@@ -39,7 +39,7 @@
             new NioClientSocketChannelFactory(Executors.newCachedThreadPool(), Executors.newCachedThreadPool()));
 
       // Set up the event pipeline factory.
-      bootstrap.setPipelineFactory(new HotrodClientPipelaneFactory(decoder));
+      bootstrap.setPipelineFactory(new HotRodClientPipelaneFactory(decoder));
 
       // Start the connection attempt.
       ChannelFuture future = bootstrap.connect(serverAddress);

Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/tcp/TransportObjectFactory.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/tcp/TransportObjectFactory.java	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/transport/tcp/TransportObjectFactory.java	2010-05-18 16:33:51 UTC (rev 1815)
@@ -1,8 +1,8 @@
 package org.infinispan.client.hotrod.impl.transport.tcp;
 
 import org.apache.commons.pool.BaseKeyedPoolableObjectFactory;
+import org.infinispan.client.hotrod.impl.protocol.HotRodConstants;
 import org.infinispan.client.hotrod.impl.protocol.HotRodOperationsHelper;
-import org.infinispan.client.hotrod.impl.protocol.HotrodConstants;
 import org.infinispan.manager.DefaultCacheManager;
 import org.infinispan.util.logging.Log;
 import org.infinispan.util.logging.LogFactory;
@@ -45,9 +45,9 @@
          if (log.isTraceEnabled()) {
             log.trace("About to validate(ping) connection to server " + key + ". TcpTransport is " + transport);
          }
-         long messageId = HotRodOperationsHelper.writeHeader(transport, HotrodConstants.PING_REQUEST, DefaultCacheManager.DEFAULT_CACHE_NAME, topologyId);
-         short respStatus = HotRodOperationsHelper.readHeaderAndValidate(transport, messageId, HotrodConstants.PING_RESPONSE, topologyId);
-         if (respStatus == HotrodConstants.NO_ERROR_STATUS) {
+         long messageId = HotRodOperationsHelper.writeHeader(transport, HotRodConstants.PING_REQUEST, DefaultCacheManager.DEFAULT_CACHE_NAME, topologyId);
+         short respStatus = HotRodOperationsHelper.readHeaderAndValidate(transport, messageId, HotRodConstants.PING_RESPONSE, topologyId);
+         if (respStatus == HotRodConstants.NO_ERROR_STATUS) {
             if (log.isTraceEnabled())
                log.trace("Successfully validated transport: " + transport);
             return true;

Modified: trunk/client/hotrod-client/src/test/resources/log4j.xml
===================================================================
--- trunk/client/hotrod-client/src/test/resources/log4j.xml	2010-05-18 16:17:21 UTC (rev 1814)
+++ trunk/client/hotrod-client/src/test/resources/log4j.xml	2010-05-18 16:33:51 UTC (rev 1815)
@@ -45,7 +45,7 @@
    <!-- ================ -->
 
    <category name="org.infinispan">
-      <priority value="INFO"/>
+      <priority value="TRACE"/>
    </category>
 
    <category name="org.infinispan.server.hotrod">



More information about the infinispan-commits mailing list