fixed unused code

alibaba · Jul 20, 2018 · 7b52568 · 7b52568
1 parent d520260
commit 7b52568
Show file tree

Hide file tree

Showing 2 changed files with 0 additions and 5 deletions.
diff --git a/...src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannelPool.java b/...src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannelPool.java
@@ -16,8 +16,6 @@ public static BioSocketChannel open(SocketAddress address) throws Exception {
         socket.setKeepAlive(true);
         socket.setReuseAddress(true);
         socket.connect(address, BioSocketChannel.DEFAULT_CONNECT_TIMEOUT);
-        System.out.println(socket.getReceiveBufferSize());
-        System.out.println(socket.getSendBufferSize());
         return new BioSocketChannel(socket);
     }
 

diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/DirectLogFetcher.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/dbsync/DirectLogFetcher.java
@@ -64,9 +64,6 @@ public void start(SocketChannel channel) throws IOException {
         if ("1".equals(dbsemi)) {
             issemi = true;
         }
-        // 和mysql driver一样，提供buffer机制，提升读取binlog速度
-        // this.input = new
-        // BufferedInputStream(channel.socket().getInputStream(), 16384);
     }
 
     /**