1.0.7 2017.1.10

1.修复killChannel的问题 2.修复读取数据递归问题
brucexx · Jan 10, 2017 · 14431f2 · 14431f2
1 parent 1d41dfc
commit 14431f2
Showing 1 changed file with 6 additions and 6 deletions.
diff --git a/src/main/server/com/baidu/hsb/mysql/bio/executor/SingleNodeExecutor.java b/src/main/server/com/baidu/hsb/mysql/bio/executor/SingleNodeExecutor.java
@@ -299,7 +299,7 @@ private void handleRowData(RouteResultsetNode rrn, BlockingSession ss, MySQLChan
  final ServerConnection sc = ss.getSource();
  this.packetId = id;
  BinaryPacket bin = null;
- int size = 0;
+// int size = 0;
  try {
  for (;;) {
  bin = mc.receive();
@@ -328,11 +328,11 @@ private void handleRowData(RouteResultsetNode rrn, BlockingSession ss, MySQLChan
  default:
  bin.packetId = ++packetId;// ROWS
  bb = bin.write(bb, sc);
- size += bin.packetLength;
- if (size > RECEIVE_CHUNK_SIZE) {
- handleNext(rrn, ss, mc, bb, packetId);
- return;
- }
+// size += bin.packetLength;
+// if (size > RECEIVE_CHUNK_SIZE) {
+// handleNext(rrn, ss, mc, bb, packetId);
+// return;
+// }
  }
  }
  } catch (IOException e) {