/foundation/communication/bluetooth_service/services/bluetooth/service/src/obex/ |
H A D | obex_mp_client.cpp | 113 void ObexMpClient::PutDataAvailable(const ObexHeader &resp) in PutDataAvailable() argument 128 HandlePutData(resp); in PutDataAvailable() 131 void ObexMpClient::HandlePutData(const ObexHeader &resp) in HandlePutData() argument 134 if (sendObject != nullptr && resp.GetFieldCode() == static_cast<uint8_t>(ObexRspCode::CONTINUE)) { in HandlePutData() 136 if (resp.HasHeader(ObexHeader::SRM)) { in HandlePutData() 137 bool srmEnable = resp.GetItemSrm(); in HandlePutData() 141 if (resp.HasHeader(ObexHeader::SRMP)) { in HandlePutData() 142 bool srmWait = resp.GetItemSrmp(); in HandlePutData() 155 clientObserver_.OnActionCompleted(*this, resp); in HandlePutData() 168 ObexClient::PutDataAvailable(resp); in HandlePutData() 219 GetDataAvailable(const ObexHeader &resp) GetDataAvailable() argument 256 ProcessGetContinueData(const ObexHeader &resp) ProcessGetContinueData() argument 295 ProcessGetSuccessData(const ObexHeader &resp) ProcessGetSuccessData() argument 318 SetPathDataAvailable(const ObexHeader &resp) SetPathDataAvailable() argument 336 AbortDataAvailable(const ObexHeader &resp) AbortDataAvailable() argument [all...] |
H A D | obex_client.cpp | 70 auto resp = GetObexHeaderFromPacket(obexPacket); in OnTransportDataAvailable() local 71 if (!resp) { in OnTransportDataAvailable() 74 obexClient_.clientSession_->SetLastRespCd(resp->GetFieldCode()); in OnTransportDataAvailable() 78 HandleDataAvailableConnect(*resp); in OnTransportDataAvailable() 81 HandleDataAvailableDisconnect(*resp); in OnTransportDataAvailable() 85 HandleDataAvailablePut(*resp); in OnTransportDataAvailable() 89 HandleDataAvailableGet(*resp); in OnTransportDataAvailable() 92 HandleDataAvailableSetPath(*resp); in OnTransportDataAvailable() 95 HandleDataAvailableSession(*resp); in OnTransportDataAvailable() 98 HandleDataAvailableAbort(*resp); in OnTransportDataAvailable() 108 HandleDataAvailableAction(const ObexHeader &resp) HandleDataAvailableAction() argument 113 HandleDataAvailableAbort(const ObexHeader &resp) HandleDataAvailableAbort() argument 123 HandleDataAvailableSession(const ObexHeader &resp) HandleDataAvailableSession() argument 141 HandleDataAvailableSetPath(const ObexHeader &resp) HandleDataAvailableSetPath() argument 146 HandleDataAvailablePut(const ObexHeader &resp) HandleDataAvailablePut() argument 151 HandleDataAvailableGet(const ObexHeader &resp) HandleDataAvailableGet() argument 156 HandleDataAvailableDisconnect(const ObexHeader &resp) HandleDataAvailableDisconnect() argument 165 HandleDataAvailableConnect(const ObexHeader &resp) HandleDataAvailableConnect() argument 208 std::unique_ptr<bluetooth::ObexHeader> resp; GetObexHeaderFromPacket() local 588 PutDataAvailable(const ObexHeader &resp) PutDataAvailable() argument 599 GetDataAvailable(const ObexHeader &resp) GetDataAvailable() argument 610 SetPathDataAvailable(const ObexHeader &resp) SetPathDataAvailable() argument 615 AbortDataAvailable(const ObexHeader &resp) AbortDataAvailable() argument [all...] |
H A D | obex_client.h | 79 * @param resp The Response from Server 81 virtual void OnConnected(ObexClient &client, const ObexHeader &resp) = 0; 86 * @param resp The Response from Server 88 virtual void OnConnectFailed(ObexClient &client, const ObexHeader &resp) = 0; 99 * @param resp The Response from Server 101 virtual void OnActionCompleted(ObexClient &client, const ObexHeader &resp) = 0; 281 void HandleDataAvailableConnect(const ObexHeader &resp); 282 void HandleDataAvailableDisconnect(const ObexHeader &resp); 283 void HandleDataAvailablePut(const ObexHeader &resp); 284 void HandleDataAvailableGet(const ObexHeader &resp); [all...] |
H A D | obex_mp_client.h | 78 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 D | obex_session.cpp | 50 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() 62 int(resp.GetFieldPacketLength()), int(maxPacketLength_)); in SendResponse() 65 bool ret = transport_.Write(resp.Build()->GetPacket()); in SendResponse() 73 int ObexServerSession::SendGetResponse(const ObexHeader &req, ObexHeader &resp, std::shared_ptr<ObexBodyObject> reader) in SendGetResponse() argument 79 if (resp.HasHeader(ObexHeader::BODY) || resp.HasHeader(ObexHeader::END_OF_BODY)) { in SendGetResponse() 83 if (resp in SendGetResponse() 363 CacheResp(const ObexHeader &resp) CacheResp() argument [all...] |
/foundation/communication/wifi/wifi/test/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/test/ |
H A D | wifi_p2p_service_response_list_test.cpp | 42 WifiP2pServiceResponse resp; in HWTEST_F() local 43 EXPECT_TRUE(pWifiP2pServiceResponseList->AddServiceResponse(resp)); in HWTEST_F() 44 EXPECT_TRUE(pWifiP2pServiceResponseList->AddServiceResponse(resp)); in HWTEST_F() 49 WifiP2pServiceResponse resp; in HWTEST_F() local 50 EXPECT_FALSE(pWifiP2pServiceResponseList->RemoveServiceResponse(resp)); in HWTEST_F() 51 EXPECT_TRUE(pWifiP2pServiceResponseList->AddServiceResponse(resp)); in HWTEST_F() 52 EXPECT_TRUE(pWifiP2pServiceResponseList->RemoveServiceResponse(resp)); in HWTEST_F() 58 WifiP2pServiceResponse resp; in HWTEST_F() local 59 resps.push_back(resp); in HWTEST_F() 60 EXPECT_TRUE(pWifiP2pServiceResponseList->AddServiceResponse(resp)); in HWTEST_F() 67 WifiP2pServiceResponse resp; HWTEST_F() local 75 WifiP2pServiceResponse resp; HWTEST_F() local 87 WifiP2pServiceResponse resp; HWTEST_F() local 97 WifiP2pServiceResponse resp; HWTEST_F() local 108 WifiP2pServiceResponse resp; HWTEST_F() local 120 WifiP2pServiceResponse resp; HWTEST_F() local 129 WifiP2pServiceResponse resp; HWTEST_F() local [all...] |
H A D | wifi_p2p_service_manager_test.cpp | 92 WifiP2pServiceResponse resp; in HWTEST_F() local 93 p2pSvrReq.AddServiceResponse(resp); in HWTEST_F() 148 WifiP2pServiceResponse resp, resq1; in HWTEST_F() local 150 p2pSvrReq.AddServiceResponse(resp); in HWTEST_F() 164 WifiP2pServiceResponse resp, resq1; in HWTEST_F() local 166 p2pSvrReq.AddServiceResponse(resp); in HWTEST_F() 192 WifiP2pServiceResponse resp; in HWTEST_F() local 193 respList.AddServiceResponse(resp); in HWTEST_F() 230 WifiP2pServiceResponse resp; in HWTEST_F() local 231 resp in HWTEST_F() 239 WifiP2pServiceResponse resp; HWTEST_F() local 249 WifiP2pServiceResponse resp; HWTEST_F() local [all...] |
H A D | p2p_state_machine_test.cpp | 381 void WarpHandleP2pServiceResp(const WifiP2pServiceResponse &resp, const WifiP2pDevice &dev) const in WarpHandleP2pServiceResp() argument 383 pP2pStateMachine->HandleP2pServiceResp(resp, dev); in WarpHandleP2pServiceResp() 866 WifiP2pServiceResponse resp; in HWTEST_F() local 867 resp.SetServiceStatus(P2pServiceStatus::PSRS_SERVICE_PROTOCOL_NOT_AVAILABLE); in HWTEST_F() 869 WarpHandleP2pServiceResp(resp, dev); in HWTEST_F() 874 WifiP2pServiceResponse resp; in HWTEST_F() local 875 resp.SetServiceStatus(P2pServiceStatus::PSRS_SUCCESS); in HWTEST_F() 876 resp.SetProtocolType(P2pServicerProtocolType::SERVICE_TYPE_BONJOUR); in HWTEST_F() 878 WarpHandleP2pServiceResp(resp, dev); in HWTEST_F() 883 WifiP2pServiceResponse resp; in HWTEST_F() local 892 WifiP2pServiceResponse resp; HWTEST_F() local [all...] |
H A D | wifi_p2p_service_request_list_test.cpp | 99 WifiP2pServiceRequest resp; in HWTEST_F() local 100 EXPECT_TRUE(pWifiP2pServiceRequestList->AddServiceRequest(resp)); in HWTEST_F()
|
/foundation/communication/dsoftbus/tests/sdk/transmission/moduletest/socket/stream_encrypt_test/ |
H A D | stream_encrypt_server_mt.cpp | 144 std::shared_ptr<Response> resp = std::make_shared<Response>(false, g_recvData); in HWTEST_F() 146 LOGI("isEcrtypr:%d, recvData:%s", resp->isEncrypt_, resp->recvData_.c_str()); in HWTEST_F() 147 return resp; in HWTEST_F() 203 std::shared_ptr<Response> resp = std::make_shared<Response>(false, g_recvData); in HWTEST_F() 205 LOGI("isEcrtypr:%d, recvData:%s", resp->isEncrypt_, resp->recvData_.c_str()); in HWTEST_F() 206 return resp; in HWTEST_F() 263 std::shared_ptr<Response> resp = std::make_shared<Response>(true, g_recvData); in HWTEST_F() 265 LOGI("isEcrtypr:%d, recvData:%s", resp in HWTEST_F() [all...] |
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() 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); in HWTEST_F() local 148 bool testResult = IsTestOk(false, TEST_STREAM_DATA, resp); in HWTEST_F() 200 std::shared_ptr<Response> resp = TMessenger::GetInstance().QueryResult(WAIT_TIMEOUT); in HWTEST_F() local 201 bool testResult = IsTestOk(true, TEST_STREAM_DATA, resp); in HWTEST_F() 341 std::shared_ptr<Response> resp = TMessenger::GetInstance().QueryResult(WAIT_TIMEOUT); in HWTEST_F() local 342 bool testResult = IsTestOk(false, TEST_STREAM_DATA, resp); in HWTEST_F() [all...] |
/foundation/communication/bluetooth/frameworks/inner/src/ |
H A D | bluetooth_avrcp_ct.cpp | 36 AvrcpCtResponse::AvrcpCtResponse(uint8_t type, int resp) : type_(type), resp_(resp) in AvrcpCtResponse() argument 467 AvrcpCtResponse resp(AVRC_ACTION_TYPE_PRESS_BUTTON, result); in OnPressButton() 468 resp.button_ = std::make_unique<AvrcpCtResponse::Button>(button); in OnPressButton() 469 observer->OnActionCompleted(device, resp); in OnPressButton() 481 AvrcpCtResponse resp(AVRC_ACTION_TYPE_RELEASE_BUTTON, result); in OnReleaseButton() 482 resp.button_ = std::make_unique<AvrcpCtResponse::Button>(button); in OnReleaseButton() 483 observer->OnActionCompleted(device, resp); in OnReleaseButton() 496 AvrcpCtResponse resp(AVRC_ACTION_TYPE_SET_BROWSED_PLAYER, result); in OnSetBrowsedPlayer() 497 observer->OnActionCompleted(device, resp); in OnSetBrowsedPlayer() [all...] |
/foundation/communication/connected_nfc_tag/services/src/hdi/src/ |
H A D | nfc_tag_hdi_adapter.cpp | 63 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()
|
/foundation/communication/wifi/wifi/services/wifi_standard/wifi_framework/wifi_manage/wifi_p2p/ |
H A D | wifi_p2p_service_response_list.cpp | 30 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 D | wifi_p2p_service_response_list.h | 46 * @param resp service response 50 virtual bool AddServiceResponse(const WifiP2pServiceResponse &resp); 54 * @param resp service response 58 virtual bool RemoveServiceResponse(const WifiP2pServiceResponse &resp);
|
H A D | wifi_p2p_dns_sd_service_response.h | 43 * @param resp - base class object of the DNS service response 45 explicit WifiP2pDnsSdServiceResponse(const WifiP2pServiceResponse &resp);
|
H A D | wifi_p2p_dns_sd_service_response.cpp | 29 WifiP2pDnsSdServiceResponse::WifiP2pDnsSdServiceResponse(const WifiP2pServiceResponse &resp) in WifiP2pDnsSdServiceResponse() argument 30 : WifiP2pServiceResponse(resp), in WifiP2pDnsSdServiceResponse()
|
H A D | p2p_state_machine.cpp | 980 void P2pStateMachine::HandleP2pServiceResp(const WifiP2pServiceResponse &resp, const WifiP2pDevice &dev) const in HandleP2pServiceResp() argument 983 serviceManager.AddDeviceService(resp, dev); in HandleP2pServiceResp() 984 if (resp.GetServiceStatus() == P2pServiceStatus::PSRS_SERVICE_PROTOCOL_NOT_AVAILABLE) { in HandleP2pServiceResp() 988 if (resp.GetProtocolType() == P2pServicerProtocolType::SERVICE_TYPE_BONJOUR) { in HandleP2pServiceResp() 989 WifiP2pDnsSdServiceResponse dnsSrvResp = WifiP2pDnsSdServiceResponse(resp); in HandleP2pServiceResp() 1006 if (resp.GetProtocolType() == P2pServicerProtocolType::SERVICE_TYPE_UP_NP) { in HandleP2pServiceResp() 1008 WifiP2pUpnpServiceResponse::Create(resp.GetServiceStatus(), resp.GetTransactionId(), resp.GetData()); in HandleP2pServiceResp() 1019 BroadcastServiceResult(resp in HandleP2pServiceResp() [all...] |
/foundation/communication/netstack/frameworks/cj/http/src/ |
H A D | net_http_request_context.cpp | 271 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() 531 resp.result.head = reinterpret_cast<uint8_t*>(MallocCString(response.GetResult())); in SendResponse() 532 resp in SendResponse() [all...] |
/foundation/systemabilitymgr/samgr_lite/samgr_endpoint/source/ |
H A D | samgr_mini_ipc_adapter.c | 59 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()
|
/foundation/communication/bluetooth/frameworks/js/napi/include/ |
H A D | napi_bluetooth_avrcp_ct_observer.h | 31 void OnActionCompleted(const BluetoothRemoteDevice &device, const AvrcpCtResponse &resp) override {}
|
/foundation/systemabilitymgr/samgr_lite/samgr/source/ |
H A D | message.c | 134 int32 SAMGR_SendSharedDirectRequest(const Identity *id, const Request *req, const Response *resp, uint32 **ref,
in SAMGR_SendSharedDirectRequest() argument 146 if (resp != NULL) {
in SAMGR_SendSharedDirectRequest() 147 exchange.response = *resp;
in SAMGR_SendSharedDirectRequest()
|
/foundation/systemabilitymgr/samgr_lite/interfaces/kits/samgr/ |
H A D | message.h | 175 * @param resp Indicates the pointer to the response. 193 int32 SAMGR_SendSharedDirectRequest(const Identity *id, const Request *req, const Response *resp, uint32 **ref,
|
/foundation/multimodalinput/input/intention/cooperate/plugin/src/ |
H A D | cooperate_out.cpp | 242 DSoftbusRelayCooperateFinished resp { in OnRelay() 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()
|
/foundation/filemanagement/dfs_service/services/cloudsyncservice/src/transport/ |
H A D | file_transfer_manager.cpp | 98 MessageHandler resp(info); in HandleDownloadFileRequest() 99 uint32_t dataLen = resp.GetDataSize(); in HandleDownloadFileRequest() 101 resp.PackData(data.get(), dataLen); in HandleDownloadFileRequest()
|