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);
-
}
}