Skip to content
Snippets Groups Projects

Add timeout within ksaReqHandler

Merged Malte Bauch requested to merge add-timeout-within-key-forwarding into master
3 files
+ 10
117
Compare changes
  • Side-by-side
  • Inline
Files
3
@@ -2,7 +2,9 @@ package server
import (
"encoding/json"
"fmt"
"net/http"
"time"
"code.fbi.h-da.de/danet/quant/goKMS/kms/event"
"github.com/google/uuid"
@@ -82,7 +84,14 @@ func ksaReqHandler(eventBus *event.EventBus, receiver *Receiver, generateAndSend
return
}
<-receiverChan
select {
case <-receiverChan:
case <-time.After(20 * time.Second):
http.Error(w, fmt.Sprintf("Platform Key exchange failed for RequestID: %s", kmsKeyRequest.RequestID), http.StatusInternalServerError)
logrus.Errorf("Platform Key exchange failed for RequestID: %s", kmsKeyRequest.RequestID)
return
}
err = generateAndSend(kmsKeyRequest.ReceivingCKMSID, pathId, kmsKeyRequest.RequestID, kmsKeyRequest.KeyProperties.Number)
if err != nil {
http.Error(w, err.Error(), http.StatusInternalServerError)
Loading