挎包也当做收到报文，进行透传

zwyqz · Aug 17, 2017 · 12b9147 · 12b9147
1 parent 142cc44
commit 12b9147
Showing 1 changed file with 10 additions and 11 deletions.
diff --git a/source/src/main/java/io/mycat/mycat2/net/DefaultMycatSessionHandler.java b/source/src/main/java/io/mycat/mycat2/net/DefaultMycatSessionHandler.java
@@ -2,27 +2,26 @@
 
 import java.io.IOException;
 import java.net.InetSocketAddress;
-import java.nio.ByteBuffer;
 import java.nio.channels.SelectionKey;
 import java.nio.channels.SocketChannel;
-import java.nio.charset.StandardCharsets;
 import java.util.HashMap;
 import java.util.Map;
 
-import io.mycat.mycat2.sqlparser.NewSQLContext;
-import io.mycat.mycat2.sqlparser.NewSQLParser;
-import io.mycat.mysql.packet.MySQLPacket;
-import io.mycat.mycat2.beans.MySQLDataSource;
-import io.mycat.mycat2.cmds.QueryCmdProcessImpl;
-import io.mycat.mycat2.cmds.SQLComandProcessInf;
-import io.mycat.proxy.*;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import io.mycat.mycat2.MySQLSession;
+import io.mycat.mycat2.beans.MySQLDataSource;
+import io.mycat.mycat2.cmds.QueryCmdProcessImpl;
+import io.mycat.mycat2.cmds.SQLComandProcessInf;
 import io.mycat.mycat2.tasks.BackendConCreateTask;
 import io.mycat.mycat2.tasks.BackendSynchronzationTask;
 import io.mycat.mysql.packet.ErrorPacket;
+import io.mycat.mysql.packet.MySQLPacket;
+import io.mycat.proxy.BackendIOHandler;
+import io.mycat.proxy.FrontIOHandler;
+import io.mycat.proxy.ProxyBuffer;
+import io.mycat.proxy.UserProxySession;
 
 /**
  * 负责MycatSession的NIO事件，驱动SQLCommand命令执行，完成SQL的处理过程
@@ -135,8 +134,8 @@ public void onBackendRead(MySQLSession session) throws IOException {
 
 		ProxyBuffer backendBuffer = session.frontBuffer;
 
-		if (session.resolveMySQLPackage(backendBuffer, session.curFrontMSQLPackgInf, false) == false) {
-			// 没有读到完整报文
+		if (session.resolveMySQLPackage(backendBuffer, session.curFrontMSQLPackgInf, false) == false||!session.curFrontMSQLPackgInf.crossBuffer) {
+			// 没有读到完整报文, 也不是挎包
 			return;
 		}