summaryrefslogtreecommitdiffstats
path: root/messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java
diff options
context:
space:
mode:
Diffstat (limited to 'messagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java')
-rwxr-xr-xmessagebus/src/main/java/com/yahoo/messagebus/network/rpc/RPCTarget.java12
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);
}
}