fix keepalive will not handle kick situation

close #58
LiterMC · Apr 11, 2024 · 0d0aa98 · 0d0aa98
1 parent 5e7f491
commit 0d0aa98
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/cluster.go b/cluster.go
@@ -612,8 +612,9 @@ func (cr *Cluster) KeepAlive(ctx context.Context) (ok bool) {
 		log.Errorf(Tr("error.cluster.keepalive.failed"), ero)
 		return false
 	}
+	kicked := data[1] == false
 	log.Infof(Tr("info.cluster.keepalive.success"), hits, utils.BytesToUnit((float64)(hbts)), data[1])
-	return true
+	return !kicked
 }
 
 func (cr *Cluster) disconnected() bool {