Prevented BinaryLogClient from getting stuck while in "pre-close"

shyiko · shyiko · commit 535b651903ce · 2015-05-19T18:39:50.000+03:00
diff --git a/src/main/java/com/github/shyiko/mysql/binlog/network/protocol/PacketChannel.java b/src/main/java/com/github/shyiko/mysql/binlog/network/protocol/PacketChannel.java
@@ -75,6 +75,12 @@ public boolean isOpen() {
 
     @Override
     public void close() throws IOException {
+        try { 
+            socket.shutdownInput(); // for socketInputStream.setEOF(true)
+        } catch (Exception ignore) {}
+        try { 
+            socket.shutdownOutput(); 
+        } catch (Exception ignore) {}
         socket.close();
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -75,6 +75,12 @@ public boolean isOpen() {`
`75`	`75`
`76`	`76`	`@Override`
`77`	`77`	`public void close() throws IOException {`
	`78`	`+ try {`
	`79`	`+ socket.shutdownInput(); // for socketInputStream.setEOF(true)`
	`80`	`+ } catch (Exception ignore) {}`
	`81`	`+ try {`
	`82`	`+ socket.shutdownOutput();`
	`83`	`+ } catch (Exception ignore) {}`
`78`	`84`	`socket.close();`
`79`	`85`	`}`
`80`	`86`	`}`