Lines Matching defs:call
84 ApiCallInfo call;
86 call.apiId_ = data.ReadString();
87 call.callerObjRef_ = data.ReadString();
89 call.fdParamIndex_ = data.ReadInt32();
90 call.paramList_ = nlohmann::json::parse(paramListStr, nullptr, false);
91 DCHECK(!call.paramList_.is_discarded());
92 if (call.fdParamIndex_ >= 0) {
93 call.paramList_.at(call.fdParamIndex_) = data.ReadFileDescriptor();
96 Call(call, result);
108 void ApiCaller::Call(const ApiCallInfo &call, ApiReplyInfo &result)
111 handler_(call, result);
136 void ApiCallerProxy::Call(const ApiCallInfo &call, ApiReplyInfo &result)
142 auto ret = data.WriteInterfaceToken(GetDescriptor()) && data.WriteString(call.apiId_) &&
143 data.WriteString(call.callerObjRef_) && data.WriteString(call.paramList_.dump()) &&
144 data.WriteInt32(call.fdParamIndex_);
145 auto fdIndex = call.fdParamIndex_;
147 DCHECK(static_cast<size_t>(fdIndex) < call.paramList_.size());
148 DCHECK(call.paramList_.at(fdIndex).type() == nlohmann::detail::value_t::number_integer);
149 if (!data.WriteFileDescriptor(call.paramList_.at(fdIndex).get<uint32_t>())) {
344 void ApiTransactor::Transact(const ApiCallInfo &call, ApiReplyInfo &reply)
352 // check concurrent call
356 reply.exception_.message_ = string(msg) + processingApi_ + ", incoming: " + call.apiId_;
359 processingApi_ = call.apiId_;
362 remoteCaller_->Call(call, reply);