| /foundation/ability/ability_runtime/test/unittest/app_running_record_test/ |
| H A D | child_process_record_test.cpp | 61 ChildProcessRequest request; in HWTEST_F() local
62 request.srcEntry = "./ets/AProcess.ts"; in HWTEST_F()
63 auto childRecord = std::make_shared<ChildProcessRecord>(101, request, appRecord); in HWTEST_F()
80 ChildProcessRequest request; in HWTEST_F() local
81 request.srcEntry = "./ets/AProcess.ts"; in HWTEST_F()
82 auto childRecord = std::make_shared<ChildProcessRecord>(101, request, appRecord); in HWTEST_F()
97 ChildProcessRequest request; in HWTEST_F() local
98 request.srcEntry = "./ets/AProcess.ts"; in HWTEST_F()
99 auto childRecord = std::make_shared<ChildProcessRecord>(101, request, nullptr); in HWTEST_F()
116 ChildProcessRequest request; in HWTEST_F() local
132 ChildProcessRequest request; HWTEST_F() local
151 ChildProcessRequest request; HWTEST_F() local
170 ChildProcessRequest request; HWTEST_F() local
186 ChildProcessRequest request; HWTEST_F() local
203 ChildProcessRequest request; HWTEST_F() local
220 ChildProcessRequest request; HWTEST_F() local
237 ChildProcessRequest request; HWTEST_F() local
257 ChildProcessRequest request; HWTEST_F() local
273 ChildProcessRequest request; HWTEST_F() local
291 ChildProcessRequest request; HWTEST_F() local
309 ChildProcessRequest request; HWTEST_F() local
328 ChildProcessRequest request; HWTEST_F() local
346 ChildProcessRequest request; HWTEST_F() local
360 ChildProcessRequest request; HWTEST_F() local
[all...] |
| /foundation/communication/dsoftbus/tests/core/authentication/unittest/ |
| H A D | auth_normalize_request_test.cpp | 50 * @tc.desc: notify normalize request success test
57 NormalizeRequest request; in HWTEST_F() local
60 (void)memset_s(&request, sizeof(NormalizeRequest), 0, sizeof(NormalizeRequest)); in HWTEST_F()
62 request.authSeq = 1; in HWTEST_F()
63 (void)memcpy_s(request.udidHash, SHA_256_HEX_HASH_LEN, udidHash, SHA_256_HEX_HASH_LEN); in HWTEST_F()
64 uint32_t ret = AddNormalizeRequest(&request); in HWTEST_F()
66 request.authSeq = 2; in HWTEST_F()
67 ret = AddNormalizeRequest(&request); in HWTEST_F()
69 DelAuthNormalizeRequest(request.authSeq); in HWTEST_F()
70 request in HWTEST_F()
90 NormalizeRequest request; HWTEST_F() local
[all...] |
| /foundation/distributeddatamgr/datamgr_service/services/distributeddataservice/service/test/ |
| H A D | data_share_service_stub_test.cpp | 57 MessageParcel request;
in HWTEST_F() local
58 request.WriteInterfaceToken(INTERFACE_TOKEN);
in HWTEST_F()
59 request.WriteBuffer(data, size);
in HWTEST_F()
60 request.RewindRead(0);
in HWTEST_F()
62 auto result = dataShareServiceStub->OnRemoteRequest(code, request, reply);
in HWTEST_F()
65 result = dataShareServiceStub->OnNotifyConnectDone(request, reply);
in HWTEST_F()
80 MessageParcel request;
in HWTEST_F() local
82 auto result = dataShareServiceStub->OnRemoteRequest(code, request, reply);
in HWTEST_F()
85 result = dataShareServiceStub->OnNotifyConnectDone(request, reply);
in HWTEST_F()
100 MessageParcel request;
in HWTEST_F() local
129 MessageParcel request; HWTEST_F() local
152 MessageParcel request; HWTEST_F() local
187 MessageParcel request; HWTEST_F() local
222 MessageParcel request; HWTEST_F() local
[all...] |
| /foundation/ai/ai_engine/services/client/communication_adapter/source/ |
| H A D | sa_client_proxy.cpp | 87 void ParcelClientInfo(IpcIo *request, const ClientInfo &clientInfo) in ParcelClientInfo() argument
89 WriteInt64(request, clientInfo.clientVersion); in ParcelClientInfo()
90 WriteInt32(request, clientInfo.clientId); in ParcelClientInfo()
91 WriteInt32(request, clientInfo.sessionId); in ParcelClientInfo()
92 WriteUint32(request, clientInfo.serverUid); in ParcelClientInfo()
93 WriteUint32(request, clientInfo.clientUid); in ParcelClientInfo()
96 ParcelDataInfo(request, &dataInfo, clientInfo.serverUid); in ParcelClientInfo()
99 void ParcelAlgorithmInfo(IpcIo *request, const AlgorithmInfo &algorithmInfo, const uid_t serverUid) in ParcelAlgorithmInfo() argument
101 WriteInt64(request, algorithmInfo.clientVersion); in ParcelAlgorithmInfo()
102 WriteBool(request, algorithmInf in ParcelAlgorithmInfo()
140 IpcIo request; InitSaEngine() local
164 IpcIo request; DestroyEngineProxy() local
195 IpcIo request; SyncExecAlgorithmProxy() local
229 IpcIo request; AsyncExecuteAlgorithmProxy() local
249 IpcIo request; LoadAlgorithmProxy() local
281 IpcIo request; UnloadAlgorithmProxy() local
302 IpcIo request; SetOptionProxy() local
324 IpcIo request; GetOptionProxy() local
366 IpcIo request; RegisterCallbackProxy() local
387 IpcIo request; UnregisterCallbackProxy() local
[all...] |
| /foundation/CastEngine/castengine_cast_plus_stream/src/channel/src/ |
| H A D | channel_manager.cpp | 72 int ChannelManager::CreateChannel(ChannelRequest &request, std::shared_ptr<IChannelListener> channelListener) in CreateChannel() argument
75 if (channelListener == nullptr || !IsRequestValid(request)) { in CreateChannel()
76 CLOGE("CreateChannel, channelListener is null or request is invalid."); in CreateChannel()
80 request.connectionId = ++connectionNum_; in CreateChannel()
81 std::shared_ptr<Connection> connection = GetConnection(request.linkType); in CreateChannel()
86 connectionMap_.insert(std::pair<ChannelRequest, std::shared_ptr<Connection>>(request, connection)); in CreateChannel()
89 bool isVtp = (request.linkType == ChannelLinkType::VTP); in CreateChannel()
90 bool isSink = (request.sessionProperty.endType == EndType::CAST_SINK); in CreateChannel()
91 CLOGI("CreateChannel In, linkType = %{public}d, isVtp = %{public}d, isSink = %{public}d.", request.linkType, in CreateChannel()
95 return connection->StartListen(request, channelListene in CreateChannel()
102 CreateChannel(ChannelRequest &request, std::shared_ptr<IChannelListener> channelListener, ChannelFileSchema &fileSchema) CreateChannel() argument
[all...] |
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/channel/src/ |
| H A D | channel_manager.cpp | 72 int ChannelManager::CreateChannel(ChannelRequest &request, std::shared_ptr<IChannelListener> channelListener) in CreateChannel() argument
75 if (channelListener == nullptr || !IsRequestValid(request)) { in CreateChannel()
76 CLOGE("CreateChannel, channelListener is null or request is invalid."); in CreateChannel()
80 request.connectionId = ++connectionNum_; in CreateChannel()
81 std::shared_ptr<Connection> connection = GetConnection(request.linkType); in CreateChannel()
86 connectionMap_.insert(std::pair<ChannelRequest, std::shared_ptr<Connection>>(request, connection)); in CreateChannel()
89 bool isVtp = (request.linkType == ChannelLinkType::VTP); in CreateChannel()
90 bool isSink = (request.sessionProperty.endType == EndType::CAST_SINK); in CreateChannel()
91 CLOGI("CreateChannel In, linkType = %{public}d, isVtp = %{public}d, isSink = %{public}d.", request.linkType, in CreateChannel()
95 return connection->StartListen(request, channelListene in CreateChannel()
102 CreateChannel(ChannelRequest &request, std::shared_ptr<IChannelListener> channelListener, ChannelFileSchema &fileSchema) CreateChannel() argument
[all...] |
| /foundation/communication/dsoftbus/sdk/bus_center/ipc/small/ |
| H A D | bus_center_server_proxy.c | 227 IpcIo request = {0}; in ServerIpcGetAllOnlineNodeInfo() local
228 IpcIoInit(&request, data, MAX_SOFT_BUS_IPC_LEN, 0); in ServerIpcGetAllOnlineNodeInfo()
229 WriteString(&request, pkgName); in ServerIpcGetAllOnlineNodeInfo()
230 WriteUint32(&request, infoTypeLen); in ServerIpcGetAllOnlineNodeInfo()
234 int32_t ans = g_serverProxy->Invoke(g_serverProxy, SERVER_GET_ALL_ONLINE_NODE_INFO, &request, &reply, in ServerIpcGetAllOnlineNodeInfo()
280 IpcIo request = {0}; in ServerIpcGetLocalDeviceInfo() local
281 IpcIoInit(&request, data, MAX_SOFT_BUS_IPC_LEN, 0); in ServerIpcGetLocalDeviceInfo()
282 WriteString(&request, pkgName); in ServerIpcGetLocalDeviceInfo()
283 WriteUint32(&request, infoTypeLen); in ServerIpcGetLocalDeviceInfo()
287 int32_t ans = g_serverProxy->Invoke(g_serverProxy, SERVER_GET_LOCAL_DEVICE_INFO, &request, in ServerIpcGetLocalDeviceInfo()
317 IpcIo request = {0}; ServerIpcGetNodeKeyInfo() local
356 IpcIo request = {0}; ServerIpcSetNodeDataChangeFlag() local
379 IpcIo request = {0}; ServerIpcRegDataLevelChangeCb() local
393 IpcIo request = {0}; ServerIpcUnregDataLevelChangeCb() local
407 IpcIo request = {0}; ServerIpcSetDataLevel() local
423 IpcIo request = {0}; ServerIpcJoinLNN() local
449 IpcIo request = {0}; ServerIpcLeaveLNN() local
475 IpcIo request = {0}; ServerIpcStartTimeSync() local
503 IpcIo request = {0}; ServerIpcStopTimeSync() local
528 IpcIo request = {0}; ServerIpcPublishLNN() local
565 IpcIo request = {0}; ServerIpcStopPublishLNN() local
590 IpcIo request = {0}; ServerIpcRefreshLNN() local
628 IpcIo request = {0}; ServerIpcStopRefreshLNN() local
649 IpcIo request = {0}; ServerIpcActiveMetaNode() local
684 IpcIo request = {0}; ServerIpcDeactiveMetaNode() local
708 IpcIo request = {0}; ServerIpcGetAllMetaNodeInfo() local
749 IpcIo request = {0}; ServerIpcShiftLNNGear() local
[all...] |
| /foundation/communication/dsoftbus/core/authentication/src/ |
| H A D | auth_request.c | 36 static uint32_t GetAuthRequestWaitNum(const AuthRequest *request) in GetAuthRequestWaitNum() argument
42 if (item->type != request->type || !CompareConnInfo(&request->connInfo, &item->connInfo, true)) { in GetAuthRequestWaitNum()
45 if (item->requestId == request->requestId) { in GetAuthRequestWaitNum()
49 if (request->addTime - item->addTime < AUTH_REQUEST_TIMTOUR) { in GetAuthRequestWaitNum()
51 "The two request addr are same. requestId1=%{public}u, requestId2=%{public}u", in GetAuthRequestWaitNum()
52 request->requestId, item->requestId); in GetAuthRequestWaitNum()
68 uint32_t AddAuthRequest(const AuthRequest *request) in AddAuthRequest() argument
70 AUTH_CHECK_AND_RETURN_RET_LOGE(request != NULL, 0, AUTH_CONN, "request i in AddAuthRequest()
88 GetAuthRequest(uint32_t requestId, AuthRequest *request) GetAuthRequest() argument
104 GetAuthRequestNoLock(uint32_t requestId, AuthRequest *request) GetAuthRequestNoLock() argument
116 FindAuthRequestByConnInfo(const AuthConnInfo *connInfo, AuthRequest *request) FindAuthRequestByConnInfo() argument
229 AuthRequest request; PerformVerifyCallback() local
247 AuthRequest request; PerformAuthConnCallback() local
[all...] |
| /foundation/communication/dhcp/frameworks/native/src/ |
| H A D | dhcp_server_proxy_lite.cpp | 177 IpcIo request; in RegisterDhcpServerCallBack() local
181 IpcIoInit(&request, data, IPC_DATA_SIZE_SMALL, MAX_IPC_OBJ_COUNT); in RegisterDhcpServerCallBack()
182 if (!WriteInterfaceToken(&request, DECLARE_INTERFACE_DESCRIPTOR_L1, DECLARE_INTERFACE_DESCRIPTOR_L1_LENGTH)) { in RegisterDhcpServerCallBack()
186 (void)WriteInt32(&request, 0); in RegisterDhcpServerCallBack()
187 (void)WriteRemoteObject(&request, &g_sid); in RegisterDhcpServerCallBack()
188 (void)WriteString(&request, ifname.c_str()); in RegisterDhcpServerCallBack()
192 &request, &owner, IpcCallback); in RegisterDhcpServerCallBack()
214 IpcIo request; in StartDhcpServer() local
218 IpcIoInit(&request, data, IPC_DATA_SIZE_MID, MAX_IPC_OBJ_COUNT); in StartDhcpServer()
219 if (!WriteInterfaceToken(&request, DECLARE_INTERFACE_DESCRIPTOR_L in StartDhcpServer()
252 IpcIo request; StopDhcpServer() local
291 IpcIo request; SetDhcpRange() local
336 IpcIo request; SetDhcpName() local
375 IpcIo request; PutDhcpRange() local
419 IpcIo request; RemoveAllDhcpRange() local
457 IpcIo request; UpdateLeasesTime() local
495 IpcIo request; RemoveDhcpRange() local
539 IpcIo request; GetDhcpClientInfos() local
[all...] |
| /foundation/barrierfree/accessibility/common/interface/test/fuzztest/accessibleabilitymanagerservicestub_fuzzer/ |
| H A D | accessibleabilitymanagerservicestub_fuzzer_back.cpp | 73 MessageParcel request; in HandleRegisterStateCallbackTest() local
75 request.WriteInterfaceToken(descriptor); in HandleRegisterStateCallbackTest()
76 if (!request.WriteInterfaceToken(descriptor)) { in HandleRegisterStateCallbackTest()
83 if (!request.WriteRemoteObject(callback->AsObject())) { in HandleRegisterStateCallbackTest()
90 static_cast<uint32_t>(AccessibilityInterfaceCode::REGISTER_STATE_CALLBACK), request, reply, option); in HandleRegisterStateCallbackTest() local
99 MessageParcel request; in HandleGetAbilityListTest() local
101 request.WriteInterfaceToken(descriptor); in HandleGetAbilityListTest()
102 if (!request.WriteInterfaceToken(descriptor)) { in HandleGetAbilityListTest()
109 if (!request.WriteUint32(abilityTypes)) { in HandleGetAbilityListTest()
113 if (!request in HandleGetAbilityListTest()
120 static_cast<uint32_t>(AccessibilityInterfaceCode::GET_ABILITYLIST), request, reply, option); HandleGetAbilityListTest() local
129 MessageParcel request; HandleRegisterAccessibilityElementOperatorTest() local
156 static_cast<uint32_t>(AccessibilityInterfaceCode::REGISTER_INTERACTION_CONNECTION), request, reply, option); HandleRegisterAccessibilityElementOperatorTest() local
165 MessageParcel request; HandleMultiRegisterAccessibilityElementOperatorTest() local
204 static_cast<uint32_t>(AccessibilityInterfaceCode::CARDREGISTER_INTERACTION_CONNECTION), request, reply, option); HandleMultiRegisterAccessibilityElementOperatorTest() local
213 MessageParcel request; HandleDeregisterAccessibilityElementOperatorTest() local
228 static_cast<uint32_t>(AccessibilityInterfaceCode::DEREGISTER_INTERACTION_CONNECTION), request, reply, option); HandleDeregisterAccessibilityElementOperatorTest() local
237 MessageParcel request; HandleSendEventTest() local
251 static_cast<uint32_t>(AccessibilityInterfaceCode::SEND_EVENT), request, reply, option); HandleSendEventTest() local
257 MessageParcel request; HandleSetDaltonizationStateTest() local
270 static_cast<uint32_t>(AccessibilityInterfaceCode::SET_DALTONIZATION_STATE), request, reply, option); HandleSetDaltonizationStateTest() local
276 MessageParcel request; HandleRemoveRequestIdTest() local
289 static_cast<uint32_t>(AccessibilityInterfaceCode::REMOVE_REQUEST_ID), request, reply, option); HandleRemoveRequestIdTest() local
[all...] |
| /foundation/communication/dsoftbus/sdk/transmission/ipc/small/ |
| H A D | trans_server_proxy.c | 62 static bool WriteQosInfo(IpcIo *request, const SessionParam *param) in WriteQosInfo() argument
64 if (!WriteBool(request, param->isQosLane)) { in WriteQosInfo()
73 if (!WriteUint32(request, param->qosCount)) { in WriteQosInfo()
79 if (!WriteBuffer(request, param->qos, sizeof(QosTV) * param->qosCount)) { in WriteQosInfo()
133 IpcIo request = {0}; in ServerIpcCreateSessionServer() local
134 IpcIoInit(&request, data, MAX_SOFT_BUS_IPC_LEN, 0); in ServerIpcCreateSessionServer()
135 WriteString(&request, pkgName); in ServerIpcCreateSessionServer()
136 WriteString(&request, sessionName); in ServerIpcCreateSessionServer()
144 int32_t ans = g_serverProxy->Invoke(g_serverProxy, SERVER_CREATE_SESSION_SERVER, &request, &ret, ProxyCallback); in ServerIpcCreateSessionServer()
161 IpcIo request in ServerIpcRemoveSessionServer() local
180 TransWriteIpcSessionAttrs(IpcIo *request, const SessionAttribute *attrs) TransWriteIpcSessionAttrs() argument
232 IpcIo request = {0}; ServerIpcOpenSession() local
275 IpcIo request = {0}; ServerIpcOpenAuthSession() local
300 IpcIo request = {0}; ServerIpcNotifyAuthSuccess() local
320 IpcIo request = {0}; ServerIpcReleaseResources() local
342 IpcIo request = {0}; ServerIpcCloseChannel() local
384 IpcIo request = {0}; ServerIpcSendMessage() local
[all...] |
| /foundation/communication/wifi/wifi/frameworks/native/src/ |
| H A D | wifi_scan_proxy_lite.cpp | 207 IpcIo request; in SetScanControlInfo() local
211 IpcIoInit(&request, data, IPC_DATA_SIZE_BIG, MAX_IPC_OBJ_COUNT); in SetScanControlInfo()
212 if (!WriteInterfaceToken(&request, DECLARE_INTERFACE_DESCRIPTOR_L1, DECLARE_INTERFACE_DESCRIPTOR_L1_LENGTH)) { in SetScanControlInfo()
216 (void)WriteInt32(&request, 0); in SetScanControlInfo()
217 (void)WriteInt32(&request, info.scanForbidList.size()); in SetScanControlInfo()
219 (void)WriteInt32(&request, iter->scanScene); in SetScanControlInfo()
220 (void)WriteInt32(&request, static_cast<int>(iter->scanMode)); in SetScanControlInfo()
221 (void)WriteInt32(&request, iter->forbidTime); in SetScanControlInfo()
222 (void)WriteInt32(&request, iter->forbidCount); in SetScanControlInfo()
225 (void)WriteInt32(&request, inf in SetScanControlInfo()
258 IpcIo request; Scan() local
291 IpcIo request; AdvanceScan() local
333 IpcIo request; IsWifiClosedScan() local
367 IpcIo request; GetScanInfoList() local
410 IpcIo request; RegisterCallBack() local
451 IpcIo request; GetSupportedFeatures() local
[all...] |
| /foundation/bundlemanager/bundle_framework_lite/services/bundlemgr_lite/src/ |
| H A D | bundle_daemon_client.cpp | 189 IpcIo request; in RegisterCallback() local
191 IpcIoInit(&request, data, MAX_IO_SIZE, 1); in RegisterCallback()
192 bool writeRemote = WriteRemoteObject(&request, &svcIdentity_); in RegisterCallback()
197 while (bdsClient_->Invoke(bdsClient_, REGISTER_CALLBACK, &request, this, Notify) != EC_SUCCESS) { in RegisterCallback()
199 while (bdsClient_->Invoke(bdsClient_, REGISTER_CALLBACK, &request, nullptr, nullptr) != EC_SUCCESS) { in RegisterCallback()
210 IpcIo request; in RegisterCallback() local
212 IpcIoInit(&request, data, MAX_IO_SIZE, 0); in RegisterCallback()
215 WriteString(&request, innerStr.c_str()); in RegisterCallback()
217 WriteUint16(&request, strlen(firstPath)); in RegisterCallback()
220 WriteBool(&request, keepDat in RegisterCallback()
279 IpcIo request; RegisterCallback() local
304 IpcIo request; RegisterCallback() local
328 IpcIo request; RegisterCallback() local
351 IpcIo request; RegisterCallback() local
[all...] |
| H A D | bundle_mgr_service.cpp | 65 Request request = {
in ServiceInitialize() local
75 (void) SAMGR_SendRequest(bundleManagerService->GetIdentity(), &request, nullptr);
in ServiceInitialize()
84 BOOL BundleMgrService::ServiceMessageHandle(Service *service, Request *request)
in ServiceMessageHandle() argument
86 if (request == nullptr) {
in ServiceMessageHandle()
89 if (request->msgId == BMS_INSTALL_MSG) {
in ServiceMessageHandle()
90 Bmsbuff *data = static_cast<Bmsbuff *>(request->data);
in ServiceMessageHandle()
93 AdapterFree(request->data);
in ServiceMessageHandle()
94 request->data = nullptr;
in ServiceMessageHandle()
95 request->len = 0;
in ServiceMessageHandle()
96 } else if (request in ServiceMessageHandle()
[all...] |
| /foundation/communication/bluetooth_service/services/bluetooth/stack/src/sdp/ |
| H A D | sdp_client.c | 181 SdpClientRequest *request = NULL; in SdpServiceSearch() local
190 /// Create service search request in SdpServiceSearch()
191 request = MEM_MALLOC.alloc(sizeof(SdpClientRequest)); in SdpServiceSearch()
192 (void)memset_s(request, sizeof(SdpClientRequest), 0, sizeof(SdpClientRequest)); in SdpServiceSearch()
201 LOG_ERROR("[%{public}s][%{public}d] Create search request failed", __FUNCTION__, __LINE__); in SdpServiceSearch()
205 (void)memcpy_s(&request->addr, sizeof(BtAddr), addr, sizeof(BtAddr)); in SdpServiceSearch()
206 request->pduId = SDP_SERVICE_SEARCH_REQUEST; in SdpServiceSearch()
207 request->transactionId = SdpGetTransactionId(); in SdpServiceSearch()
208 request->resentFlag = false; in SdpServiceSearch()
209 request in SdpServiceSearch()
227 SdpClientRequest *request = NULL; SdpServiceAttribute() local
272 SdpClientRequest *request = NULL; SdpServiceSearchAttribute() local
314 SdpClientRequest *request = NULL; SdpServiceBrowse() local
[all...] |
| /foundation/multimedia/media_library/frameworks/js/src/ |
| H A D | thumbnail_manager.cpp | 202 shared_ptr<ThumbnailRequest> request = make_shared<ThumbnailRequest>(params, env, callback); in AddPhotoRequest() local
204 request->SetUUID(requestId); in AddPhotoRequest()
205 if (!thumbRequest_.Insert(requestId, request)) { in AddPhotoRequest()
208 // judge from request option in AddPhotoRequest()
210 AddFastPhotoRequest(request); in AddPhotoRequest()
212 AddQualityPhotoRequest(request); in AddPhotoRequest()
249 void ThumbnailManager::AddFastPhotoRequest(const RequestSharedPtr &request) in AddFastPhotoRequest() argument
251 request->UpdateStatus(ThumbnailStatus::THUMB_FAST); in AddFastPhotoRequest()
252 fastQueue_.Push(request); in AddFastPhotoRequest()
256 void ThumbnailManager::AddQualityPhotoRequest(const RequestSharedPtr &request) in AddQualityPhotoRequest() argument
482 RequestFastImage(const RequestSharedPtr &request) RequestFastImage() argument
519 DealWithFastRequest(const RequestSharedPtr &request) DealWithFastRequest() argument
538 DealWithQualityRequest(const RequestSharedPtr &request) DealWithQualityRequest() argument
568 RequestSharedPtr request; ImageWorker() local
573 RequestSharedPtr request; ImageWorker() local
586 HandlePixelCallback(const RequestSharedPtr &request) HandlePixelCallback() argument
669 NotifyImage(const RequestSharedPtr &request) NotifyImage() argument
[all...] |
| /foundation/communication/netstack/test/fuzztest/http_fuzzer/ |
| H A D | http_fuzzer.cpp | 289 HttpClientRequest request; in HttpClientTaskGetHttpVersionFuzzTest() local
290 request.SetHttpProtocol(ptcl); in HttpClientTaskGetHttpVersionFuzzTest()
292 request.SetTimeout(timeout); in HttpClientTaskGetHttpVersionFuzzTest()
294 std::string result = request.GetBody(); in HttpClientTaskGetHttpVersionFuzzTest()
295 request.body_ = ""; in HttpClientTaskGetHttpVersionFuzzTest()
296 request.SetCaPath(testData); in HttpClientTaskGetHttpVersionFuzzTest()
298 request.SetPriority(priority); in HttpClientTaskGetHttpVersionFuzzTest()
299 result = request.GetURL(); in HttpClientTaskGetHttpVersionFuzzTest()
300 result = request.GetMethod(); in HttpClientTaskGetHttpVersionFuzzTest()
301 uint32_t ret = request in HttpClientTaskGetHttpVersionFuzzTest()
322 HttpClientRequest request; HttpClientTaskSetHttpProtocolFuzzTest() local
354 HttpClientRequest request; HttpClientTaskSetOtherCurlOptionFuzzTest() local
[all...] |
| /foundation/resourceschedule/memmgr/services/memmgrservice/src/event/ |
| H A D | extension_connection_observer.cpp | 60 ReclaimHandleRequest request; in OnDlpAbilityOpened() local
61 request.callerPid = data.callerPid; in OnDlpAbilityOpened()
62 request.callerUid = data.callerUid; in OnDlpAbilityOpened()
63 request.callerBundleName = data.callerName; in OnDlpAbilityOpened()
64 request.pid = data.targetPid; in OnDlpAbilityOpened()
65 request.uid = data.targetUid; in OnDlpAbilityOpened()
66 request.bundleName = data.targetBundleName; in OnDlpAbilityOpened()
67 request.reason = AppStateUpdateReason::BIND_EXTENSION; in OnDlpAbilityOpened()
80 ReclaimHandleRequest request; in OnDlpAbilityClosed() local
81 request in OnDlpAbilityClosed()
[all...] |
| /foundation/ability/ability_lite/services/abilitymgr_lite/src/slite/ |
| H A D | ability_mgr_service_slite.cpp | 123 BOOL AbilityMgrServiceSlite::OnFeatureMessage(Feature *feature, Request *request) in OnFeatureMessage() argument
125 if (feature == nullptr || request == nullptr) { in OnFeatureMessage()
150 BOOL AbilityMgrServiceSlite::ServiceMessageHandle(Service *service, Request *request) in ServiceMessageHandle() argument
152 if (request == nullptr) { in ServiceMessageHandle()
156 if (request->msgId == START_ABILITY) { in ServiceMessageHandle()
157 auto *data = static_cast<StartAbilityData *>(request->data); in ServiceMessageHandle()
165 AdapterFree(request->data); in ServiceMessageHandle()
166 request->data = nullptr; in ServiceMessageHandle()
167 request->len = 0; in ServiceMessageHandle()
168 } else if (request in ServiceMessageHandle()
[all...] |
| /foundation/ability/dmsfwk_lite/source/ |
| H A D | dmslite_feature.c | 31 static BOOL OnMessage(Feature *feature, Request *request);
73 static BOOL OnMessage(Feature *feature, Request *request) in OnMessage() argument
75 if (feature == NULL || request == NULL) { in OnMessage()
80 switch (request->msgId) { in OnMessage()
82 if (request->data == NULL) { in OnMessage()
84 HILOGE("[START_REMOTE_ABILITY request is NULL]"); in OnMessage()
87 const RequestData *data = (const RequestData *)request->data; in OnMessage()
96 HandleSessionOpened(request->msgValue); in OnMessage()
99 HandleSessionClosed(request->msgValue); in OnMessage()
102 HandleBytesReceived(request in OnMessage()
[all...] |
| /foundation/systemabilitymgr/samgr_lite/samgr/source/ |
| H A D | message.c | 33 int32 SAMGR_SendRequest(const Identity *identity, const Request *request, Handler handler)
in SAMGR_SendRequest() argument
35 if (request == NULL || identity == NULL) {
in SAMGR_SendRequest()
39 Exchange exchange = {*identity, *request, {NULL, 0}, MSG_NON, handler, NULL};
in SAMGR_SendRequest()
49 int32 SAMGR_SendResponse(const Request *request, const Response *response)
in SAMGR_SendResponse() argument
52 if (request == NULL) {
in SAMGR_SendResponse()
56 Exchange *exchange = GET_OBJECT(request, Exchange, request);
in SAMGR_SendResponse()
74 exchange->handler(&exchange->request, &exchange->response);
in SAMGR_SendResponse()
81 exchange->handler(&exchange->request, &exchange->response);
in SAMGR_SendResponse()
106 if (exchange->request in SAMGR_FreeMsg()
118 SAMGR_SendSharedRequest(const Identity *identity, const Request *request, uint32 *token, Handler handler) SAMGR_SendSharedRequest() argument
164 SAMGR_SendResponseByIdentity(const Identity *id, const Request *request, const Response *response) SAMGR_SendResponseByIdentity() argument
[all...] |
| /foundation/CastEngine/castengine_cast_plus_stream/src/rtsp/src/ |
| H A D | rtsp_package.cpp | 74 std::string request; in EncapAnnounce() local
75 request.append("ANNOUNCE * RTSP/1.0") in EncapAnnounce()
86 return request; in EncapAnnounce()
92 std::string request; in EncapRequestOption() local
93 request.append("OPTIONS * RTSP/1.0") in EncapRequestOption()
100 return request; in EncapRequestOption()
148 std::string request; in EncapRequestGetParameter() local
149 request.append("GET_PARAMETER rtsp://localhost/hisight") in EncapRequestGetParameter()
160 request.append(body); in EncapRequestGetParameter()
162 return request; in EncapRequestGetParameter()
235 EncapResponseGetParamM3(ParamInfo &clientParam, RtspParse &request, int seq) EncapResponseGetParamM3() argument
399 std::string request; EncapSetParameterM4Request() local
512 std::string request; EncapActionRequest() local
537 std::string request; EncapKeepAliveRequest() local
546 EncapCommonResponse(RtspParse &request, const std::string &statusCode) EncapCommonResponse() argument
561 std::string request; EncapSetupRequest() local
609 std::string request; EncapPlayRequest() local
625 std::string request; EncapTearDownRequest() local
636 std::string request; EncapPauseRequest() local
648 std::string request; EncapEventChangeRequest() local
671 std::string request; EncapSetParamRequestM11() local
682 std::string request; EncapCastRenderReadyRequest() local
[all...] |
| /foundation/CastEngine/castengine_cast_framework/service/src/session/src/rtsp/src/ |
| H A D | rtsp_package.cpp | 74 std::string request; in EncapAnnounce() local
75 request.append("ANNOUNCE * RTSP/1.0") in EncapAnnounce()
86 return request; in EncapAnnounce()
92 std::string request; in EncapRequestOption() local
93 request.append("OPTIONS * RTSP/1.0") in EncapRequestOption()
100 return request; in EncapRequestOption()
148 std::string request; in EncapRequestGetParameter() local
149 request.append("GET_PARAMETER rtsp://localhost/hisight") in EncapRequestGetParameter()
160 request.append(body); in EncapRequestGetParameter()
162 return request; in EncapRequestGetParameter()
235 EncapResponseGetParamM3(ParamInfo &clientParam, RtspParse &request, int seq) EncapResponseGetParamM3() argument
399 std::string request; EncapSetParameterM4Request() local
512 std::string request; EncapActionRequest() local
537 std::string request; EncapKeepAliveRequest() local
546 EncapCommonResponse(RtspParse &request, const std::string &statusCode) EncapCommonResponse() argument
561 std::string request; EncapSetupRequest() local
609 std::string request; EncapPlayRequest() local
625 std::string request; EncapTearDownRequest() local
636 std::string request; EncapPauseRequest() local
648 std::string request; EncapEventChangeRequest() local
671 std::string request; EncapSetParamRequestM11() local
682 std::string request; EncapCastRenderReadyRequest() local
[all...] |
| /foundation/ability/ability_lite/frameworks/abilitymgr_lite/src/slite/ |
| H A D | abilityms_slite_client.cpp | 55 int32_t AbilityMsClient::SendRequestToAms(Request &request) const
in SendRequestToAms()
59 int32_t ret = SAMGR_SendRequest(identity_, &request, nullptr);
in SendRequestToAms()
106 Request request = {
in StartAbility() local
112 return SendRequestToAms(request);
in StartAbility()
120 Request request = {
in TerminateAbility() local
126 return SendRequestToAms(request);
in TerminateAbility()
131 Request request = {
in TerminateMission() local
137 return SendRequestToAms(request);
in TerminateMission()
149 Request request = {
in TerminateAll() local
155 return SendRequestToAms(request);
in TerminateAll()
163 Request request = { SchedulerLifecycleDone() local
178 Request request = { ForceStopBundle() local
218 Request request = { ForceStop() local
249 Request request = { ForceStop() local
262 Request request = { AddAbilityRecordObserver() local
277 Request request = { RemoveAbilityRecordObserver() local
[all...] |
| /foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | async_msg_handler.cpp | 40 IRequest *request = task.request; in Process() local
41 if (request == nullptr) { in Process()
42 HILOGE("[AsyncMsgHandler]Invalid request param"); in Process()
46 ResGuard<IRequest> guardReq(request); in Process()
47 return pluginAlgorithm_->AsyncProcess(request, this); in Process()
71 int AsyncMsgHandler::SendRequest(IRequest *request) in SendRequest() argument
73 if (request == nullptr) { in SendRequest()
74 HILOGE("[AsyncMsgHandler]Invalid request param"); in SendRequest()
86 int retCode = futureFactory->CreateFuture(request); in SendRequest()
[all...] |