You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hama.apache.org by ed...@apache.org on 2011/10/30 00:26:30 UTC

svn commit: r1195059 - in /incubator/hama/trunk/core/src: main/java/org/apache/hama/bsp/sync/rpc/ test/java/org/apache/hama/bsp/sync/TestSyncServiceFactory.java test/java/org/apache/hama/bsp/sync/rpc/

Author: edwardyoon
Date: Sat Oct 29 22:26:29 2011
New Revision: 1195059

URL: http://svn.apache.org/viewvc?rev=1195059&view=rev
Log:
Remove rpc package.

Removed:
    incubator/hama/trunk/core/src/main/java/org/apache/hama/bsp/sync/rpc/
    incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/sync/rpc/
Modified:
    incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/sync/TestSyncServiceFactory.java

Modified: incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/sync/TestSyncServiceFactory.java
URL: http://svn.apache.org/viewvc/incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/sync/TestSyncServiceFactory.java?rev=1195059&r1=1195058&r2=1195059&view=diff
==============================================================================
--- incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/sync/TestSyncServiceFactory.java (original)
+++ incubator/hama/trunk/core/src/test/java/org/apache/hama/bsp/sync/TestSyncServiceFactory.java Sat Oct 29 22:26:29 2011
@@ -20,8 +20,6 @@ package org.apache.hama.bsp.sync;
 import junit.framework.TestCase;
 
 import org.apache.hadoop.conf.Configuration;
-import org.apache.hama.bsp.sync.rpc.RPCSyncClientImpl;
-import org.apache.hama.bsp.sync.rpc.RPCSyncServerImpl;
 import org.apache.hama.bsp.sync.zookeeper.ZooKeeperSyncClientImpl;
 import org.apache.hama.bsp.sync.zookeeper.ZooKeeperSyncServerImpl;
 
@@ -33,12 +31,6 @@ public class TestSyncServiceFactory exte
     // given null, should return zookeeper
     SyncClient syncClient = SyncServiceFactory.getSyncClient(conf);
     assertTrue(syncClient instanceof ZooKeeperSyncClientImpl);
-    
-    // other class
-    conf.set(SyncServiceFactory.SYNC_CLIENT_CLASS, RPCSyncClientImpl.class.getCanonicalName());
-    syncClient = SyncServiceFactory.getSyncClient(conf);
-    assertTrue(syncClient instanceof RPCSyncClientImpl);
-
   }
   
   public void testServerInstantiation() throws Exception {
@@ -47,12 +39,6 @@ public class TestSyncServiceFactory exte
     // given null, should return zookeeper
     SyncServer syncServer = SyncServiceFactory.getSyncServer(conf);
     assertTrue(syncServer instanceof ZooKeeperSyncServerImpl);
-    
-    // other class
-    conf.set(SyncServiceFactory.SYNC_SERVER_CLASS, RPCSyncServerImpl.class.getCanonicalName());
-    syncServer = SyncServiceFactory.getSyncServer(conf);
-    assertTrue(syncServer instanceof RPCSyncServerImpl);
-
   }
 
 }