google.golang.org/grpc/internal/transport.Stream.Context (method)

21 uses

	google.golang.org/grpc/internal/transport (current package)
		handler_server.go#L235: 			ht.stats.HandleRPC(s.Context(), &stats.OutTrailer{
		handler_server.go#L321: 			ht.stats.HandleRPC(s.Context(), &stats.OutHeader{
		http2_server.go#L837: 		t.stats.HandleRPC(s.Context(), outHeader)
		http2_server.go#L901: 		t.stats.HandleRPC(s.Context(), &stats.OutTrailer{
		transport.go#L400: func (s *Stream) Context() context.Context {

	google.golang.org/grpc
		rpc_util.go#L244: 	if x, ok := peer.FromContext(attempt.s.Context()); ok {
		server.go#L917: 	tr, ok := trace.FromContext(stream.Context())
		server.go#L929: 	if dl, ok := stream.Context().Deadline(); ok {
		server.go#L1000: 		s.opts.statsHandler.HandleRPC(stream.Context(), outPayload(false, msg, data, payload, time.Now()))
		server.go#L1051: 			sh.HandleRPC(stream.Context(), statsBegin)
		server.go#L1083: 				sh.HandleRPC(stream.Context(), end)
		server.go#L1098: 		ctx := stream.Context()
		server.go#L1175: 			sh.HandleRPC(stream.Context(), &stats.InPayload{
		server.go#L1193: 	ctx := NewContextWithServerTransportStream(stream.Context(), stream)
		server.go#L1331: 		sh.HandleRPC(stream.Context(), statsBegin)
		server.go#L1333: 	ctx := NewContextWithServerTransportStream(stream.Context(), stream)
		server.go#L1368: 				sh.HandleRPC(stream.Context(), end)
		stream.go#L605: 	return cs.attempt.s.Context()
		stream.go#L1169: 	return as.s.Context()
		stream.go#L1459: 		ss.statsHandler.HandleRPC(ss.s.Context(), outPayload(false, m, data, payload, time.Now()))
		stream.go#L1509: 		ss.statsHandler.HandleRPC(ss.s.Context(), &stats.InPayload{