зеркало из https://github.com/Azure/go-amqp.git
Disambiguate error message (#137)
* Disambiguate error message * add logging for connWriter error
This commit is contained in:
Родитель
e4d07ca41e
Коммит
e0c6c63fb0
3
conn.go
3
conn.go
|
@ -479,7 +479,7 @@ func (c *conn) mux() {
|
|||
case *frames.PerformEnd:
|
||||
session, ok = sessionsByRemoteChannel[fr.Channel]
|
||||
if !ok {
|
||||
c.err = fmt.Errorf("%T: didn't find channel %d in sessionsByRemoteChannel", fr.Body, fr.Channel)
|
||||
c.err = fmt.Errorf("%T: didn't find channel %d in sessionsByRemoteChannel (PerformEnd)", fr.Body, fr.Channel)
|
||||
break
|
||||
}
|
||||
// we MUST remove the remote channel from our map as soon as we receive
|
||||
|
@ -701,6 +701,7 @@ func (c *conn) connWriter() {
|
|||
var err error
|
||||
for {
|
||||
if err != nil {
|
||||
debug(1, "connWriter error: %v", err)
|
||||
c.connErr <- err
|
||||
return
|
||||
}
|
||||
|
|
Загрузка…
Ссылка в новой задаче