diff options
author | OpenShift Merge Robot <openshift-merge-robot@users.noreply.github.com> | 2020-02-25 15:43:25 +0100 |
---|---|---|
committer | GitHub <noreply@github.com> | 2020-02-25 15:43:25 +0100 |
commit | 3d37dc639d87e4469a6457cf4592ff5b773d0777 (patch) | |
tree | f487a0db671b5303286a935b58577b0d50c64ab9 /vendor/github.com/docker/spdystream/connection.go | |
parent | 6babc9f20ca9e3633da1792a31d0391bde6201b6 (diff) | |
parent | 68c313911e8a3aed605a12398442212b99f41619 (diff) | |
download | podman-3d37dc639d87e4469a6457cf4592ff5b773d0777.tar.gz podman-3d37dc639d87e4469a6457cf4592ff5b773d0777.tar.bz2 podman-3d37dc639d87e4469a6457cf4592ff5b773d0777.zip |
Merge pull request #5297 from rhatdan/vendor
Update vendor of buildah and containers/common
Diffstat (limited to 'vendor/github.com/docker/spdystream/connection.go')
-rw-r--r-- | vendor/github.com/docker/spdystream/connection.go | 11 |
1 files changed, 5 insertions, 6 deletions
diff --git a/vendor/github.com/docker/spdystream/connection.go b/vendor/github.com/docker/spdystream/connection.go index 2023ecf84..6031a0db1 100644 --- a/vendor/github.com/docker/spdystream/connection.go +++ b/vendor/github.com/docker/spdystream/connection.go @@ -14,7 +14,7 @@ import ( var ( ErrInvalidStreamId = errors.New("Invalid stream id") - ErrTimeout = errors.New("Timeout occurred") + ErrTimeout = errors.New("Timeout occured") ErrReset = errors.New("Stream reset") ErrWriteClosedStream = errors.New("Write on closed stream") ) @@ -325,7 +325,7 @@ Loop: readFrame, err := s.framer.ReadFrame() if err != nil { if err != io.EOF { - debugMessage("frame read error: %s", err) + fmt.Errorf("frame read error: %s", err) } else { debugMessage("(%p) EOF received", s) } @@ -421,7 +421,7 @@ func (s *Connection) frameHandler(frameQueue *PriorityFrameQueue, newHandler Str } if frameErr != nil { - debugMessage("frame handling error: %s", frameErr) + fmt.Errorf("frame handling error: %s", frameErr) } } } @@ -451,7 +451,6 @@ func (s *Connection) addStreamFrame(frame *spdy.SynStreamFrame) { dataChan: make(chan []byte), headerChan: make(chan http.Header), closeChan: make(chan bool), - priority: frame.Priority, } if frame.CFHeader.Flags&spdy.ControlFlagFin != 0x00 { stream.closeRemoteChannels() @@ -474,7 +473,7 @@ func (s *Connection) checkStreamFrame(frame *spdy.SynStreamFrame) bool { go func() { resetErr := s.sendResetFrame(spdy.ProtocolError, frame.StreamId) if resetErr != nil { - debugMessage("reset error: %s", resetErr) + fmt.Errorf("reset error: %s", resetErr) } }() return false @@ -719,7 +718,7 @@ func (s *Connection) shutdown(closeTimeout time.Duration) { select { case err, ok := <-s.shutdownChan: if ok { - debugMessage("Unhandled close error after %s: %s", duration, err) + fmt.Errorf("Unhandled close error after %s: %s", duration, err) } default: } |