geode-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From upthewatersp...@apache.org
Subject [07/38] incubator-geode git commit: Now we call shutDownOutput on stream while closing the socket. We have cache close message, which doesn't have any resposne from server. Because of that some this message doesn't reach to server while closing the clien
Date Tue, 26 Jan 2016 19:38:30 GMT
Now we call shutDownOutput on stream while closing the socket. We have
cache close message, which doesn't have any resposne from server. Because
of that some this message doesn't reach to server while closing the client
connection. Thus Bruce suggested, we should call shutDownOutput on stream while
closing the connection.


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

Branch: refs/heads/wan_cq_donation
Commit: ba3c8c5793c94a31775fb6cf866f3276253f9b63
Parents: b56e23f
Author: Hitesh Khamesra <hkhamesra@pivotal.io>
Authored: Mon Jan 25 09:57:57 2016 -0800
Committer: Hitesh Khamesra <hkhamesra@pivotal.io>
Committed: Mon Jan 25 10:03:17 2016 -0800

----------------------------------------------------------------------
 .../gemstone/gemfire/cache/client/internal/ConnectionImpl.java  | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)
----------------------------------------------------------------------


http://git-wip-us.apache.org/repos/asf/incubator-geode/blob/ba3c8c57/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ConnectionImpl.java
----------------------------------------------------------------------
diff --git a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ConnectionImpl.java
b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ConnectionImpl.java
index e93d068..c2289ac 100644
--- a/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ConnectionImpl.java
+++ b/gemfire-core/src/main/java/com/gemstone/gemfire/cache/client/internal/ConnectionImpl.java
@@ -184,8 +184,11 @@ public class ConnectionImpl implements Connection {
       endpoint.removeReference();
     }
     try {
-      if (theSocket != null)
+      if (theSocket != null) {
+        theSocket.getOutputStream().flush();
+        theSocket.shutdownOutput();
         theSocket.close();
+      }
     }
     catch (Exception e) {
       if (logger.isDebugEnabled()) {


Mime
View raw message