Skip to content

Commit

Permalink
return error when sender manager has been closed
Browse files Browse the repository at this point in the history
  • Loading branch information
mmcloughlin committed Oct 29, 2017
1 parent b95cfa7 commit 01b3d45
Showing 1 changed file with 6 additions and 0 deletions.
6 changes: 6 additions & 0 deletions cellio.go
Original file line number Diff line number Diff line change
Expand Up @@ -166,11 +166,17 @@ func (m *SenderManager) Add(sc CellSenderCloser) CircID {
func (m *SenderManager) AddWithID(id CircID, sc CellSenderCloser) error {
m.Lock()
defer m.Unlock()

if m.senders == nil {
return errors.New("sender manager closed")
}

_, exists := m.senders[id]
if exists {
return errors.New("cannot override existing sender id")
}
m.senders[id] = sc

return nil
}

Expand Down

0 comments on commit 01b3d45

Please sign in to comment.