如果session没有对应的connection不需要发送错误信息 #219

lealone · Jan 3, 2024 · 4671ba0 · 4671ba0
1 parent cdecc1f
commit 4671ba0
Showing 1 changed file with 10 additions and 4 deletions.
diff --git a/lealone-server/src/main/java/com/lealone/server/scheduler/SessionInfo.java b/lealone-server/src/main/java/com/lealone/server/scheduler/SessionInfo.java
@@ -140,7 +140,11 @@ YieldableCommand getYieldableCommand(boolean checkTimeout) {
     }
 
     void sendError(int packetId, Throwable e) {
-        conn.sendError(session, packetId, e);
+        // 如果session没有对应的connection不需要发送错误信息
+        if (conn != null)
+            conn.sendError(session, packetId, e);
+        else
+            logger.error("", e);
     }
 
     @Override
@@ -150,9 +154,11 @@ public void onTimeout(YieldableCommand c, Throwable e) {
 
     boolean isMarkClosed() {
         if (session.isMarkClosed()) {
-            conn.closeSession(this);
-            if (conn.getSessionCount() == 0)
-                conn.close();
+            if (conn != null) {
+                conn.closeSession(this);
+                if (conn.getSessionCount() == 0)
+                    conn.close();
+            }
             return true;
         }
         return false;