summaryrefslogtreecommitdiff
path: root/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
diff options
context:
space:
mode:
authorKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-04-11 16:13:08 +0200
committerKjetil Ørbekk <kjetil.orbekk@gmail.com>2012-04-11 16:13:08 +0200
commit8cef018aab54ac3f31643a26a75f974c454893ba (patch)
treef50b80f7ead481912ce68159b6b0916fffd5ce1e /same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
parent04d448aade12127b1d8c9d4f26963833102698f8 (diff)
Use new RPC in Client.joinNetwork().
Diffstat (limited to 'same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java')
-rw-r--r--same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java10
1 files changed, 10 insertions, 0 deletions
diff --git a/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java b/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
index 9aa4f81..8c3b9df 100644
--- a/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
+++ b/same/src/main/java/com/orbekk/same/ConnectionManagerImpl.java
@@ -117,6 +117,16 @@ public class ConnectionManagerImpl implements ConnectionManager {
}
@Override
+ public Services.Master getMaster0(String location) {
+ RpcChannel channel = getChannel(location);
+ if (channel != null) {
+ return Services.Master.newStub(channel);
+ } else {
+ return null;
+ }
+ }
+
+ @Override
public Services.Directory getDirectory(String location) {
RpcChannel channel = getChannel(location);
if (channel != null) {