Skip to content

Commit

Permalink
Merge PR #769: Use a more meaningful value for the size of the buffer…
Browse files Browse the repository at this point in the history
…ed channel
  • Loading branch information
jtieri authored Jun 3, 2022
1 parent 32d77f0 commit ea011db
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions relayer/strategies.go
Original file line number Diff line number Diff line change
Expand Up @@ -31,8 +31,6 @@ func StartRelayer(ctx context.Context, log *zap.Logger, src, dst *Chain, filter
func relayerMainLoop(ctx context.Context, log *zap.Logger, src, dst *Chain, filter ChannelFilter, maxTxSize, maxMsgLength uint64, errCh chan<- error) {
defer close(errCh)

channels := make(chan *ActiveChannel, 10)

// Query the list of channels on the src connection.
srcChannels, err := queryChannelsOnConnection(ctx, src)
if err != nil {
Expand All @@ -45,6 +43,8 @@ func relayerMainLoop(ctx context.Context, log *zap.Logger, src, dst *Chain, filt
return
}

channels := make(chan *ActiveChannel, len(srcChannels))

// Apply the channel filter rule (i.e. build allowlist, denylist or relay on all channels available),
// then filter out only the channels in the OPEN state.
srcChannels = applyChannelFilterRule(filter, srcChannels)
Expand Down

0 comments on commit ea011db

Please sign in to comment.