From 1f5f708a628730fa0d69aaa51496572731c83157 Mon Sep 17 00:00:00 2001
From: Magnus Root <magnusroot@inbox.ru>
Date: Wed, 25 Feb 2026 14:47:25 +0300
Subject: [PATCH] Fix

---
 drain.go | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/drain.go b/drain.go
index 7b7627f..5d86a5a 100644
--- a/drain.go
+++ b/drain.go
@@ -95,7 +95,7 @@ func processAllDrainingContainersGlobally(db *sql.DB, hostname string) {
 		clientInfo, err := getClientInfoByClientTitle(db, clientTitle)
 		if err != nil {
 			log.Printf("    ⚠ Ошибка получения данных клиента из БД: %v", err)
-			checkAndProcessExistingDrainMarkers(clientTitle, &processedClients)
+			checkAndProcessExistingDrainMarkers(clientTitle, 0, &processedClients)
 			continue
 		}
 
@@ -150,7 +150,7 @@ func processAllDrainingContainersGlobally(db *sql.DB, hostname string) {
 			processedClients++
 		} else {
 			log.Printf("    ✓ Клиент должен быть здесь, проверяю устаревшие drain-маркеры")
-			checkAndProcessExistingDrainMarkers(clientTitle, &processedClients)
+			checkAndProcessExistingDrainMarkers(clientTitle, clientInfo.ContainersCount, &processedClients)
 		}
 	}
 
@@ -165,7 +165,7 @@ func processAllDrainingContainersGlobally(db *sql.DB, hostname string) {
 	processDrainingAngieConfigs()
 }
 
-func checkAndProcessExistingDrainMarkers(clientTitle string, processedCount *int) {
+func checkAndProcessExistingDrainMarkers(clientTitle string, containersCount int, processedCount *int) {
 	hasAnyDrainMarkers := false
 	for containerNum := 1; containerNum <= MaxContainersPerClient; containerNum++ {
 		if _, err := os.Stat(fmt.Sprintf("/tmp/ptaf-drain-ptaf_%s_%03d", clientTitle, containerNum)); err == nil {
@@ -180,7 +180,7 @@ func checkAndProcessExistingDrainMarkers(clientTitle string, processedCount *int
 	}
 	if hasAnyDrainMarkers {
 		log.Printf("    → Найдены drain-маркеры, обрабатываю")
-		processDrainingContainers(clientTitle, 0)
+		processDrainingContainers(clientTitle, containersCount)
 		*processedCount++
 	}
 }