Home
last modified time | relevance | path

Searched refs:Response (Results 1 - 25 of 25) sorted by relevance

/foundation/ai/ai_engine/services/common/protocol/data_channel/source/
H A Dresponse.cpp27 Response::Response(IRequest *request) : requestId_(0), innerSequenceId_(0), transactionId_(0), in Response() function in OHOS::AI::Response
41 Response::~Response() in ~Response()
50 int Response::GetRequestId() const in GetRequestId()
55 long long Response::GetInnerSequenceId() const in GetInnerSequenceId()
60 void Response::SetInnerSequenceId(long long seqId) in SetInnerSequenceId()
65 long long Response::GetTransactionId() const in GetTransactionId()
70 void Response::SetTransactionId(long long transactionId) in SetTransactionId()
75 int Response
[all...]
/foundation/systemabilitymgr/samgr_lite/interfaces/kits/samgr/
H A Dmessage.h55 typedef struct Response Response; typedef
66 typedef void (*Handler)(const Request *request, const Response *response);
114 struct Response { struct
193 int32 SAMGR_SendSharedDirectRequest(const Identity *id, const Request *req, const Response *resp, uint32 **ref,
216 int32 SAMGR_SendResponse(const Request *request, const Response *response);
242 int32 SAMGR_SendResponseByIdentity(const Identity *id, const Request *request, const Response *response);
/foundation/communication/dsoftbus/tests/sdk/transmission/moduletest/socket/stream_encrypt_test/
H A Dtmessenger.h45 class Response { class
47 Response(bool isEncrypt, const std::string &recvData) : isEncrypt_(isEncrypt), recvData_(recvData) { } in Response() function in OHOS::Response
49 static std::shared_ptr<Response> Decode(const std::string &data);
62 explicit Message(const Response &rsp) : msgType_(MsgType::MSG_RSP), response(new Response(rsp)) { } in Message()
70 Response *response;
87 std::shared_ptr<Response> QueryResult(uint32_t timeout);
89 using OnQueryCallback = std::function<std::shared_ptr<Response>(void)>;
113 std::shared_ptr<Response> WaitResponse(uint32_t timeout);
114 std::shared_ptr<Response> GetMessageFromRecvLis
[all...]
H A Dtmessenger.cpp47 std::string Response::Encode() const in Encode()
53 std::shared_ptr<Response> Response::Decode(const std::string &data) in Decode()
70 return std::make_shared<Response>(isEncrypt, recvData); in Decode()
114 std::shared_ptr<Response> rsp = Response::Decode(data.substr(pos + 1)); in Decode()
296 std::shared_ptr<Response> resp = onQuery_(); in OnRequest()
314 std::shared_ptr<Response> TMessenger::QueryResult(uint32_t timeout) in QueryResult()
342 std::shared_ptr<Response> TMessenger::WaitResponse(uint32_t timeout) in WaitResponse()
345 std::shared_ptr<Response> rs in WaitResponse()
[all...]
H A Dstream_encrypt_server_mt.cpp144 std::shared_ptr<Response> resp = std::make_shared<Response>(false, g_recvData); in HWTEST_F()
203 std::shared_ptr<Response> resp = std::make_shared<Response>(false, g_recvData); in HWTEST_F()
263 std::shared_ptr<Response> resp = std::make_shared<Response>(true, g_recvData); in HWTEST_F()
323 std::shared_ptr<Response> resp = std::make_shared<Response>(false, g_recvData); in HWTEST_F()
H A Dstream_encrypt_client_mt.cpp69 bool IsTestOk(bool isLocalEncrypt, const std::string sendData, const std::shared_ptr<Response> &resp) in IsTestOk()
147 std::shared_ptr<Response> resp = TMessenger::GetInstance().QueryResult(WAIT_TIMEOUT); in HWTEST_F()
200 std::shared_ptr<Response> resp = TMessenger::GetInstance().QueryResult(WAIT_TIMEOUT); in HWTEST_F()
341 std::shared_ptr<Response> resp = TMessenger::GetInstance().QueryResult(WAIT_TIMEOUT); in HWTEST_F()
/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/downloader/
H A Dbuilder.rs17 use crate::{Response, SpeedLimit, Timeout};
27 /// # use ylong_http_client::Response;
29 /// # async fn create_a_downloader(body: Response) {
62 /// # use ylong_http_client::Response;
64 /// # async fn set_body(body: Response) {
68 pub fn body(self, body: Response) -> DownloaderBuilder<WantsOperator> { in body()
83 body: Response,
97 /// # use ylong_http_client::{HttpClientError, Response};
99 /// # async fn set_downloader_operator(body: Response) {
141 /// # use ylong_http_client::Response;
[all...]
H A Dmod.rs26 use reqwest::Response;
59 /// # use ylong_http_client::Response;
61 /// # async fn download_and_show_progress_on_console(response: Response) {
73 /// # use ylong_http_client::{HttpClientError, Response, SpeedLimit, Timeout};
75 /// # async fn download_and_show_progress(response: Response) {
112 body: Response,
125 /// # use ylong_http_client::Response;
127 /// # async fn download_and_show_progress_on_console(response: Response) {
133 pub fn console(response: Response) -> Downloader<Console> { in console()
161 /// # use ylong_http_client::Response;
[all...]
/foundation/ai/ai_engine/services/common/protocol/data_channel/include/
H A Dresponse.h25 class Response { class
27 explicit Response(IRequest *request);
28 ~Response();
82 * @return Response return code.
89 * @param [in] retCode Response return code.
110 * @return Response return description.
117 * @param [in] retDesc Response return description.
124 * @return Response result.
/foundation/communication/netstack/frameworks/native/http/http_curl/include/
H A Dhttp_curl.h19 using RequestCallback = std::function<void(int32_t errorNumber, const Response &response)>;
27 int32_t SyncRunRequest(const RequestOptions &options, Response &response);
/foundation/communication/netstack/frameworks/native/http/http_rust/include/
H A Dhttp_rust.h19 using RequestCallback = std::function<void(int32_t errorNumber, const Response &response)>;
27 int32_t SyncRunRequest(const RequestOptions &options, Response &response);
/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/async_impl/
H A Dmod.rs17 use reqwest::Response;
75 /// Sends a `Request` and gets the `Response`.
105 ) -> Result<Response, HttpClientError> {
/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dfuture_factory.cpp158 HILOGI("[FutureFactory]Begin to Process Response."); in ProcessResponse()
159 Response *res = reinterpret_cast<Response *>(response); in ProcessResponse()
183 Future *FutureFactory::FetchFuture(Response *response) in FetchFuture()
/foundation/communication/netstack/interfaces/innerkits/rust/ylong_http_client/src/reqwest_impl/
H A Dmod.rs30 pub use reqwest::{tls::Version as TlsVersion, Method, Response, Version};
/foundation/systemabilitymgr/samgr_lite/samgr/source/
H A Dmessage.c49 int32 SAMGR_SendResponse(const Request *request, const Response *response) in SAMGR_SendResponse()
134 int32 SAMGR_SendSharedDirectRequest(const Identity *id, const Request *req, const Response *resp, uint32 **ref, in SAMGR_SendSharedDirectRequest()
164 int32 SAMGR_SendResponseByIdentity(const Identity *id, const Request *request, const Response *response) in SAMGR_SendResponseByIdentity()
H A Dmessage_inner.h40 Response response;
H A Dsamgr_lite.c61 static void HandleInitRequest(const Request *request, const Response *response);
506 static void HandleInitRequest(const Request *request, const Response *response) in HandleInitRequest()
510 HILOG_ERROR(HILOG_MODULE_SAMGR, "Init service Request:<%d,%u>, Response:<%d>!", in HandleInitRequest()
/foundation/systemabilitymgr/samgr_lite/samgr_endpoint/source/
H A Dsamgr_mini_ipc_adapter.c19 static void HandleIpc(const Request *request, const Response *response);
59 Response resp = {0}; in Dispatch()
79 static void HandleIpc(const Request *request, const Response *response) in HandleIpc()
H A Dsamgr_small_ipc_adapter.c25 static void HandleIpc(const Request *request, const Response *response);
217 Response resp = {0}; in Dispatch()
231 static void HandleIpc(const Request *request, const Response *response) in HandleIpc()
H A Dendpoint.c71 static void HandleIpc(const Request *request, const Response *response);
411 Response resp = {0}; in Dispatch()
437 static void HandleIpc(const Request *request, const Response *response) in HandleIpc()
/foundation/multimedia/drm_framework/frameworks/native/test/fuzztest/mediakeydecryptndk_fuzzer/
H A Dmediakeydecryptndk_fuzzer.cpp104 uint8_t Response[12288] = OFFRESPONSE; in GenerateDeviceCertificate() local
105 int32_t ResponseLen = sizeof(Response); in GenerateDeviceCertificate()
107 HttpPost(PROVISION_URL, request, requestLen, Response, &ResponseLen, HTTPOUTTIME); in GenerateDeviceCertificate()
109 OH_MediaKeySystem_ProcessKeySystemResponse(mediaKeySystem, Response, ResponseLen); in GenerateDeviceCertificate()
/foundation/ai/ai_engine/services/server/server_executor/include/
H A Dfuture_factory.h75 * @param [in] response Response of asynchronous task processing.
85 Future* FetchFuture(Response *response);
/foundation/systemabilitymgr/samgr_lite/communication/broadcast/source/
H A Dpub_sub_implement.c27 static void DefaultHandle(const Request *request, const Response *response);
231 Response response = {item->consumer, 0}; in ImmediatelyPublish()
245 static void DefaultHandle(const Request *request, const Response *response) in DefaultHandle()
/foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/rust/ylong_cloud_extension/src/ipc_conn/
H A Dconnect.rs37 pub(crate) struct Response {
43 impl Serialize for Response {
52 impl Deserialize for Response {
58 let result = Response { in deserialize()
904 use crate::ipc_conn::connect::{Response, SubscriptionResultValue, SwitchStatus};
916 /// 1. Create a `Response` struct.
921 let response = Response::default(); in ut_response_serialize()
937 /// 1. Create a `Response` struct.
940 /// 4. Deserialize the data to `Response`.
944 let response = Response in ut_response_deserialize()
[all...]
/foundation/graphic/graphic_2d/rosen/modules/render_service/core/pipeline/
H A Drs_base_render_util.cpp139 inline constexpr float Response(float x, const TransferParameters& p) in Response() function
174 return [params](float x) { return Response(x, params); };

Completed in 24 milliseconds