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

infinispan-commits at lists.jboss.org infinispan-commits at lists.jboss.org
Tue May 18 15:46:28 EDT 2010


Author: mircea.markus
Date: 2010-05-18 15:46:27 -0400 (Tue, 18 May 2010)
New Revision: 1820

Modified:
   trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/RemoteCache.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/protocol/HotRodOperationsImpl.java
   trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/CacheManagerNotStartedTest.java
   trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/CacheManagerStoppedTest.java
   trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/HotRodIntegrationTest.java
   trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/RemoteCacheManagerTest.java
Log:
removed ping from the interface


Modified: trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/RemoteCache.java
===================================================================
--- trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/RemoteCache.java	2010-05-18 19:27:20 UTC (rev 1819)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/RemoteCache.java	2010-05-18 19:46:27 UTC (rev 1820)
@@ -338,11 +338,6 @@
    @Override
    void putAll(Map<? extends K, ? extends V> m);
 
-   /**
-    * Returns true if the remote cluster can be reached, false otherwise.
-    */
-   boolean ping();
-
    public ServerStatistics stats();
 
    RemoteCache<K,V> withFlags(Flag... flags);

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 19:27:20 UTC (rev 1819)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/RemoteCacheImpl.java	2010-05-18 19:46:27 UTC (rev 1820)
@@ -287,12 +287,6 @@
    }
 
    @Override
-   public boolean ping() {
-      assertRemoteCacheManagerIsStarted();
-      return operations.ping();
-   }
-
-   @Override
    public void start() {
       if (log.isInfoEnabled()) {
          log.info("Start called, nothing to do here(" + getName() + ")");

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 19:27:20 UTC (rev 1819)
+++ trunk/client/hotrod-client/src/main/java/org/infinispan/client/hotrod/impl/protocol/HotRodOperationsImpl.java	2010-05-18 19:46:27 UTC (rev 1820)
@@ -234,7 +234,7 @@
          }
          throw new IllegalStateException("Unknown response status: " + Integer.toHexString(respStatus));
       } catch (TransportException te) {
-         log.trace("Exception while ping", te);
+         log.trace("Exception while adsdsa", te);
          return false;
       }
       finally {

Modified: trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/CacheManagerNotStartedTest.java
===================================================================
--- trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/CacheManagerNotStartedTest.java	2010-05-18 19:27:20 UTC (rev 1819)
+++ trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/CacheManagerNotStartedTest.java	2010-05-18 19:46:27 UTC (rev 1820)
@@ -107,11 +107,6 @@
       cache().removeWithVersionAsync("key", 12312321l);
    }
 
-   @Test(expectedExceptions = RemoteCacheManagerNotStartedException.class)
-   public void testPing() {
-      cache().ping();
-   }
-
    private RemoteCache<Object, Object> cache() {
       return remoteCacheManager.getCache();
    }

Modified: trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/CacheManagerStoppedTest.java
===================================================================
--- trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/CacheManagerStoppedTest.java	2010-05-18 19:27:20 UTC (rev 1819)
+++ trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/CacheManagerStoppedTest.java	2010-05-18 19:46:27 UTC (rev 1820)
@@ -44,7 +44,6 @@
    public void testGetCacheOperations() {
       assert remoteCacheManager.getCache() != null;
       assert remoteCacheManager.getCache(CACHE_NAME) != null;
-      cache().ping();
       cache().put("k", "v");
       assert cache().get("k").equals("v");      
    }
@@ -118,11 +117,6 @@
       cache().removeWithVersionAsync("key", 12312321l);
    }
 
-   @Test(expectedExceptions = RemoteCacheManagerNotStartedException.class, dependsOnMethods = "testStopCacheManager")
-   public void testPing() {
-      cache().ping();
-   }
-
    private RemoteCache<Object, Object> cache() {
       return remoteCacheManager.getCache();
    }

Modified: trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/HotRodIntegrationTest.java
===================================================================
--- trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/HotRodIntegrationTest.java	2010-05-18 19:27:20 UTC (rev 1819)
+++ trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/HotRodIntegrationTest.java	2010-05-18 19:46:27 UTC (rev 1820)
@@ -71,9 +71,7 @@
    @AfterClass 
    public void testDestroyRemoteCacheFactory() {
       remoteCacheManager.stop();
-//      assert remoteCache.ping();
       hotrodServer.stop();
-//      assert !remoteCache.ping();
    }
 
    public void testPut() {

Modified: trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/RemoteCacheManagerTest.java
===================================================================
--- trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/RemoteCacheManagerTest.java	2010-05-18 19:27:20 UTC (rev 1819)
+++ trunk/client/hotrod-client/src/test/java/org/infinispan/client/hotrod/RemoteCacheManagerTest.java	2010-05-18 19:46:27 UTC (rev 1820)
@@ -98,7 +98,6 @@
 
    private void assertWorks(RemoteCacheManager remoteCacheManager) {
       RemoteCache<Object, Object> cache = remoteCacheManager.getCache();
-      assert cache.ping();
       cache.put("aKey", "aValue");
       assert cache.get("aKey").equals("aValue");
    }



More information about the infinispan-commits mailing list