google.golang.org/grpc/internal/transport.Stream.ctx (field)

40 uses

	google.golang.org/grpc/internal/transport (current package)
		handler_server.go#L372: 	s.ctx = peer.NewContext(ctx, pr)
		handler_server.go#L374: 		s.ctx = ht.stats.TagRPC(s.ctx, &stats.RPCTagInfo{FullMethodName: s.method})
		handler_server.go#L380: 		ht.stats.HandleRPC(s.ctx, inHeader)
		handler_server.go#L383: 		reader:        &recvBufferReader{ctx: s.ctx, ctxDone: s.ctx.Done(), recv: s.buf, freeBuffer: func(*bytes.Buffer) {}},
		http2_client.go#L390: 	s.ctx = ctx
		http2_client.go#L393: 			ctx:     s.ctx,
		http2_client.go#L394: 			ctxDone: s.ctx.Done(),
		http2_client.go#L699: 		case <-s.ctx.Done():
		http2_client.go#L700: 			return nil, ContextErr(s.ctx.Err())
		http2_client.go#L724: 		t.statsHandler.HandleRPC(s.ctx, outHeader)
		http2_client.go#L1025: 		if d, ok := s.ctx.Deadline(); ok && !d.After(time.Now()) {
		http2_client.go#L1224: 				t.statsHandler.HandleRPC(s.ctx, inHeader)
		http2_client.go#L1231: 				t.statsHandler.HandleRPC(s.ctx, inTrailer)
		http2_server.go#L336: 		s.ctx, s.cancel = context.WithTimeout(t.ctx, state.data.timeout)
		http2_server.go#L338: 		s.ctx, s.cancel = context.WithCancel(t.ctx)
		http2_server.go#L347: 	s.ctx = peer.NewContext(s.ctx, pr)
		http2_server.go#L350: 		s.ctx = metadata.NewIncomingContext(s.ctx, state.data.mdata)
		http2_server.go#L353: 		s.ctx = stats.SetIncomingTags(s.ctx, state.data.statsTags)
		http2_server.go#L356: 		s.ctx = stats.SetIncomingTrace(s.ctx, state.data.statsTrace)
		http2_server.go#L363: 		s.ctx, err = t.inTapHandle(s.ctx, info)
		http2_server.go#L417: 	s.ctx = traceCtx(s.ctx, s.method)
		http2_server.go#L419: 		s.ctx = t.stats.TagRPC(s.ctx, &stats.RPCTagInfo{FullMethodName: s.method})
		http2_server.go#L428: 		t.stats.HandleRPC(s.ctx, inHeader)
		http2_server.go#L430: 	s.ctxDone = s.ctx.Done()
		http2_server.go#L434: 			ctx:        s.ctx,
		http2_server.go#L929: 			return ContextErr(s.ctx.Err())
		http2_server.go#L944: 		return ContextErr(s.ctx.Err())
		transport.go#L241: 	ctx          context.Context    // the associated context of the stream
		transport.go#L322: 	case <-s.ctx.Done():
		transport.go#L325: 		s.ct.CloseStream(s, ContextErr(s.ctx.Err()))
		transport.go#L401: 	return s.ctx