Home
last modified time | relevance | path

Searched refs:reply (Results 1 – 25 of 44) sorted by relevance

12

/device/google/cuttlefish/host/libs/audio_connector/
Dcommands.cpp40 const std::vector<virtio_snd_jack_info>& reply) { in Reply() argument
45 CHECK(reply.size() == count()) in Reply()
46 << "Returned unmatching info count: " << reply.size() << " vs " in Reply()
48 for (int i = 0; i < reply.size(); ++i) { in Reply()
49 info_reply()[i] = reply[i]; in Reply()
59 const std::vector<virtio_snd_chmap_info>& reply) { in Reply() argument
64 CHECK(reply.size() == count()) in Reply()
65 << "Returned unmatching info count: " << reply.size() << " vs " in Reply()
67 for (int i = 0; i < reply.size(); ++i) { in Reply()
68 info_reply()[i].hdr.hda_fn_nid = Le32(reply[i].hdr.hda_fn_nid); in Reply()
[all …]
Dserver.cpp87 IoStatusMsg reply; in SendStatusCallback() local
88 reply.status.status = Le32(static_cast<uint32_t>(status)); in SendStatusCallback()
89 reply.status.latency_bytes = Le32(latency_bytes); in SendStatusCallback()
90 reply.buffer_offset = buffer_offset; in SendStatusCallback()
91 reply.consumed_length = consumed_length; in SendStatusCallback()
94 auto sent = socket->Send(&reply, sizeof(reply), MSG_DONTWAIT); in SendStatusCallback()
95 if (sent < sizeof(reply)) { in SendStatusCallback()
187 std::unique_ptr<virtio_snd_pcm_info[]> reply( in ReceiveCommands() local
189 StreamInfoCommand cmd(start_id, info_count, reply.get()); in ReceiveCommands()
192 return CmdReply(cmd.status(), reply.get(), in ReceiveCommands()
[all …]
Dcommands.h45 InfoCommand(AudioCommandType type, uint32_t start_id, size_t count, R* reply) in InfoCommand() argument
49 info_reply_(reply) {} in InfoCommand()
69 const std::vector<virtio_snd_chmap_info>& reply);
78 const std::vector<virtio_snd_jack_info>& reply);
86 void Reply(AudioStatus status, const std::vector<virtio_snd_pcm_info>& reply);
/device/generic/goldfish/camera/
Dqemu_channel.cpp83 std::vector<uint8_t> reply; in qemuRunQuery() local
84 e = qemuReceiveMessage(fd, &reply); in qemuRunQuery()
89 if (reply.size() >= 3) { in qemuRunQuery()
92 if (!memcmp(reply.data(), "ok", 2)) { in qemuRunQuery()
94 } else if (!memcmp(reply.data(), "ko", 2)) { in qemuRunQuery()
100 switch (reply[2]) { in qemuRunQuery()
106 const int msgSize = reply.size() - 3; in qemuRunQuery()
109 query, msgSize, &reply[3]); in qemuRunQuery()
114 reply.erase(reply.begin(), reply.begin() + 3); in qemuRunQuery()
115 *result = std::move(reply); in qemuRunQuery()
[all …]
/device/linaro/poplar/wifi/wifi_hal/
Drtt.cpp157 virtual int handleResponse(WifiEvent& reply) { in handleResponse() argument
161 if (reply.get_cmd() != NL80211_CMD_VENDOR) { in handleResponse()
162 ALOGD("Ignoring reply with cmd = %d", reply.get_cmd()); in handleResponse()
166 int id = reply.get_vendor_id(); in handleResponse()
167 int subcmd = reply.get_vendor_subcmd(); in handleResponse()
169 void *data = reply.get_vendor_data(); in handleResponse()
170 int len = reply.get_vendor_data_len(); in handleResponse()
205 virtual int handleResponse(WifiEvent& reply) { in handleResponse() argument
209 if (reply.get_cmd() != NL80211_CMD_VENDOR) { in handleResponse()
210 ALOGD("Ignoring reply with cmd = %d", reply.get_cmd()); in handleResponse()
[all …]
Dwifi_logger.cpp312 virtual int handleResponse(WifiEvent& reply) { in handleResponse() argument
315 if (reply.get_cmd() != NL80211_CMD_VENDOR) { in handleResponse()
316 ALOGD("Ignoring reply with cmd = %d", reply.get_cmd()); in handleResponse()
324 void *data = reply.get_vendor_data(); in handleResponse()
325 int len = reply.get_vendor_data_len(); in handleResponse()
341 nlattr *vendor_data = reply.get_attribute(NL80211_ATTR_VENDOR_DATA); in handleResponse()
342 int len = reply.get_vendor_data_len(); in handleResponse()
381 void *data = reply.get_vendor_data(); in handleResponse()
382 int len = reply.get_vendor_data_len(); in handleResponse()
646 virtual int handleResponse(WifiEvent& reply) { in handleResponse() argument
[all …]
Dlink_layer_stats.cpp71 virtual int handleResponse(WifiEvent& reply) { in handleResponse() argument
75 if (reply.get_cmd() != NL80211_CMD_VENDOR) { in handleResponse()
76 ALOGD("Ignoring reply with cmd = %d", reply.get_cmd()); in handleResponse()
80 int id = reply.get_vendor_id(); in handleResponse()
81 int subcmd = reply.get_vendor_subcmd(); in handleResponse()
85 void *data = reply.get_vendor_data(); in handleResponse()
86 int len = reply.get_vendor_data_len(); in handleResponse()
Dwifi_hal.cpp618 virtual int handleResponse(WifiEvent& reply) { in handleResponse() argument
622 struct nlattr **tb = reply.attributes(); in handleResponse()
623 struct genlmsghdr *gnlh = reply.header(); in handleResponse()
710 virtual int handleResponse(WifiEvent& reply) { in handleResponse() argument
850 virtual int handleResponse(WifiEvent& reply) { in handleResponse() argument
982 int handleResponse(WifiEvent& reply) { in handleResponse() argument
985 if (reply.get_cmd() != NL80211_CMD_VENDOR) { in handleResponse()
986 ALOGD("Ignoring reply with cmd = %d", reply.get_cmd()); in handleResponse()
990 int id = reply.get_vendor_id(); in handleResponse()
991 int subcmd = reply.get_vendor_subcmd(); in handleResponse()
[all …]
Dgscan.cpp213 virtual int handleResponse(WifiEvent& reply) { in handleResponse() argument
217 if (reply.get_cmd() != NL80211_CMD_VENDOR) { in handleResponse()
218 ALOGD("Ignoring reply with cmd = %d", reply.get_cmd()); in handleResponse()
222 int id = reply.get_vendor_id(); in handleResponse()
223 int subcmd = reply.get_vendor_subcmd(); in handleResponse()
225 void *data = reply.get_vendor_data(); in handleResponse()
226 int len = reply.get_vendor_data_len(); in handleResponse()
279 virtual int handleResponse(WifiEvent& reply) { in handleResponse() argument
283 if (reply.get_cmd() != NL80211_CMD_VENDOR) { in handleResponse()
284 ALOGD("Ignoring reply with cmd = %d", reply.get_cmd()); in handleResponse()
[all …]
Dwifi_offload.cpp191 virtual int handleResponse(WifiEvent& reply) { in handleResponse() argument
194 if (reply.get_cmd() != NL80211_CMD_VENDOR) { in handleResponse()
195 ALOGD("Ignoring reply with cmd = %d", reply.get_cmd()); in handleResponse()
/device/google/contexthub/firmware/os/core/
DnanohubCommand.c379 uint32_t reply; in appSecErrToNanohubReply() local
383 reply = NANOHUB_FIRMWARE_UPLOAD_SUCCESS; in appSecErrToNanohubReply()
386 reply = NANOHUB_FIRMWARE_UPLOAD_APP_SEC_KEY_NOT_FOUND; in appSecErrToNanohubReply()
389 reply = NANOHUB_FIRMWARE_UPLOAD_APP_SEC_HEADER_ERROR; in appSecErrToNanohubReply()
392 reply = NANOHUB_FIRMWARE_UPLOAD_APP_SEC_TOO_MUCH_DATA; in appSecErrToNanohubReply()
395 reply = NANOHUB_FIRMWARE_UPLOAD_APP_SEC_TOO_LITTLE_DATA; in appSecErrToNanohubReply()
398 reply = NANOHUB_FIRMWARE_UPLOAD_APP_SEC_SIG_VERIFY_FAIL; in appSecErrToNanohubReply()
401 reply = NANOHUB_FIRMWARE_UPLOAD_APP_SEC_SIG_DECODE_FAIL; in appSecErrToNanohubReply()
404 reply = NANOHUB_FIRMWARE_UPLOAD_APP_SEC_SIG_ROOT_UNKNOWN; in appSecErrToNanohubReply()
407 reply = NANOHUB_FIRMWARE_UPLOAD_APP_SEC_MEMORY_ERROR; in appSecErrToNanohubReply()
[all …]
/device/google/cuttlefish/host/commands/control_env_proxy_server/
Dmain.cpp60 CallUnaryMethodReply* reply) override { in CallUnaryMethod() argument
69 reply->set_json_formatted_proto(*result); in CallUnaryMethod()
75 ListServicesReply* reply) override { in ListServices() argument
94 reply->add_services(service.asString()); in ListServices()
101 ListMethodsReply* reply) override { in ListMethods() argument
120 reply->add_methods(method.asString()); in ListMethods()
128 ListReqResTypeReply* reply) override { in ListReqResType() argument
145 reply->set_request_type_name(value["request_type"].asString()); in ListReqResType()
146 reply->set_response_type_name(value["response_type"].asString()); in ListReqResType()
153 TypeInformationReply* reply) override { in TypeInformation() argument
[all …]
/device/google/cuttlefish/host/frontend/webrtc/libcommon/
Dconnection_controller.cpp117 Json::Value reply; in FailConnection() local
118 reply["type"] = "error"; in FailConnection()
119 reply["error"] = message; in FailConnection()
120 auto res = sig_handler_.SendMessage(reply); in FailConnection()
200 Json::Value reply; in OnCreateSDPSuccess() local
201 reply["type"] = sdp_type; in OnCreateSDPSuccess()
202 reply["sdp"] = offer_str; in OnCreateSDPSuccess()
204 CF_EXPECT(sig_handler_.SendMessage(reply)); in OnCreateSDPSuccess()
399 Json::Value reply; in OnIceCandidate() local
400 reply["type"] = "ice-candidate"; in OnIceCandidate()
[all …]
/device/google/cuttlefish/host/commands/openwrt_control_server/
Dmain.cpp76 auto reply = RequestLuciRpc(request->subpath(), request->method(), in LuciRpc() local
80 if (!TypeIsSuccess(reply)) { in LuciRpc()
84 reply = RequestLuciRpc(request->subpath(), request->method(), in LuciRpc()
86 if (!TypeIsSuccess(reply)) { in LuciRpc()
92 response->set_id((*reply)["id"].asInt()); in LuciRpc()
93 response->set_error((*reply)["error"].asString()); in LuciRpc()
94 response->set_result(writer.write((*reply)["result"])); in LuciRpc()
175 auto reply = CF_EXPECT(http_client_.PostToJson(url, data, header_)); in RequestLuciRpc() local
176 if (reply.data["error"].isString()) { in RequestLuciRpc()
178 !StartsWith(reply.data["error"].asString(), "Failed to parse json:"), in RequestLuciRpc()
[all …]
/device/generic/goldfish-opengl/system/codecs/c2/decoders/base/
DSimpleC2Component.cpp74 sp<AMessage> reply = new AMessage; in Reply() local
76 reply->setInt32("err", *err); in Reply()
78 reply->postReply(replyId); in Reply()
88 sp<AMessage> reply = new AMessage; in onMessageReceived() local
89 reply->setInt32("err", C2_CORRUPTED); in onMessageReceived()
90 reply->postReply(replyId); in onMessageReceived()
322 sp<AMessage> reply; in start() local
324 ->postAndAwaitResponse(&reply); in start()
326 CHECK(reply->findInt32("err", &err)); in start()
352 sp<AMessage> reply; in stop() local
[all …]
/device/google/cuttlefish/host/frontend/webrtc_operator/
Dclient_handler.cpp218 Json::Value reply; in ReplyError() local
219 reply["type"] = "error"; in ReplyError()
220 reply["error"] = message; in ReplyError()
221 Reply(reply); in ReplyError()
260 Json::Value reply(Json::arrayValue); in Poll() local
262 reply.append(msg); in Poll()
264 Reply(reply); in Poll()
349 Json::Value reply = server_config_.ToJson(); in DoGet() local
350 reply[webrtc_signaling::kTypeField] = webrtc_signaling::kConfigType; in DoGet()
352 auto replyAsString = Json::writeString(factory, reply); in DoGet()
Ddevice_list_handler.cpp25 Json::Value reply(Json::ValueType::arrayValue); in DoGet() local
28 reply.append(id); in DoGet()
31 auto replyAsString = Json::writeString(json_factory, reply); in DoGet()
Dsignal_handler.cpp83 auto reply = server_config_.ToJson(); in SendServerConfig() local
84 reply[webrtc_signaling::kTypeField] = webrtc_signaling::kConfigType; in SendServerConfig()
85 Reply(reply); in SendServerConfig()
/device/google/cuttlefish/host/commands/screen_recording_server/
Dmain.cpp52 StartRecordingResponse* reply) override { in StartRecording() argument
57 reply->mutable_successes()->Assign(successes.begin(), successes.end()); in StartRecording()
62 StopRecordingResponse* reply) override { in StopRecording() argument
67 reply->mutable_successes()->Assign(successes.begin(), successes.end()); in StopRecording()
/device/google/cuttlefish/host/libs/location/
DGnssClient.cpp47 SendGpsCoordinatesReply reply; in SendGpsLocations() local
52 grpc::Status status = stub_->SendGpsVector(&context, request, &reply); in SendGpsLocations()
58 LOG(DEBUG) << reply.status(); in SendGpsLocations()
/device/google/atv/audio_proxy/service/
DWriteThread.cpp70 status.reply.written = 0; in doWrite()
93 status.reply.written = writeStatus.written; in doWrite()
114 status.reply.presentationPosition = {mPresentationFrames, in doGetPresentationPosition()
124 status.reply.latencyMs = mLatencyMs; in doGetLatency()
/device/generic/goldfish/audio/
Dstream_out.cpp225 status.reply.written = reader.totalRead; in doWrite()
233 status.reply.presentationPosition.frames, in doGetPresentationPosition()
234 status.reply.presentationPosition.timeStamp); in doGetPresentationPosition()
237 (unsigned long long) status.reply.presentationPosition.frames, in doGetPresentationPosition()
238 (long long) util::timespec2Nsecs( status.reply.presentationPosition.timeStamp)); in doGetPresentationPosition()
252 status.reply.latencyMs = latencyMs; in doGetLatency()
/device/google/cuttlefish/host/commands/gnss_grpc_proxy/
Dgnss_grpc_proxy.proto41 // The response message containing the return nmea reply message
43 string reply = 1; field
54 string reply = 1; field
Dgnss_grpc_proxy.cpp121 SendGpsReply* reply) override { in SendGps() argument
122 reply->set_reply("Received gps record"); in SendGps()
139 SendGpsCoordinatesReply* reply) override { in SendGpsVector() argument
140 reply->set_status(SendGpsCoordinatesReply::OK);//update protobuf reply in SendGpsVector()
/device/google/cuttlefish/host/commands/echo_server/
Dmain.cpp43 EchoReply* reply) override { in Echo() argument
44 reply->set_message(request->message()); in Echo()

12