diff options
Diffstat (limited to 'messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java')
-rwxr-xr-x | messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java | 12 |
1 files changed, 6 insertions, 6 deletions
diff --git a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java index 6179097e5d9..07a33a646d9 100755 --- a/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java +++ b/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java @@ -43,7 +43,7 @@ public class RPCTarget implements RequestWaiter { * * @return The target. */ - public Target getJRTTarget() { + Target getJRTTarget() { return target; } @@ -54,7 +54,7 @@ public class RPCTarget implements RequestWaiter { * * @see #subRef() */ - public void addRef() { + void addRef() { ref.incrementAndGet(); } @@ -65,7 +65,7 @@ public class RPCTarget implements RequestWaiter { * * @see #addRef() */ - public void subRef() { + void subRef() { if (ref.decrementAndGet() == 0) { target.close(); } @@ -77,7 +77,7 @@ public class RPCTarget implements RequestWaiter { * * @return The number of references in use. */ - public int getRefCount() { + int getRefCount() { return ref.get(); } @@ -90,7 +90,7 @@ public class RPCTarget implements RequestWaiter { * @param timeout The timeout for the request in seconds. * @param handler The handler to be called once the version is available. */ - public void resolveVersion(double timeout, VersionHandler handler) { + void resolveVersion(double timeout, VersionHandler handler) { boolean hasVersion = false; boolean shouldInvoke = false; boolean shouldLog = log.isLoggable(LogLevel.DEBUG); @@ -168,6 +168,6 @@ public class RPCTarget implements RequestWaiter { * * @param ver The version of corresponding target, or null. */ - public void handleVersion(Version ver); + void handleVersion(Version ver); } } |