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

fixed more info

Browse Source
This commit is contained in:
七锋
2018-11-02 12:51:36 +08:00
parent a895ce666e
commit 8597d9e926
1 changed files with 5 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
driver/src/main/java/com/alibaba/otter/canal/parse/driver/mysql/socket/BioSocketChannel.java
View File

@@ -88,8 +88,9 @@ public class BioSocketChannel implements SocketChannel {
} }
} }
if (remain > 0 && accTimeout >= timeout) { if (remain > 0 && accTimeout >= timeout) {
throw new SocketTimeoutException("Timeout occurred, failed to read " + readSize + " bytes in " + timeout throw new SocketTimeoutException("Timeout occurred, failed to read total " + readSize + " bytes in "
+ " milliseconds."); + timeout + " milliseconds, actual read only " + (readSize - remain)
+ " bytes");
} }
return data; return data;
} }
@@ -120,8 +121,8 @@ public class BioSocketChannel implements SocketChannel {
} }
if (n < len && accTimeout >= timeout) { if (n < len && accTimeout >= timeout) {
throw new SocketTimeoutException("Timeout occurred, failed to read " + len + " bytes in " + timeout throw new SocketTimeoutException("Timeout occurred, failed to read total " + len + " bytes in " + timeout
+ " milliseconds."); + " milliseconds, actual read only " + n + " bytes");
} }
} }