api/handler/rpc: fix panic on invalid error conversation (#1483)
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
parent
281cced325
commit
bad15af45d
16
stream.go
16
stream.go
@ -183,16 +183,16 @@ func writeLoop(rw io.ReadWriter, stream client.Stream) {
|
|||||||
default:
|
default:
|
||||||
buf, op, err := wsutil.ReadClientData(rw)
|
buf, op, err := wsutil.ReadClientData(rw)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
wserr := err.(wsutil.ClosedError)
|
if wserr, ok := err.(wsutil.ClosedError); ok {
|
||||||
switch wserr.Code {
|
switch wserr.Code {
|
||||||
case ws.StatusNormalClosure, ws.StatusNoStatusRcvd:
|
case ws.StatusNormalClosure, ws.StatusNoStatusRcvd:
|
||||||
return
|
return
|
||||||
default:
|
|
||||||
if logger.V(logger.ErrorLevel, logger.DefaultLogger) {
|
|
||||||
logger.Error(err)
|
|
||||||
}
|
}
|
||||||
return
|
|
||||||
}
|
}
|
||||||
|
if logger.V(logger.ErrorLevel, logger.DefaultLogger) {
|
||||||
|
logger.Error(err)
|
||||||
|
}
|
||||||
|
return
|
||||||
}
|
}
|
||||||
switch op {
|
switch op {
|
||||||
default:
|
default:
|
||||||
|
Loading…
Reference in New Issue
Block a user