wait time in GlobalKeyHandler now configurable

kms/kms.go

@@ -17,6 +17,7 @@ import (
 
 type Qkdnkms interface {
 	AddQuantumElement() *QuantumElement
+	GlobalKeyHandler(time.Duration) error
 }
 
 type qlElementId uint64
@@ -81,7 +82,7 @@ func (kms *eKMS) AddQuantumElement(kmsUDPAddrr string) *QuantumElement {
 	return &qle
 }
 
-func (kms *eKMS) GlobalKeyHandler() error {
+func (kms *eKMS) GlobalKeyHandler(waitTime time.Duration) error {
 
 	// periodically walk through QuantumElements and retrieve their
 	// - local key bulk buffer
@@ -110,7 +111,7 @@ func (kms *eKMS) GlobalKeyHandler() error {
 				kms.QuantumElements[currentQE].keyStoreRemote.KeyChopper256Bit(&bulkKeysLocal)
 			}
 		}
-		time.Sleep(10 * time.Second)
+		time.Sleep(waitTime)
 	}
 }
 

main.go

@@ -4,6 +4,7 @@ import (
 	"flag"
 	"log"
 	"net"
+	"time"
 
 	"code.fbi.h-da.de/m.stiemerling/proto-kms/kms"
 	"github.com/google/uuid"
@@ -70,5 +71,5 @@ func emulatedKMS(myName string, myUDPAddr string, peerUDPAddr string) {
 	myQL.QuantumElementLink.AddPeer(*udpQL2Addr)
 
 	// TODO/XXX catch errors!
-	emuKMS.GlobalKeyHandler()
+	emuKMS.GlobalKeyHandler(7 * time.Second)
 }