Skip to content

Commit 2123ab3

Browse files
author
夜色
committed
add test branch
1 parent d850bea commit 2123ab3

File tree

2 files changed

+4
-4
lines changed

2 files changed

+4
-4
lines changed

src/main/java/com/mpush/client/DefaultClientListener.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -71,7 +71,7 @@ public void run() {
7171
} else {
7272
//do heathCheck
7373
}
74-
client.getConnection().getReader().stopRead();//防止线程膨胀
74+
//client.getConnection().getReader().stopRead();//防止线程膨胀
7575
//client.bindUser(ClientConfig.I.getUserId());
7676
}
7777

src/main/java/com/mpush/codec/AsyncPacketReader.java

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -80,8 +80,8 @@ public void run() {
8080
in.compact();
8181
}
8282
} finally {
83-
//logger.w("read an error, do reconnect!!!");
84-
//connection.reconnect();
83+
logger.w("read an error, do reconnect!!!");
84+
connection.reconnect();
8585
}
8686
}
8787

@@ -99,7 +99,7 @@ private boolean read(SocketChannel channel, ByteBuffer in) {
9999
readCount = channel.read(in);
100100
connection.setLastReadTime();
101101
} catch (IOException e) {
102-
//logger.e(e, "read packet ex, do reconnect");
102+
logger.e(e, "read packet ex, do reconnect");
103103
readCount = -1;
104104
}
105105
return readCount > 0;

0 commit comments

Comments
 (0)