Home
last modified time | relevance | path

Searched refs:transactionId (Results 1 – 25 of 85) sorted by relevance

1234

/ohos5.0/foundation/ai/ai_engine/services/server/communication_adapter/source/
H A Dsa_server_adapter.cpp44 int SaServerAdapter::GetSessionId(long long transactionId) const in GetSessionId()
46 return static_cast<int>(static_cast<unsigned long long>(transactionId) & TRANS_ID_MASK); in GetSessionId()
163 SaveTransaction(transactionId); in LoadAlgorithm()
175 return engineManager->SetOption(transactionId, optionType, dataInfo); in SetOption()
187 return engineManager->GetOption(transactionId, optionType, dataInfo, outputInfo); in GetOption()
190 void SaServerAdapter::SaveTransaction(long long transactionId) in SaveTransaction() argument
193 transactionIds_.insert(transactionId); in SaveTransaction()
203 int retCode = engineInstance->StopEngine(transactionId, inputInfo); in UnloadAlgorithm()
208 RemoveTransaction(transactionId); in UnloadAlgorithm()
212 void SaServerAdapter::RemoveTransaction(long long transactionId) in RemoveTransaction() argument
[all …]
H A Dsa_async_handler.cpp89 void SaAsyncHandler::RemoveTransaction(long long transactionId) in RemoveTransaction() argument
92 transactions_.erase(transactionId); in RemoveTransaction()
95 bool SaAsyncHandler::IsExistTransaction(long long transactionId) in IsExistTransaction() argument
98 auto iter = transactions_.find(transactionId); in IsExistTransaction()
102 void SaAsyncHandler::SaveTransaction(long long transactionId) in SaveTransaction() argument
105 transactions_.insert(transactionId); in SaveTransaction()
163 taskManager->RegisterListener(listener, transactionId); in StartAsyncTransaction()
164 SaveTransaction(transactionId); in StartAsyncTransaction()
170 CHK_RET_NONE(!IsExistTransaction(transactionId)); in StopAsyncTransaction()
177 taskManager->UnRegisterListener(transactionId); in StopAsyncTransaction()
[all …]
H A Dadapter_wrapper.cpp179 long long transactionId = adapter->GetTransactionId(clientInfo->sessionId); in LoadAlgoWrapper() local
180 int retCode = adapter->LoadAlgorithm(transactionId, *algoInfo, *inputInfo, *outputInfo); in LoadAlgoWrapper()
183 transactionId, retCode, algoInfo->algorithmType); in LoadAlgoWrapper()
190 retCode = saAsyncHandler->StartAsyncTransaction(transactionId, clientInfo->clientId); in LoadAlgoWrapper()
206 long long transactionId = adapter->GetTransactionId(clientInfo->sessionId); in UnloadAlgoWrapper() local
214 saAsyncHandler->StopAsyncTransaction(transactionId); in UnloadAlgoWrapper()
218 return adapter->UnloadAlgorithm(transactionId, *inputInfo); in UnloadAlgoWrapper()
246 long long transactionId = adapter->GetTransactionId(clientInfo->sessionId); in SetOptionWrapper() local
247 return adapter->SetOption(transactionId, optionType, *inputInfo); in SetOptionWrapper()
264 long long transactionId = adapter->GetTransactionId(clientInfo->sessionId); in GetOptionWrapper() local
[all …]
/ohos5.0/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dengine_manager.cpp71 transactionId, retCode); in StartEngine()
86 RecordClient(transactionId, engine); in StartEngine()
92 std::shared_ptr<Engine> engine = FindEngine(transactionId); in StopEngine()
127 UnRecordClient(transactionId); in StopEngine()
133 std::shared_ptr<Engine> engine = FindEngine(transactionId); in SetOption()
149 std::shared_ptr<Engine> engine = FindEngine(transactionId); in GetOption()
162 std::shared_ptr<Engine> EngineManager::FindEngine(long long transactionId) in FindEngine() argument
165 auto iter = clientEngines_.find(transactionId); in FindEngine()
176 clientEngines_[transactionId] = engine; in RecordClient()
179 void EngineManager::UnRecordClient(long long transactionId) in UnRecordClient() argument
[all …]
H A Dserver_executor.cpp88 return engineMgr_->StartEngine(transactionId, algoInfo, inputInfo, outputInfo); in StartEngine()
91 int ServerExecutor::StopEngine(long long transactionId, const DataInfo &inputInfo) in StopEngine() argument
96 return engineMgr_->StopEngine(transactionId, inputInfo); in StopEngine()
99 int ServerExecutor::SetOption(long long transactionId, int optionType, const DataInfo &inputInfo) in SetOption() argument
104 return engineMgr_->SetOption(transactionId, optionType, inputInfo); in SetOption()
107 int ServerExecutor::GetOption(long long transactionId, int optionType, const DataInfo &inputInfo, in GetOption() argument
113 return engineMgr_->GetOption(transactionId, optionType, inputInfo, outputInfo); in GetOption()
150 int ServerExecutor::RegisterListener(IFutureListener *listener, long long transactionId) in RegisterListener() argument
154 futureFactory->RegisterListener(listener, transactionId); in RegisterListener()
158 int ServerExecutor::UnRegisterListener(long long transactionId) in UnRegisterListener() argument
[all …]
H A Dfuture_factory.cpp138 void FutureFactory::RegisterListener(IFutureListener *listener, long long transactionId) in RegisterListener() argument
141 listeners_[transactionId] = listener; in RegisterListener()
144 void FutureFactory::UnregisterListener(long long transactionId) in UnregisterListener() argument
147 auto iter = listeners_.find(transactionId); in UnregisterListener()
151 listeners_.erase(transactionId); in UnregisterListener()
194 IFutureListener *FutureFactory::FindListener(long long transactionId) in FindListener() argument
198 auto findProc = listeners_.find(transactionId); in FindListener()
/ohos5.0/foundation/ai/ai_engine/services/server/communication_adapter/include/
H A Dsa_server_adapter.h73 int GetSessionId(long long transactionId) const;
96 …int LoadAlgorithm(long long transactionId, const AlgorithmInfo &algoInfo, const DataInfo &inputInf…
107 int SetOption(long long transactionId, int optionType, const DataInfo &dataInfo);
118 …int GetOption(long long transactionId, int optionType, const DataInfo &dataInfo, DataInfo &outputI…
127 int UnloadAlgorithm(long long transactionId, const DataInfo &inputInfo);
143 void SaveTransaction(long long transactionId);
144 void RemoveTransaction(long long transactionId);
H A Dsa_async_handler.h74 int StartAsyncTransaction(long long transactionId, int clientId);
81 void StopAsyncTransaction(long long transactionId);
107 void RemoveTransaction(long long transactionId);
115 bool IsExistTransaction(long long transactionId);
122 void SaveTransaction(long long transactionId);
/ohos5.0/foundation/ai/ai_engine/services/server/server_executor/include/
H A Dengine_manager.h74 … int StartEngine(long long transactionId, const AlgorithmInfo &algoInfo, const DataInfo &inputInfo,
84 int StopEngine(long long transactionId, const DataInfo &inputInfo);
92 std::shared_ptr<Engine> FindEngine(long long transactionId);
102 int SetOption(long long transactionId, int optionType, const DataInfo &inputInfo);
113 int GetOption(long long transactionId, int optionType, const DataInfo &inputInfo,
118 void RecordClient(long long transactionId, const std::shared_ptr<Engine> &engine);
119 void UnRecordClient(long long transactionId);
H A Dserver_executor.h75 int RegisterListener(IFutureListener *listener, long long transactionId) override;
83 int UnRegisterListener(long long transactionId) override;
94 … int StartEngine(long long transactionId, const AlgorithmInfo &algoInfo, const DataInfo &inputInfo,
104 int StopEngine(long long transactionId, const DataInfo &inputInfo) override;
114 int SetOption(long long transactionId, int optionType, const DataInfo &inputInfo) override;
125 int GetOption(long long transactionId, int optionType, const DataInfo &inputInfo,
H A Di_engine_manager.h42 …virtual int StartEngine(long long transactionId, const AlgorithmInfo &algoInfo, const DataInfo &in…
52 virtual int StopEngine(long long transactionId, const DataInfo &inputInfo) = 0;
62 virtual int SetOption(long long transactionId, int optionType, const DataInfo &inputInfo) = 0;
73 virtual int GetOption(long long transactionId, int optionType, const DataInfo &inputInfo,
H A Dfuture_factory.h62 void RegisterListener(IFutureListener *listener, long long transactionId);
69 void UnregisterListener(long long transactionId);
87 IFutureListener *FindListener(long long transactionId);
H A Di_async_task_manager.h46 virtual int RegisterListener(IFutureListener *listener, long long transactionId) = 0;
55 virtual int UnRegisterListener(long long transactionId) = 0;
/ohos5.0/foundation/communication/bluetooth_service/services/bluetooth/stack/src/sdp/
H A Dsdp_connect.h34 void SdpSendErrorResponse(uint16_t lcid, uint16_t transactionId, uint16_t errorCode);
36 uint16_t lcid, uint16_t transactionId, uint16_t maxCount, const Packet *searchPacket);
37 void SdpSendSearchResponse(uint16_t lcid, uint16_t transactionId, uint16_t offset, uint8_t *buffer,…
39 …uint16_t lcid, SdpPduId pduId, uint16_t transactionId, uint16_t maxCount, const Packet *attributeP…
41 uint16_t lcid, uint16_t transactionId, SdpPduId pduId, uint16_t maxCount, const Packet *packet);
42 void SdpSendRequest(uint16_t lcid, uint16_t transactionId, uint8_t continuationStateLen,
H A Dsdp_client_parse.c158 if (request->transactionId == transactionId) { in SdpFindRequestByTransactionId()
313 uint16_t transactionId; in SdpParseServerResponse() local
334 SdpCallbackError(addr, transactionId); in SdpParseServerResponse()
627 SdpCallbackError(addr, transactionId); in SdpParseResponseCommon()
638 SdpCallbackError(addr, transactionId); in SdpParseResponseCommon()
666 SdpCallbackError(addr, transactionId); in SdpParseErrorResponse()
682 SdpCallbackError(addr, transactionId); in SdpParseSearchResponse()
693 SdpCallbackError(addr, transactionId); in SdpParseSearchResponse()
716 SdpCallbackError(addr, transactionId); in SdpParseSearchResponse()
751 SdpCallbackError(addr, transactionId); in SdpParseAttributeResponse()
[all …]
H A Dsdp_server.c1048 uint16_t transactionId; in SdpParseClientRequest() local
1058 transactionId = BE2H_16(*(uint16_t *)(header + 1)); in SdpParseClientRequest()
1063 SdpSendErrorResponse(lcid, transactionId, SDP_INVALID_PDU_SIZE); in SdpParseClientRequest()
1072 transactionId, in SdpParseClientRequest()
1087 SdpParseSearchRequest(lcid, transactionId, &bufferInfo); in SdpParseClientRequest()
1090 SdpParseAttributeRequest(lcid, transactionId, &bufferInfo); in SdpParseClientRequest()
1208 SdpSendErrorResponse(lcid, transactionId, SDP_INVALID_CONT_STATE); in SdpParseSearchRequest()
1227 SdpSendErrorResponse(lcid, transactionId, SDP_INVALID_REQ_SYNTAX); in SdpParseSearchRequest()
1337 SdpSendErrorResponse(lcid, transactionId, SDP_INVALID_PDU_SIZE); in SdpCreateAttributeResponse()
1394 SdpSendErrorResponse(lcid, transactionId, SDP_INVALID_CONT_STATE); in SdpParseAttributeRequest()
[all …]
H A Dsdp_connect.c1216 *(uint16_t *)(header + offset) = H2BE_16(transactionId); in SdpSendErrorResponse()
1274 *(uint16_t *)(header + offset) = H2BE_16(transactionId); in SdpBuildSearchFragmentResponse()
1322 SdpSendErrorResponse(lcid, transactionId, SDP_INVALID_CONT_STATE); in SdpSendSearchFragmentResponse()
1375 SdpSendSearchFragmentResponse(lcid, transactionId, maxCount, packet); in SdpSendSearchResponse()
1390 *(uint16_t *)(header + pos) = H2BE_16(transactionId); in SdpSendSearchResponse()
1413 SdpPduId pduId, uint16_t transactionId, size_t size, Packet *fragmentPacket) in SdpBuildAttributeFragmentResponse() argument
1455 *(uint16_t *)(header + offset) = H2BE_16(transactionId); in SdpBuildAttributeFragmentResponse()
1494 SdpSendErrorResponse(lcid, transactionId, SDP_INVALID_CONT_STATE); in SdpSendAttributeFragmentResponse()
1555 *(uint16_t *)(header + offset) = H2BE_16(transactionId); in SdpSendAttributeResponse()
1597 request = SdpFindRequestByTransactionId(transactionId); in SdpSendRequest()
[all …]
/ohos5.0/docs/zh-cn/device-dev/reference/hdi-apis/usb/
H A D_usb_fn_mtp_file_slice.md24 | unsigned int [transactionId](#transactionid) | 传输id |
70 ### transactionId subsection
73 unsigned int UsbFnMtpFileSlice::transactionId
/ohos5.0/foundation/ai/ai_engine/services/common/protocol/data_channel/source/
H A Drequest.cpp89 void Request::SetTransactionId(long long transactionId) in SetTransactionId() argument
91 transactionId_ = transactionId; in SetTransactionId()
161 void IRequest::SetTransactionId(long long transactionId) in SetTransactionId() argument
163 RequestCast::Ref(this).SetTransactionId(transactionId); in SetTransactionId()
H A Dresponse.cpp70 void Response::SetTransactionId(long long transactionId) in SetTransactionId() argument
72 transactionId_ = transactionId; in SetTransactionId()
152 void IResponse::SetTransactionId(long long transactionId) in SetTransactionId() argument
154 ResponseCast::Ref(this).SetTransactionId(transactionId); in SetTransactionId()
/ohos5.0/base/telephony/sms_mms/frameworks/js/napi/include/
H A Dnapi_mms.h70 std::string transactionId = ""; member
78 std::string transactionId = ""; member
94 std::string transactionId = ""; member
108 std::string transactionId = ""; member
115 std::string transactionId = ""; member
133 std::string transactionId = ""; member
/ohos5.0/base/telephony/sms_mms/interfaces/kits/js/
H A D@ohos.telephony.sms.d.ts1008 transactionId: string;
1168 transactionId: string;
1208 transactionId: string;
1318 transactionId: string;
1368 transactionId: string;
1518 transactionId: string;
/ohos5.0/foundation/ability/idl_tool/test/hdi_unittest/usb_gadget_mtp_v1_0/cpp_target/usb/gadget/mtp/v1_0/
H A Dusbfn_mtp_types.cpp.txt89 if (!data.WriteUint32(dataBlock.transactionId)) {
90 HDF_LOGE("%{public}s: write dataBlock.transactionId failed!", __func__);
119 if (!data.ReadUint32(dataBlock.transactionId)) {
120 HDF_LOGE("%{public}s: read dataBlock.transactionId failed!", __func__);
/ohos5.0/foundation/ai/ai_engine/services/server/plugin/
H A Di_plugin.h75 … virtual int Prepare(long long transactionId, const DataInfo &inputInfo, DataInfo &outputInfo) = 0;
85 virtual int Release(bool isFullUnload, long long transactionId, const DataInfo &inputInfo) = 0;
/ohos5.0/foundation/ai/ai_engine/test/sample/include/
H A Dsample_plugin_1.h39 int Prepare(long long transactionId, const DataInfo &inputInfo, DataInfo &outputInfo) override;
41 int Release(bool isFullUnload, long long transactionId, const DataInfo &inputInfo) override;

1234