mirror of https://github.com/k3s-io/k3s
bump(github.com/docker/spdystream): 449fdfce4d962303d702fec724ef0ad181c92528
parent
1460f24746
commit
36243b8081
|
@ -399,7 +399,7 @@
|
|||
},
|
||||
{
|
||||
"ImportPath": "github.com/docker/spdystream",
|
||||
"Rev": "106e140db2cb50923efe088bf2906b2ee5a45fec"
|
||||
"Rev": "449fdfce4d962303d702fec724ef0ad181c92528"
|
||||
},
|
||||
{
|
||||
"ImportPath": "github.com/elazarl/go-bindata-assetfs",
|
||||
|
|
|
@ -170,6 +170,11 @@ func (s *Stream) Reset() error {
|
|||
}
|
||||
|
||||
func (s *Stream) resetStream() error {
|
||||
// Always call closeRemoteChannels, even if s.finished is already true.
|
||||
// This makes it so that stream.Close() followed by stream.Reset() allows
|
||||
// stream.Read() to unblock.
|
||||
s.closeRemoteChannels()
|
||||
|
||||
s.finishLock.Lock()
|
||||
if s.finished {
|
||||
s.finishLock.Unlock()
|
||||
|
@ -178,8 +183,6 @@ func (s *Stream) resetStream() error {
|
|||
s.finished = true
|
||||
s.finishLock.Unlock()
|
||||
|
||||
s.closeRemoteChannels()
|
||||
|
||||
resetFrame := &spdy.RstStreamFrame{
|
||||
StreamId: s.streamId,
|
||||
Status: spdy.Cancel,
|
||||
|
@ -320,7 +323,5 @@ func (s *Stream) closeRemoteChannels() {
|
|||
case <-s.closeChan:
|
||||
default:
|
||||
close(s.closeChan)
|
||||
s.dataLock.Lock()
|
||||
defer s.dataLock.Unlock()
|
||||
}
|
||||
}
|
||||
|
|
Loading…
Reference in New Issue