diff --git a/kms/kmspeers.go b/kms/kmspeers.go index de1361dca6a0879b407f2dd6fcee998f63b1933a..6e42f8f78e47394572c9be6ab3e22affd27ff930 100644 --- a/kms/kmspeers.go +++ b/kms/kmspeers.go @@ -229,7 +229,8 @@ func (ph *kmsPeer) TransportKeyNegotiation() error { } func (ph *kmsPeer) SendPayload(payload []byte, pathId uuid.UUID) error { - if len(ph.servingQLE.keyStorePeer.keyStore) == int(ph.servingQLE.keyStorePeer.indexCounter-1) { + if len(ph.servingQLE.keyStorePeer.keyStore) <= int(ph.servingQLE.keyStorePeer.indexCounter) { + log.Debug("Syncing bulk keys before sending the payload") err := ph.SyncBulkKeys() if err != nil { return err