internal/transport: Unlock mutex before panic (#7488)

grpc · Aug 8, 2024 · f9b96b8 · f9b96b8
1 parent d00dd8f
commit f9b96b8
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/transport/handler_server.go b/internal/transport/handler_server.go
@@ -244,6 +244,7 @@ func (ht *serverHandlerTransport) WriteStatus(s *Stream, st *status.Status) erro
 		}
 
 		s.hdrMu.Lock()
+		defer s.hdrMu.Unlock()
 		if p := st.Proto(); p != nil && len(p.Details) > 0 {
 			delete(s.trailer, grpcStatusDetailsBinHeader)
 			stBytes, err := proto.Marshal(p)
@@ -268,7 +269,6 @@ func (ht *serverHandlerTransport) WriteStatus(s *Stream, st *status.Status) erro
 				}
 			}
 		}
-		s.hdrMu.Unlock()
 	})
 
 	if err == nil { // transport has not been closed