/foundation/ai/ai_engine/services/common/protocol/data_channel/source/ |
H A D | response.cpp | 27 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 D | message.h | 55 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 D | tmessenger.h | 45 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 D | tmessenger.cpp | 47 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 D | stream_encrypt_server_mt.cpp | 144 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 D | stream_encrypt_client_mt.cpp | 69 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 D | builder.rs | 17 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 D | mod.rs | 26 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 D | response.h | 25 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 D | http_curl.h | 19 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 D | http_rust.h | 19 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 D | mod.rs | 17 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 D | future_factory.cpp | 158 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 D | mod.rs | 30 pub use reqwest::{tls::Version as TlsVersion, Method, Response, Version};
|
/foundation/systemabilitymgr/samgr_lite/samgr/source/ |
H A D | message.c | 49 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 D | message_inner.h | 40 Response response;
|
H A D | samgr_lite.c | 61 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 D | samgr_mini_ipc_adapter.c | 19 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 D | samgr_small_ipc_adapter.c | 25 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 D | endpoint.c | 71 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 D | mediakeydecryptndk_fuzzer.cpp | 104 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 D | future_factory.h | 75 * @param [in] response Response of asynchronous task processing. 85 Future* FetchFuture(Response *response);
|
/foundation/systemabilitymgr/samgr_lite/communication/broadcast/source/ |
H A D | pub_sub_implement.c | 27 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 D | connect.rs | 37 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 D | rs_base_render_util.cpp | 139 inline constexpr float Response(float x, const TransferParameters& p) in Response() function 174 return [params](float x) { return Response(x, params); };
|