(stream *transport.ServerStream, ti *traceInfo)
| 1780 | } |
| 1781 | |
| 1782 | func (s *Server) handleMalformedMethodName(stream *transport.ServerStream, ti *traceInfo) { |
| 1783 | if ti != nil { |
| 1784 | ti.tr.LazyLog(&fmtStringer{"Malformed method name %q", []any{stream.Method()}}, true) |
| 1785 | ti.tr.SetError() |
| 1786 | } |
| 1787 | errDesc := fmt.Sprintf("malformed method name: %q", stream.Method()) |
| 1788 | if err := stream.WriteStatus(status.New(codes.Unimplemented, errDesc)); err != nil { |
| 1789 | if ti != nil { |
| 1790 | ti.tr.LazyLog(&fmtStringer{"%v", []any{err}}, true) |
| 1791 | ti.tr.SetError() |
| 1792 | } |
| 1793 | channelz.Warningf(logger, s.channelz, "grpc: Server.handleStream failed to write status: %v", err) |
| 1794 | } |
| 1795 | if ti != nil { |
| 1796 | ti.tr.Finish() |
| 1797 | } |
| 1798 | } |
| 1799 | |
| 1800 | func (s *Server) handleStream(t transport.ServerTransport, stream *transport.ServerStream) { |
| 1801 | ctx := stream.Context() |
no test coverage detected