Skip to content

Commit

Permalink
Update distributor.go
Browse files Browse the repository at this point in the history
  • Loading branch information
kc1116 committed Jul 8, 2024
1 parent fc4df7b commit 5d935c9
Showing 1 changed file with 4 additions and 4 deletions.
8 changes: 4 additions & 4 deletions state/protocol/events/distributor.go
Original file line number Diff line number Diff line change
Expand Up @@ -67,11 +67,11 @@ func (d *Distributor) EpochCommittedPhaseStarted(currentEpochCounter uint64, fir
}
}

func (d *Distributor) EpochFallbackModeTriggered(epochCounter uint64, header *flow.Header) {
func (d *Distributor) EpochFallbackModeTriggered(epoch uint64, header *flow.Header) {
d.mu.RLock()
defer d.mu.RUnlock()
for _, sub := range d.subscribers {
sub.EpochFallbackModeTriggered(epochCounter, header)
sub.EpochFallbackModeTriggered(epoch, header)
}
}

Expand All @@ -83,10 +83,10 @@ func (d *Distributor) EpochFallbackModeExited(epochCounter uint64, header *flow.
}
}

func (d *Distributor) EpochExtended(epoch uint64, header *flow.Header, extension flow.EpochExtension) {
func (d *Distributor) EpochExtended(epochCounter uint64, header *flow.Header, extension flow.EpochExtension) {
d.mu.RLock()
defer d.mu.RUnlock()
for _, sub := range d.subscribers {
sub.EpochExtended(epoch, header, extension)
sub.EpochExtended(epochCounter, header, extension)
}
}

0 comments on commit 5d935c9

Please sign in to comment.