chenjl/canal
1
0
Fork 0
mirror of https://github.com/alibaba/canal.git synced 2026-11-04 00:30:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

Update SocketChannelPool.java

Browse Source
This commit is contained in:
luoyaogui
2017-06-27 15:03:16 +08:00
committed by GitHub
parent 48c108806a
commit 9ea88c7863
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/SocketChannelPool.java
View File

@@ -54,7 +54,7 @@ public abstract class SocketChannelPool {
@Override @Override
public void operationComplete(ChannelFuture arg0) throws Exception { public void operationComplete(ChannelFuture arg0) throws Exception {
if(arg0.isSuccess()) if(arg0.isSuccess())
socket.setChannel(arg0.channel(),false); socket.setChannel(arg0.channel());
synchronized (socket) { synchronized (socket) {
socket.notify(); socket.notify();
} }
@@ -73,7 +73,7 @@ public abstract class SocketChannelPool {
private SocketChannel socket=null; private SocketChannel socket=null;
@Override @Override
public void channelInactive(ChannelHandlerContext ctx) throws Exception { public void channelInactive(ChannelHandlerContext ctx) throws Exception {
socket.setChannel(null,true); socket.setChannel(null);
chManager.remove(ctx.channel());//移除 chManager.remove(ctx.channel());//移除
} }
@Override @Override