Method TarsInvoke

tars/servant.go:116–225

TarsInvoke is used for client invoking server.

(ctx context.Context, cType byte,
	sFuncName string,
	buf []byte,
	status map[string]string,
	reqContext map[string]string,
	resp *requestf.ResponsePacket)

// TarsInvoke is used for client invoking server.
func (s *ServantProxy) TarsInvoke(ctx context.Context, cType byte,
	sFuncName string,
	buf []byte,
	status map[string]string,
	reqContext map[string]string,
	resp *requestf.ResponsePacket) error {
	defer CheckPanic()

	// 将ctx中的dyeing信息传入到request中
	var msgType int32
	if dyeingKey, ok := current.GetDyeingKey(ctx); ok {
		TLOG.Debug("dyeing debug: find dyeing key:", dyeingKey)
		if status == nil {
			status = make(map[string]string)
		}
		status[current.StatusDyedKey] = dyeingKey
		msgType |= basef.TARSMESSAGETYPEDYED
	}

	// 将ctx中的trace信息传入到request中
	if trace, ok := current.GetTarsTrace(ctx); ok && trace.Call() {
		traceKey := trace.GetTraceFullKey(false)
		TLOG.Debug("trace debug: find trace key:", traceKey)
		if status == nil {
			status = make(map[string]string)
		}
		status[current.StatusTraceKey] = traceKey
		msgType |= basef.TARSMESSAGETYPETRACE
	}

	req := requestf.RequestPacket{
		IVersion:     s.version,
		CPacketType:  int8(cType),
		IRequestId:   s.genRequestID(),
		SServantName: s.name,
		SFuncName:    sFuncName,
		SBuffer:      tools.ByteToInt8(buf),
		ITimeout:     int32(s.timeout),
		Context:      reqContext,
		Status:       status,
		IMessageType: msgType,
	}
	msg := &Message{Req: &req, Ser: s, Resp: resp}
	msg.Init()

	if ok, hashType, hashCode, isHash := current.GetClientHash(ctx); ok {
		msg.isHash = isHash
		msg.hashType = HashType(hashType)
		msg.hashCode = hashCode
	}

	timeout := time.Duration(s.timeout) * time.Millisecond
	if ok, to, isTimeout := current.GetClientTimeout(ctx); ok && isTimeout {
		timeout = time.Duration(to) * time.Millisecond
		req.ITimeout = int32(to)
	}
	// timeout delivery
	if dl, ok := ctx.Deadline(); ok {