Skip to content

Commit

Permalink
Merge pull request #2052 from OffchainLabs/fix-relay-memory-leak
Browse files Browse the repository at this point in the history
Fix memory leak in relay
  • Loading branch information
PlasmaPower committed Dec 23, 2023
2 parents fef6581 + e0f35dd commit 63bcedc
Showing 1 changed file with 3 additions and 5 deletions.
8 changes: 3 additions & 5 deletions broadcaster/backlog/backlog.go
Original file line number Diff line number Diff line change
Expand Up @@ -77,7 +77,6 @@ func (b *backlog) Append(bm *m.BroadcastMessage) error {
nextSegment := newBacklogSegment()
segment.nextSegment.Store(nextSegment)
prevMsgIdx = segment.End()
nextSegment.previousSegment.Store(segment)
segment = nextSegment
b.tail.Store(segment)
}
Expand Down Expand Up @@ -253,10 +252,9 @@ type BacklogSegment interface {
// backlogSegment stores messages up to a limit defined by the backlog. It also
// points to the next backlogSegment in the list.
type backlogSegment struct {
messagesLock sync.RWMutex
messages []*m.BroadcastFeedMessage
nextSegment atomic.Pointer[backlogSegment]
previousSegment atomic.Pointer[backlogSegment]
messagesLock sync.RWMutex
messages []*m.BroadcastFeedMessage
nextSegment atomic.Pointer[backlogSegment]
}

// newBacklogSegment creates a backlogSegment object with an empty slice of
Expand Down

0 comments on commit 63bcedc

Please sign in to comment.