geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From kl...@apache.org
Subject [16/20] incubator-geode git commit: Added helpe function for test to know CacheClientProxy state.
Date Tue, 19 Jan 2016 18:30:04 GMT
Added helpe function for test to know CacheClientProxy state.


Project: http://git-wip-us.apache.org/repos/asf/incubator-geode/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-geode/commit/6e6861d1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-geode/tree/6e6861d1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-geode/diff/6e6861d1

Branch: refs/heads/feature/GEODE-715
Commit: 6e6861d142d69c8dea098eb2e9fc2b5b47e1c769
Parents: ecbd773
Author: Hitesh Khamesra <hkhamesra@pivotal.io>
Authored: Mon Jan 18 15:58:59 2016 -0800
Committer: Hitesh Khamesra <hkhamesra@pivotal.io>
Committed: Mon Jan 18 15:59:33 2016 -0800

----------------------------------------------------------------------
 .../cache/tier/sockets/CacheClientProxy.java    | 20 ++++++++++++++++++++
 1 file changed, 20 insertions(+)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/6e6861d1/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxy.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxy.java
b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxy.java
index 52d1cc1..5101770 100755
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxy.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/internal/cache/tier/sockets/CacheClientProxy.java
@@ -1862,6 +1862,26 @@ public class CacheClientProxy implements ClientSession {
       .append("]");
     return buffer.toString();
   }
+  
+  public String getState(){
+    StringBuffer buffer = new StringBuffer();
+    buffer.append("CacheClientProxy[")
+      // .append("client proxy id=")
+      .append(this.proxyID)
+      // .append("; client host name=")
+      // .append(this._socket.getInetAddress().getCanonicalHostName())
+      // .append("; client host address=")
+      // .append(this._remoteHostAddress)
+      .append("; port=").append(this._socket.getPort())
+      .append("; primary=").append(isPrimary)
+      .append("; version=").append(clientVersion)
+      .append("; paused=").append(isPaused())
+      .append("; alive=").append(isAlive())
+      .append("; connected=").append(isConnected())
+      .append("; isMarkedForRemoval=").append(isMarkedForRemoval)
+      .append("]");
+    return buffer.toString();
+  }
 
   public boolean isPrimary()
   {


Mime
View raw message