remove test panic

Author: zyxkad

cluster.go

@@ -333,33 +333,37 @@ func (cr *Cluster) Disable(ctx context.Context) (ok bool) {
 	{
 		logInfo("Making keepalive before disable")
 		tctx, cancel := context.WithTimeout(ctx, time.Second*10)
-		cr.KeepAlive(tctx)
+		ok = cr.KeepAlive(tctx)
 		cancel()
+		if ok {
+			tctx, cancel := context.WithTimeout(ctx, time.Second*10)
+			data, err := cr.socket.EmitAckContext(tctx, "disable")
+			cancel()
+			if err != nil {
+				logErrorf("Disable failed: %v", err)
+				ok = false
+			} else {
+				logDebug("disable ack:", data)
+				if ero := data[0]; ero != nil {
+					logErrorf("Disable failed: %v", ero)
+					ok = false
+				} else if !data[1].(bool) {
+					logError("Disable failed: acked non true value")
+					ok = false
+				}
+			}
+		} else {
+			logWarn("Keep alive failed, disable without send packet")
+			ok = true
+		}
 	}
 
-	tctx, cancel := context.WithTimeout(ctx, time.Second*10)
-	data, err := cr.socket.EmitAckContext(tctx, "disable")
-	cancel()
-
 	cr.enabled.Store(false)
 	go cr.socket.Close()
 	cr.socket = nil
 	close(cr.disabled)
-	if err != nil {
-		logErrorf("Disable failed: %v", err)
-		return false
-	}
-	logDebug("disable ack:", data)
-	if ero := data[0]; ero != nil {
-		logErrorf("Disable failed: %v", ero)
-		return false
-	}
-	if !data[1].(bool) {
-		logError("Disable failed: ack non true value")
-		return false
-	}
 	logWarn("Cluster disabled")
-	return true
+	return
 }
 
 func (cr *Cluster) Disabled() <-chan struct{} {

logger.go

@@ -139,5 +139,4 @@ func startFlushLogFile() {
 			}
 		}
 	}()
-	panic("test panic")
 }