add LLR votes for right epoch only

gossip/emitter/emitter_llr.go

@@ -29,22 +29,26 @@ func (em *Emitter) addLlrBlockVotes(e *inter.MutableEventPayload) {
 	if prevInFile != nil && start < *prevInFile+1 {
 		start = *prevInFile + 1
 	}
-	records := make([]hash.Hash, 0, 16)
+	records := make([]hash.Hash, 0, basiccheck.MaxBlockVotesPerEvent)
 	epochEnd := false
 	var epoch idx.Epoch
 	for b := start; len(records) < basiccheck.MaxBlockVotesPerEvent; b++ {
-		record := em.world.GetBlockRecordHash(b)
-		if record == nil {
-			break
-		}
 		blockEpoch := em.world.GetBlockEpoch(b)
 		if epoch == 0 {
+			if !em.isEpochValidator(blockEpoch) {
+				continue
+			}
 			epoch = blockEpoch
+			start = b
 		}
 		if epoch != blockEpoch || blockEpoch == 0 {
 			epochEnd = true
 			break
 		}
+		record := em.world.GetBlockRecordHash(b)
+		if record == nil {
+			break
+		}
 		records = append(records, *record)
 	}
 
@@ -73,6 +77,9 @@ func (em *Emitter) addLlrEpochVote(e *inter.MutableEventPayload) {
 	if prevInFile != nil && target < *prevInFile+1 {
 		target = *prevInFile + 1
 	}
+	if !em.isEpochValidator(target) {
+		return
+	}
 	vote := em.world.GetEpochRecordHash(target)
 	if vote == nil {
 		return
@@ -106,3 +113,13 @@ func (em *Emitter) skipLlrEpochVote() bool {
 	// otherwise, poor validators have a small chance to vote
 	return rand.Intn(30) != 0
 }
+
+func (em *Emitter) isEpochValidator(epoch idx.Epoch) bool {
+	es := em.world.GetHistoryEpochState(epoch)
+	if es == nil {
+		return false
+	}
+
+	_, ok := es.ValidatorProfiles[em.config.Validator.ID]
+	return ok
+}

gossip/emitter/world.go

@@ -12,6 +12,7 @@ import (
 	"github.com/ethereum/go-ethereum/core/types"
 
 	"github.com/Fantom-foundation/go-opera/inter"
+	"github.com/Fantom-foundation/go-opera/inter/iblockproc"
 	"github.com/Fantom-foundation/go-opera/opera"
 	"github.com/Fantom-foundation/go-opera/valkeystore"
 	"github.com/Fantom-foundation/go-opera/vecmt"
@@ -69,6 +70,7 @@ type Reader interface {
 	LlrReader
 	GetLatestBlockIndex() idx.Block
 	GetEpochValidators() (*pos.Validators, idx.Epoch)
+	GetHistoryEpochState(epoch idx.Epoch) *iblockproc.EpochState
 	GetEvent(hash.Event) *inter.Event
 	GetEventPayload(hash.Event) *inter.EventPayload
 	GetLastEvent(epoch idx.Epoch, from idx.ValidatorID) *hash.Event