WIP

cybozu-go · Jul 10, 2024 · 76df80e · 76df80e
1 parent 8af6a69
commit 76df80e
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/clustering/operations.go b/clustering/operations.go
@@ -162,6 +162,9 @@ func (p *managerProcess) switchover(ctx context.Context, ss *StatusSet) error {
 	select {
 	case err := <-done:
 		if err != nil {
+			if errKill := pdb.KillConnections(ctx); errKill != nil {
+				return fmt.Errorf("failed to make instance %d read-only: %w, and failed to kill connections: %w", ss.Primary, err, errKill)
+			}
 			return fmt.Errorf("failed to make instance %d read-only: %w", ss.Primary, err)
 		}
 		time.Sleep(100 * time.Millisecond)