VOL-2001 resolve sca errors
Change-Id: Iee4c814e721437c6f2f0d3387cac92be498ceb99
diff --git a/internal/pkg/afrouter/request.go b/internal/pkg/afrouter/request.go
index 8fc15aa..dbd9968 100644
--- a/internal/pkg/afrouter/request.go
+++ b/internal/pkg/afrouter/request.go
@@ -66,7 +66,10 @@
}
}
if r.sendClosed {
- stream.CloseSend()
+ err := stream.CloseSend()
+ if err != nil {
+ log.Errorf("%v", err)
+ }
}
r.mutex.Unlock()
@@ -111,9 +114,9 @@
if err = r.sendResponseFrame(stream, frame); err != nil {
break
}
- } else { // !activeStream && !r.isStreamingRequest && !r.isStreamingResponse
- // just read & discard until the stream dies
}
+ // !activeStream && !r.isStreamingRequest && !r.isStreamingResponse
+ // just read & discard until the stream dies
}
}
}
@@ -264,7 +267,10 @@
log.Debug("Closing southbound streams")
r.sendClosed = true
for _, stream := range r.streams {
- stream.CloseSend()
+ err := stream.CloseSend()
+ if err != nil {
+ log.Errorf("%v", err)
+ }
}
r.mutex.Unlock()