Home
last modified time | relevance | path

Searched refs:resp (Results 1 – 25 of 80) sorted by relevance

1234

/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/
H A Dobex_mp_client.cpp128 HandlePutData(resp); in PutDataAvailable()
168 ObexClient::PutDataAvailable(resp); in HandlePutData()
237 ProcessGetContinueData(resp); in GetDataAvailable()
242 ProcessGetSuccessData(resp); in GetDataAvailable()
249 ObexClient::GetDataAvailable(resp); in GetDataAvailable()
253 ObexClient::GetDataAvailable(resp); in GetDataAvailable()
261 recvObj->CacheResp(resp); in ProcessGetContinueData()
262 auto body = resp.GetItemBody(); in ProcessGetContinueData()
299 recvObj->CacheResp(resp); in ProcessGetSuccessData()
300 auto body = resp.GetItemEndBody(); in ProcessGetSuccessData()
[all …]
H A Dobex_client.cpp71 if (!resp) { in OnTransportDataAvailable()
85 HandleDataAvailablePut(*resp); in OnTransportDataAvailable()
89 HandleDataAvailableGet(*resp); in OnTransportDataAvailable()
98 HandleDataAvailableAbort(*resp); in OnTransportDataAvailable()
101 HandleDataAvailableAction(*resp); in OnTransportDataAvailable()
120 obexClient_.AbortDataAvailable(resp); in HandleDataAvailableAbort()
143 obexClient_.SetPathDataAvailable(resp); in HandleDataAvailableSetPath()
148 obexClient_.PutDataAvailable(resp); in HandleDataAvailablePut()
153 obexClient_.GetDataAvailable(resp); in HandleDataAvailableGet()
215 if (resp == nullptr) { in GetObexHeaderFromPacket()
[all …]
H A Dobex_client.h281 void HandleDataAvailableConnect(const ObexHeader &resp);
283 void HandleDataAvailablePut(const ObexHeader &resp);
284 void HandleDataAvailableGet(const ObexHeader &resp);
285 void HandleDataAvailableSetPath(const ObexHeader &resp);
286 void HandleDataAvailableSession(const ObexHeader &resp);
287 void HandleDataAvailableAbort(const ObexHeader &resp);
288 void HandleDataAvailableAction(const ObexHeader &resp);
297 virtual void PutDataAvailable(const ObexHeader &resp);
298 virtual void GetDataAvailable(const ObexHeader &resp);
299 virtual void SetPathDataAvailable(const ObexHeader &resp);
[all …]
H A Dobex_mp_client.h78 void PutDataAvailable(const ObexHeader &resp) override;
79 void GetDataAvailable(const ObexHeader &resp) override;
80 void SetPathDataAvailable(const ObexHeader &resp) override;
81 void AbortDataAvailable(const ObexHeader &resp) override;
84 void ProcessGetContinueData(const ObexHeader &resp);
85 void ProcessGetSuccessData(const ObexHeader &resp);
89 void HandlePutData(const ObexHeader &resp);
H A Dobex_session.cpp50 int ObexServerSession::SendResponse(ObexHeader &resp) const in SendResponse()
57 if (resp.GetFieldMaxPacketLength() != nullptr) { in SendResponse()
58 resp.SetFieldMaxPacketLength(maxPacketLength_); in SendResponse()
60 if (resp.GetFieldPacketLength() > maxPacketLength_) { in SendResponse()
65 bool ret = transport_.Write(resp.Build()->GetPacket()); in SendResponse()
79 if (resp.HasHeader(ObexHeader::BODY) || resp.HasHeader(ObexHeader::END_OF_BODY)) { in SendGetResponse()
85 return SendResponse(resp); in SendGetResponse()
89 resp.AppendItemSrm(true); in SendGetResponse()
91 return SendResponse(resp); in SendGetResponse()
363 void ObexClientReceivedObject::CacheResp(const ObexHeader &resp) in CacheResp() argument
[all …]
/ohos5.0/foundation/communication/wifi/wifi/test/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/test/
H A Dwifi_p2p_service_response_list_test.cpp42 WifiP2pServiceResponse resp; variable
49 WifiP2pServiceResponse resp; variable
58 WifiP2pServiceResponse resp; variable
59 resps.push_back(resp);
67 WifiP2pServiceResponse resp; variable
75 WifiP2pServiceResponse resp; variable
87 WifiP2pServiceResponse resp; variable
97 WifiP2pServiceResponse resp; variable
108 WifiP2pServiceResponse resp; variable
120 WifiP2pServiceResponse resp; variable
[all …]
H A Dwifi_p2p_service_manager_test.cpp92 WifiP2pServiceResponse resp; variable
93 p2pSvrReq.AddServiceResponse(resp);
148 WifiP2pServiceResponse resp, resq1; variable
150 p2pSvrReq.AddServiceResponse(resp);
164 WifiP2pServiceResponse resp, resq1; variable
166 p2pSvrReq.AddServiceResponse(resp);
192 WifiP2pServiceResponse resp; variable
193 respList.AddServiceResponse(resp);
230 WifiP2pServiceResponse resp; variable
239 WifiP2pServiceResponse resp; variable
[all …]
H A Dp2p_state_machine_test.cpp378 pP2pStateMachine->HandleP2pServiceResp(resp, dev); in WarpHandleP2pServiceResp()
861 WifiP2pServiceResponse resp; variable
864 WarpHandleP2pServiceResp(resp, dev);
869 WifiP2pServiceResponse resp; variable
870 resp.SetServiceStatus(P2pServiceStatus::PSRS_SUCCESS);
873 WarpHandleP2pServiceResp(resp, dev);
878 WifiP2pServiceResponse resp; variable
879 resp.SetServiceStatus(P2pServiceStatus::PSRS_SUCCESS);
882 WarpHandleP2pServiceResp(resp, dev);
887 WifiP2pServiceResponse resp; variable
[all …]
/ohos5.0/foundation/communication/dsoftbus/tests/sdk/transmission/moduletest/socket/stream_encrypt_test/
H A Dstream_encrypt_server_mt.cpp144 std::shared_ptr<Response> resp = std::make_shared<Response>(false, g_recvData); in __anon078d23d30102() local
146 LOGI("isEcrtypr:%d, recvData:%s", resp->isEncrypt_, resp->recvData_.c_str()); in __anon078d23d30102()
147 return resp; in __anon078d23d30102()
203 std::shared_ptr<Response> resp = std::make_shared<Response>(false, g_recvData); in __anon078d23d30202() local
205 LOGI("isEcrtypr:%d, recvData:%s", resp->isEncrypt_, resp->recvData_.c_str()); in __anon078d23d30202()
206 return resp; in __anon078d23d30202()
263 std::shared_ptr<Response> resp = std::make_shared<Response>(true, g_recvData); in __anon078d23d30302() local
265 LOGI("isEcrtypr:%d, recvData:%s", resp->isEncrypt_, resp->recvData_.c_str()); in __anon078d23d30302()
266 return resp; in __anon078d23d30302()
325 LOGI("isEcrtypr:%d, recvData:%s", resp->isEncrypt_, resp->recvData_.c_str()); in __anon078d23d30402()
[all …]
H A Dstream_encrypt_client_mt.cpp69 …ol IsTestOk(bool isLocalEncrypt, const std::string sendData, const std::shared_ptr<Response> &resp) in IsTestOk() argument
71 if (resp == nullptr) { in IsTestOk()
76 bool isPeerEncrypt = resp->isEncrypt_; in IsTestOk()
77 std::string recvData = resp->recvData_; in IsTestOk()
147 std::shared_ptr<Response> resp = TMessenger::GetInstance().QueryResult(WAIT_TIMEOUT); variable
148 bool testResult = IsTestOk(false, TEST_STREAM_DATA, resp);
200 std::shared_ptr<Response> resp = TMessenger::GetInstance().QueryResult(WAIT_TIMEOUT); variable
201 bool testResult = IsTestOk(true, TEST_STREAM_DATA, resp);
341 std::shared_ptr<Response> resp = TMessenger::GetInstance().QueryResult(WAIT_TIMEOUT); variable
342 bool testResult = IsTestOk(false, TEST_STREAM_DATA, resp);
/ohos5.0/foundation/communication/bluetooth/frameworks/inner/src/
H A Dbluetooth_avrcp_ct.cpp39 AvrcpCtResponse::AvrcpCtResponse(uint8_t type, int resp) : type_(type), resp_(resp) in AvrcpCtResponse() argument
472 observer->OnActionCompleted(device, resp); in OnPressButton()
486 observer->OnActionCompleted(device, resp); in OnReleaseButton()
500 observer->OnActionCompleted(device, resp); in OnSetBrowsedPlayer()
519 observer->OnActionCompleted(device, resp); in OnGetCapabilities()
533 observer->OnActionCompleted(device, resp); in OnGetPlayerAppSettingAttributes()
547 observer->OnActionCompleted(device, resp); in OnGetPlayerAppSettingValues()
561 observer->OnActionCompleted(device, resp); in OnGetPlayerAppSettingCurrentValue()
573 observer->OnActionCompleted(device, resp); in OnSetPlayerAppSettingCurrentValue()
587 observer->OnActionCompleted(device, resp); in OnGetPlayerAppSettingAttributeText()
[all …]
/ohos5.0/base/telephony/ril_adapter/services/vendor/src/
H A Dat_support.c88 void FreeResponseInfo(ResponseInfo *resp) in FreeResponseInfo() argument
91 if (resp == NULL) { in FreeResponseInfo()
95 p = resp->head; in FreeResponseInfo()
96 if (p == NULL && resp->result != NULL) { in FreeResponseInfo()
97 free(resp->result); in FreeResponseInfo()
98 resp->result = NULL; in FreeResponseInfo()
112 if (resp->result != NULL) { in FreeResponseInfo()
113 free(resp->result); in FreeResponseInfo()
114 resp->result = NULL; in FreeResponseInfo()
116 free(resp); in FreeResponseInfo()
[all …]
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/tests/
H A Dsdv_async_http_body_io.rs78 let mut resp = client.request(request).await.unwrap(); in sdv_body_chunk_and_trailer() localVariable
83 let read = resp.body_mut().data(&mut buf).await.unwrap(); in sdv_body_chunk_and_trailer()
86 let read = resp.body_mut().data(&mut buf).await.unwrap(); in sdv_body_chunk_and_trailer()
89 let read = resp.body_mut().data(&mut buf).await.unwrap(); in sdv_body_chunk_and_trailer()
93 let res = resp.body_mut().trailer().await.unwrap().unwrap(); in sdv_body_chunk_and_trailer()
H A Dsdv_async_http_client_error.rs77 let resp = client.request(request).await; in sdv_err_start_connect_timeout() localVariable
78 assert!(resp.is_err()) in sdv_err_start_connect_timeout()
137 let resp = client.request(request).await; in sdv_err_req_timeout() localVariable
139 resp.map_err(|e| { in sdv_err_req_timeout()
214 let resp = client.request(request).await; in sdv_err_redirect_wrong_location() localVariable
215 assert_eq!(resp.map_err(|e| { in sdv_err_redirect_wrong_location()
278 let resp = client.request(request).await; in sdv_err_response_with_wrong_body_length() localVariable
280 resp.map_err(|e| { in sdv_err_response_with_wrong_body_length()
/ohos5.0/foundation/communication/connected_nfc_tag/services/src/hdi/src/
H A Dnfc_tag_hdi_adapter.cpp63 std::string resp = ""; in ReadNdefTag() local
65 g_nfcTagHdi->ReadNdefTag(resp); in ReadNdefTag()
66 HILOGI("NfcTagHdiAdapter::ReadNdefTag() resp = %{public}s", resp.c_str()); in ReadNdefTag()
68 return resp; in ReadNdefTag()
/ohos5.0/foundation/communication/netstack/frameworks/cj/http/src/
H A Dnet_http_request_context.cpp271 void RequestContext::SetPerformanceTimingToResult(CHttpResponse &resp) in SetPerformanceTimingToResult() argument
290 resp.performanceTiming = timing; in SetPerformanceTimingToResult()
511 CHttpResponse resp = { .errCode = 0, in SendResponse() local
521 resp.responseCode = response.GetResponseCode(); in SendResponse()
524 resp.cookies = MallocCString(response.GetCookies()); in SendResponse()
526 resp.header = g_map2CArrString(response.GetHeader()); in SendResponse()
528 ParseSetCookie(resp.setCookie, response); in SendResponse()
530 SetPerformanceTimingToResult(resp); in SendResponse()
536 resp.errCode = GetErrorCode(); in SendResponse()
537 resp.errMsg = MallocCString(GetErrorMessage()); in SendResponse()
[all …]
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/async_impl/
H A Dclient.rs1281 assert!(resp.is_ok()); in ut_client_send_request()
1282 let body = resp.unwrap().text().await; in ut_client_send_request()
1360 assert!(resp.is_err()); in ut_client_redirect()
1410 assert!(resp.is_ok()); in ut_client_http_proxy()
1453 assert!(resp.is_ok()); in ut_client_send_trunk_body()
1495 assert!(resp.is_ok()); in ut_client_send_unknown_size()
1540 assert!(resp.is_ok()); in ut_client_recv_conn_close()
1586 assert!(resp.is_ok()); in ut_client_recv_http1_0_resp()
1631 assert!(resp.is_err()); in ut_client_recv_invalid_http1_0_resp()
1667 assert!(resp.is_err()); in ut_client_recv_when_server_shutdown()
[all …]
/ohos5.0/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/
H A Dwifi_p2p_service_response_list.cpp30 bool WifiP2pServiceResponseList::AddServiceResponse(const WifiP2pServiceResponse &resp) in AddServiceResponse() argument
33 if (*it == resp) { in AddServiceResponse()
37 srvRespList.push_back(resp); in AddServiceResponse()
40 bool WifiP2pServiceResponseList::RemoveServiceResponse(const WifiP2pServiceResponse &resp) in RemoveServiceResponse() argument
43 if (*it == resp) { in RemoveServiceResponse()
H A Dwifi_p2p_service_response_list.h50 virtual bool AddServiceResponse(const WifiP2pServiceResponse &resp);
58 virtual bool RemoveServiceResponse(const WifiP2pServiceResponse &resp);
/ohos5.0/base/security/certificate_framework/test/unittest/v1.0/src/
H A Dcrypto_x509_cert_chain_test_part2.cpp125 CfBlob *resp = (CfBlob *)CfMalloc(sizeof(CfBlob), 0); in ConstructHcfRevocationCheckParam() local
126 if (resp == nullptr) { in ConstructHcfRevocationCheckParam()
131 resp->data = (uint8_t *)(&g_testOcspResponses[0]); in ConstructHcfRevocationCheckParam()
132 resp->size = sizeof(g_testOcspResponses); in ConstructHcfRevocationCheckParam()
142 param->ocspResponses = resp; in ConstructHcfRevocationCheckParam()
348 CfBlob resp; variable
349 resp.data = (uint8_t *)(&g_testOcspResponses[0]);
350 resp.size = sizeof(g_testOcspResponses);
351 rcp.ocspResponses = &resp;
/ohos5.0/commonlibrary/rust/ylong_http/ylong_http_client/src/sync_impl/
H A Dconnector.rs186 let resp = &buf[..pos]; in tunnel() localVariable
187 if resp.starts_with(b"HTTP/1.1 200") { in tunnel()
188 if resp.ends_with(b"\r\n\r\n") { in tunnel()
197 } else if resp.starts_with(b"HTTP/1.1 407") { in tunnel()
/ohos5.0/foundation/systemabilitymgr/samgr_lite/samgr_endpoint/source/
H A Dsamgr_mini_ipc_adapter.c59 Response resp = {0}; in Dispatch() local
60 resp.data = endpoint; in Dispatch()
64 resp.reply = reply; in Dispatch()
67 int ret = SAMGR_SendSharedDirectRequest(&router->identity, &request, &resp, &ref, HandleIpc); in Dispatch()
/ohos5.0/base/hiviewdfx/faultloggerd/test/unittest/faultloggerd_client/
H A Dfaultloggerd_client_test.cpp245 int resp = RequestSdkDump(1, 1); variable
246 if (resp == FaultLoggerCheckPermissionResp::CHECK_PERMISSION_PASS) {
286 int resp = RequestSdkDump(1, 1); variable
287 if (resp == FaultLoggerCheckPermissionResp::CHECK_PERMISSION_REJECT) {
/ohos5.0/foundation/multimodalinput/input/intention/cooperate/plugin/src/
H A Dcooperate_out.cpp242 DSoftbusRelayCooperateFinished resp { in OnRelay() local
250 resp.normal = false; in OnRelay()
251 context.dsoftbus_.RelayCooperateFinish(notice.networkId, resp); in OnRelay()
255 resp.normal = true; in OnRelay()
256 context.dsoftbus_.RelayCooperateFinish(notice.networkId, resp); in OnRelay()
/ohos5.0/base/msdp/device_status/intention/cooperate/plugin/src/
H A Dcooperate_out.cpp243 DSoftbusRelayCooperateFinished resp { in OnRelay() local
251 resp.normal = false; in OnRelay()
252 context.dsoftbus_.RelayCooperateFinish(notice.networkId, resp); in OnRelay()
256 resp.normal = true; in OnRelay()
257 context.dsoftbus_.RelayCooperateFinish(notice.networkId, resp); in OnRelay()

1234