mirror of
https://github.com/ipfs/kubo.git
synced 2025-10-24 15:12:55 +08:00
update go-peerstream dependency
License: MIT Signed-off-by: Jeromy <jeromyj@gmail.com>
This commit is contained in:
2
Godeps/Godeps.json
generated
2
Godeps/Godeps.json
generated
@ -196,7 +196,7 @@
|
||||
},
|
||||
{
|
||||
"ImportPath": "github.com/jbenet/go-peerstream",
|
||||
"Rev": "cfdc29a19c1a209d548670f5c33c5cda2e040143"
|
||||
"Rev": "f90119e97e8be7b2bdd5e598067b0dc44df63381"
|
||||
},
|
||||
{
|
||||
"ImportPath": "github.com/jbenet/go-random",
|
||||
|
||||
11
Godeps/_workspace/src/github.com/jbenet/go-peerstream/conn.go
generated
vendored
11
Godeps/_workspace/src/github.com/jbenet/go-peerstream/conn.go
generated
vendored
@ -44,6 +44,9 @@ type Conn struct {
|
||||
|
||||
streams map[*Stream]struct{}
|
||||
streamLock sync.RWMutex
|
||||
|
||||
closed bool
|
||||
closeLock sync.Mutex
|
||||
}
|
||||
|
||||
func newConn(nconn net.Conn, tconn smux.Conn, s *Swarm) *Conn {
|
||||
@ -114,6 +117,14 @@ func (c *Conn) Streams() []*Stream {
|
||||
|
||||
// Close closes this connection
|
||||
func (c *Conn) Close() error {
|
||||
c.closeLock.Lock()
|
||||
defer c.closeLock.Unlock()
|
||||
|
||||
if c.closed {
|
||||
return nil
|
||||
}
|
||||
c.closed = true
|
||||
|
||||
// close streams
|
||||
streams := c.Streams()
|
||||
for _, s := range streams {
|
||||
|
||||
Reference in New Issue
Block a user