drpcmanager: cancel stream with error when terminated

Terminations were canceling streams with `context.Canceled` instead of surfacing the error, causing unexpected behavior.
storj · Apr 24, 2022 · c366353 · c366353
1 parent 41e8fa5
commit c366353
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/drpcmanager/manager.go b/drpcmanager/manager.go
@@ -291,7 +291,8 @@ func (m *Manager) manageStream(ctx context.Context, stream *drpcstream.Stream) {
 
 	select {
 	case <-m.sigs.term.Signal():
-		stream.Cancel(context.Canceled)
+		err, _ := m.sigs.term.Get()
+		stream.Cancel(err)
 		<-m.sterm
 		return