Gemessen nach dem letzten Deploy: Der ERSTE Zugriff auf die CIFS-Freigabe stallt
nach einem Container-Neustart mehrere Sekunden (die SMB-Sitzung wird neu
aufgebaut), danach antwortet sie in 0,01 s - zehn von zehn Versuchen, NAS per
Ping bei 0,47 ms. Die Freigabe ist also gesund, nur der erste Griff ist teuer.
In diesem Fenster lief die Pruefung in ihre Zeitgrenze, der Vorrat notierte
"keine Rohdaten", und der Knopf "Neu komprimieren" verschwand - obwohl 74 GB
dalagen. Der Nutzer haette daraus geschlossen, seine Daten seien weg. Genau
diese Sorte Fehlschluss ("aus einem Zustandswert auf einen Mechanismus") hat das
Projekt schon zweimal bezahlt.
Deshalb drei Antworten statt zwei: "da", "weg", "unklar". 124 ist der
Rueckgabewert von `timeout`, wenn es das Kind abgeschossen hat - das heisst
NICHT angesehen. Bleibt eine Pruefung unklar und der Vorrat hatte vorher einen
Treffer, wird die letzte bekannte Antwort gehalten statt Abwesenheit behauptet.
Wer eine Ja/Nein-Antwort braucht (verzeichnis_da), bekommt im Zweifel weiter
Nein - das ist die richtige Richtung fuer eine einzelne Abfrage.
Live davor geprueft: Die Schleife LEBT jetzt (alter_sekunden 30 -> 21 -> 12 -> 3
ueber 100 s) und heilt sich selbst - sobald die Freigabe antwortete, stand
mit_treffer=1 und can_retry=true.
Co-Authored-By: Claude Opus 5 <noreply@anthropic.com>
This commit is contained in:
@@ -179,3 +179,54 @@ def test_suche_mit_der_zeitgrenze_findet_den_echten_fall():
|
||||
isdir=lambda p: rohdaten.verzeichnis_da(p, laufen),
|
||||
)
|
||||
assert gefunden == [f"/app/media/rippy/{JOB}"]
|
||||
|
||||
|
||||
# --- Drei Antworten: "konnte nicht nachsehen" ist nicht "ist weg" ------------
|
||||
|
||||
|
||||
def test_pruefen_unterscheidet_drei_faelle():
|
||||
assert rohdaten.pruefen("/x", _Lauf(rc=0)) == "da"
|
||||
assert rohdaten.pruefen("/x", _Lauf(rc=2)) == "weg"
|
||||
# 124 = `timeout` hat das Kind abgeschossen (coreutils) -> nicht angesehen
|
||||
assert rohdaten.pruefen("/x", _Lauf(rc=124)) == "unklar"
|
||||
assert rohdaten.pruefen("/x", _Lauf(wirf=OSError("kein timeout"))) == "unklar"
|
||||
assert rohdaten.pruefen("", _Lauf(rc=0)) == "weg"
|
||||
|
||||
|
||||
def test_verzeichnis_da_bleibt_streng():
|
||||
"""Wer Ja/Nein braucht, bekommt im Zweifel Nein."""
|
||||
assert rohdaten.verzeichnis_da("/x", _Lauf(rc=0)) is True
|
||||
assert rohdaten.verzeichnis_da("/x", _Lauf(rc=124)) is False
|
||||
|
||||
|
||||
def test_suche_mit_status_meldet_ungepruefte_orte():
|
||||
"""Der echte Fall: Die Freigabe antwortet nicht, der lokale Ort ist leer.
|
||||
Ein leeres Ergebnis darf dann NICHT als "nichts da" gelten."""
|
||||
def pruefe(pfad):
|
||||
return "unklar" if pfad.startswith("/app/media/rippy/") else "weg"
|
||||
|
||||
e = rohdaten.suche_mit_status(
|
||||
JOB, "", listdir=lambda p: ["rippy"], pruefer=pruefe)
|
||||
assert e == {"pfade": [], "unklar": True}
|
||||
|
||||
|
||||
def test_suche_mit_status_ohne_zweifel():
|
||||
def pruefe(pfad):
|
||||
return "da" if pfad == f"/app/media/rippy/{JOB}" else "weg"
|
||||
|
||||
e = rohdaten.suche_mit_status(
|
||||
JOB, "", listdir=lambda p: ["movies", "rippy"], pruefer=pruefe)
|
||||
assert e == {"pfade": [f"/app/media/rippy/{JOB}"], "unklar": False}
|
||||
|
||||
|
||||
def test_suche_mit_status_findet_trotz_unklarem_anderen_ort():
|
||||
"""Ein Treffer bleibt ein Treffer, auch wenn ein anderer Ort schweigt."""
|
||||
def pruefe(pfad):
|
||||
if pfad == f"/app/media/rippy/{JOB}":
|
||||
return "da"
|
||||
return "unklar" if "totes-nas" in pfad else "weg"
|
||||
|
||||
e = rohdaten.suche_mit_status(
|
||||
JOB, "", listdir=lambda p: ["rippy", "totes-nas"], pruefer=pruefe)
|
||||
assert e["pfade"] == [f"/app/media/rippy/{JOB}"]
|
||||
assert e["unklar"] is True
|
||||
|
||||
Reference in New Issue
Block a user