Handle race condition where events are reported out of order (#115)

replicatedhq · Oct 31, 2023 · f77cc32 · f77cc32
1 parent 9eb386b
commit f77cc32
Showing 1 changed file with 10 additions and 0 deletions.
diff --git a/pkg/heartbeat/app.go b/pkg/heartbeat/app.go
@@ -6,6 +6,7 @@ import (
 	"encoding/json"
 	"fmt"
 	"net/http"
+	"sync"
 	"time"
 
 	"github.com/pkg/errors"
@@ -19,6 +20,8 @@ import (
 	"k8s.io/client-go/kubernetes"
 )
 
+var heartbeatMtx sync.Mutex
+
 func SendAppHeartbeat(clientset kubernetes.Interface, sdkStore store.Store) error {
 	license := sdkStore.GetLicense()
 
@@ -30,6 +33,13 @@ func SendAppHeartbeat(clientset kubernetes.Interface, sdkStore store.Store) erro
 		return nil
 	}
 
+	// make sure events are reported in order
+	heartbeatMtx.Lock()
+	defer func() {
+		time.Sleep(1 * time.Second)
+		heartbeatMtx.Unlock()
+	}()
+
 	heartbeatInfo := GetHeartbeatInfo(sdkStore)
 
 	if util.IsAirgap() {