Skip to content

Commit

Permalink
xrootd/internal/mux: make channels unbuffered in both Claim{,WithID}
Browse files Browse the repository at this point in the history
  • Loading branch information
EgorMatirov authored and sbinet committed May 30, 2018
1 parent ca05e46 commit cf5e5b5
Showing 1 changed file with 1 addition and 1 deletion.
2 changes: 1 addition & 1 deletion xrootd/internal/mux/mux.go
Expand Up @@ -145,7 +145,7 @@ func (m *Mux) ClaimWithID(id protocol.StreamID) (DataRecvChan, error) {
if m.closed {
return nil, errors.New("mux: ClaimWithID was called on closed Mux")
}
ch := make(chan ServerResponse, 1)
ch := make(chan ServerResponse)

if _, claimed := m.dataWaiters[id]; claimed {
return nil, errors.Errorf("mux: channel with id %s is already claimed", id)
Expand Down

0 comments on commit cf5e5b5

Please sign in to comment.