Skip to content

Commit

Permalink
Address comments
Browse files Browse the repository at this point in the history
  • Loading branch information
cedric-cordenier committed Jun 19, 2024
1 parent bd5b0a6 commit 23c6d3d
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 2 deletions.
2 changes: 1 addition & 1 deletion core/capabilities/remote/dispatcher.go
Original file line number Diff line number Diff line change
Expand Up @@ -99,7 +99,7 @@ func (d *dispatcher) SetReceiver(capabilityId string, donId string, rec remotety
k := key{capabilityId, donId}
_, ok := d.receivers[k]
if ok {
return fmt.Errorf("%w: capability %s and don %s", ErrReceiverExists, capabilityId, donId)
return ErrReceiverExists
}

receiverCh := make(chan *remotetypes.MessageBody, receiverBufferSize)
Expand Down
2 changes: 1 addition & 1 deletion core/capabilities/syncer.go
Original file line number Diff line number Diff line change
Expand Up @@ -546,7 +546,7 @@ func (s *registrySyncer) addReceiver(ctx context.Context, capability kcr.Capabil
if errors.Is(err, remote.ErrReceiverExists) {
// If a receiver already exists, let's log the error for debug purposes, but
// otherwise short-circuit here. We've handled this capability in a previous iteration.
s.lggr.Debugf("failed to set receiver for cap ID %s and don ID %d: %s", fullCapID, don.Id, err)
s.lggr.Debugf("receiver already exists for cap ID %s and don ID %d: %s", fullCapID, don.Id, err)
return nil
} else if err != nil {
return err
Expand Down

0 comments on commit 23c6d3d

Please sign in to comment.