google.golang.org/grpc/internal/transport.decodeState.data (field)

63 uses

	google.golang.org/grpc/internal/transport (current package)
		http2_client.go#L1208: 	state.data.isGRPC = !initialHeader
		http2_client.go#L1245: 			s.recvCompress = state.data.encoding
		http2_client.go#L1246: 			if len(state.data.mdata) > 0 {
		http2_client.go#L1247: 				s.header = state.data.mdata
		http2_client.go#L1262: 	t.closeStream(s, io.EOF, rst, http2.ErrCodeNo, state.status(), state.data.mdata, true)
		http2_server.go#L327: 		recvCompress:   state.data.encoding,
		http2_server.go#L328: 		method:         state.data.method,
		http2_server.go#L329: 		contentSubtype: state.data.contentSubtype,
		http2_server.go#L335: 	if state.data.timeoutSet {
		http2_server.go#L336: 		s.ctx, s.cancel = context.WithTimeout(t.ctx, state.data.timeout)
		http2_server.go#L349: 	if len(state.data.mdata) > 0 {
		http2_server.go#L350: 		s.ctx = metadata.NewIncomingContext(s.ctx, state.data.mdata)
		http2_server.go#L352: 	if state.data.statsTags != nil {
		http2_server.go#L353: 		s.ctx = stats.SetIncomingTags(s.ctx, state.data.statsTags)
		http2_server.go#L355: 	if state.data.statsTrace != nil {
		http2_server.go#L356: 		s.ctx = stats.SetIncomingTrace(s.ctx, state.data.statsTrace)
		http2_server.go#L361: 			FullMethodName: state.data.method,
		http2_server.go#L426: 			Header:      metadata.MD(state.data.mdata).Copy(),
		http_util.go#L148: 	data parsedHeaderData
		http_util.go#L189: 	if d.data.statusGen == nil {
		http_util.go#L191: 		d.data.statusGen = status.New(codes.Code(int32(*(d.data.rawStatusCode))), d.data.rawStatusMsg)
		http_util.go#L193: 	return d.data.statusGen
		http_util.go#L236: 	if d.data.isGRPC {
		http_util.go#L237: 		if d.data.grpcErr != nil {
		http_util.go#L238: 			return d.data.grpcErr
		http_util.go#L243: 		if d.data.rawStatusCode == nil && d.data.statusGen == nil {
		http_util.go#L251: 			d.data.rawStatusCode = &code
		http_util.go#L257: 	if d.data.httpErr != nil {
		http_util.go#L258: 		return d.data.httpErr
		http_util.go#L266: 	if d.data.httpStatus != nil {
		http_util.go#L267: 		code, ok = HTTPStatusConvTab[*(d.data.httpStatus)]
		http_util.go#L281: 	if d.data.httpStatus == nil {
		http_util.go#L284: 		errMsgs = append(errMsgs, fmt.Sprintf("%s: HTTP status code %d", http.StatusText(*(d.data.httpStatus)), *d.data.httpStatus))
		http_util.go#L287: 	if d.data.contentTypeErr == "" {
		http_util.go#L290: 		errMsgs = append(errMsgs, d.data.contentTypeErr)
		http_util.go#L297: 	if d.data.mdata == nil {
		http_util.go#L298: 		d.data.mdata = make(map[string][]string)
		http_util.go#L300: 	d.data.mdata[k] = append(d.data.mdata[k], v)
		http_util.go#L308: 			d.data.contentTypeErr = fmt.Sprintf("transport: received the unexpected content-type %q", f.Value)
		http_util.go#L311: 		d.data.contentSubtype = contentSubtype
		http_util.go#L317: 		d.data.isGRPC = true
		http_util.go#L319: 		d.data.encoding = f.Value
		http_util.go#L323: 			d.data.grpcErr = status.Errorf(codes.Internal, "transport: malformed grpc-status: %v", err)
		http_util.go#L326: 		d.data.rawStatusCode = &code
		http_util.go#L328: 		d.data.rawStatusMsg = decodeGrpcMessage(f.Value)
		http_util.go#L332: 			d.data.grpcErr = status.Errorf(codes.Internal, "transport: malformed grpc-status-details-bin: %v", err)
		http_util.go#L337: 			d.data.grpcErr = status.Errorf(codes.Internal, "transport: malformed grpc-status-details-bin: %v", err)
		http_util.go#L340: 		d.data.statusGen = status.FromProto(s)
		http_util.go#L342: 		d.data.timeoutSet = true
		http_util.go#L344: 		if d.data.timeout, err = decodeTimeout(f.Value); err != nil {
		http_util.go#L345: 			d.data.grpcErr = status.Errorf(codes.Internal, "transport: malformed time-out: %v", err)
		http_util.go#L348: 		d.data.method = f.Value
		http_util.go#L352: 			d.data.httpErr = status.Errorf(codes.Internal, "transport: malformed http-status: %v", err)
		http_util.go#L355: 		d.data.httpStatus = &code
		http_util.go#L359: 			d.data.grpcErr = status.Errorf(codes.Internal, "transport: malformed grpc-tags-bin: %v", err)
		http_util.go#L362: 		d.data.statsTags = v
		http_util.go#L367: 			d.data.grpcErr = status.Errorf(codes.Internal, "transport: malformed grpc-trace-bin: %v", err)
		http_util.go#L370: 		d.data.statsTrace = v