From 152b43cb72013293aeef8eca8793312ad4275303 Mon Sep 17 00:00:00 2001
From: Malte Bauch <malte.bauch@h-da.de>
Date: Fri, 30 Aug 2024 08:03:11 +0000
Subject: [PATCH] Resolve "Trying to access QM / Syncing Keys with Peer should
not fully timeout after x attempts"
See merge request danet/quant!200
---
goKMS/kms/peers/etsi14Quantummodule.go | 13 ++-----------
1 file changed, 2 insertions(+), 11 deletions(-)
diff --git a/goKMS/kms/peers/etsi14Quantummodule.go b/goKMS/kms/peers/etsi14Quantummodule.go
index c2af3318..a53e5053 100644
--- a/goKMS/kms/peers/etsi14Quantummodule.go
+++ b/goKMS/kms/peers/etsi14Quantummodule.go
@@ -113,17 +113,9 @@ func (qm *ETSI014HTTPQuantumModule) Initialize() error {
ticker := time.NewTicker(restartWaitingTime)
defer ticker.Stop()
- restartedAfterWaitingTime := new(int)
-
// immediately start with the ticker instead of waiting the defined amount
for ; true; <-ticker.C {
- if *restartedAfterWaitingTime == 5 {
- log.Fatalf("Stopped retrying to fetch keys after %d attempts waiting %v each time in between.", restartedAfterWaitingTime, restartWaitingTime)
- break
- }
-
- qm.doKeyFetching(restartedAfterWaitingTime)
- *restartedAfterWaitingTime++
+ qm.doKeyFetching()
}
}()
}
@@ -184,7 +176,7 @@ func (qm *ETSI014HTTPQuantumModule) GetKeyWithIds(keyIds []etsi14ClientGenerated
return container, nil
}
-func (qm *ETSI014HTTPQuantumModule) doKeyFetching(restartedAfterWaitingTime *int) {
+func (qm *ETSI014HTTPQuantumModule) doKeyFetching() {
ticker := time.NewTicker(time.Duration(qm.keyFetchInterval) * time.Second)
defer ticker.Stop()
@@ -230,7 +222,6 @@ func (qm *ETSI014HTTPQuantumModule) doKeyFetching(restartedAfterWaitingTime *int
}
failedAttemps = 0
- *restartedAfterWaitingTime = 0
}
}
}
--
GitLab