Home
last modified time | relevance | path

Searched refs:transactionId (Results 1 - 25 of 59) sorted by relevance

123

/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()
149 int SaServerAdapter::LoadAlgorithm(long long transactionId, const AlgorithmInfo &algoInfo, in LoadAlgorithm() argument
154 HILOGE("[SaServerAdapter][transactionId:%lld]Failed to get engine manager.", transactionId); in LoadAlgorithm()
157 int retCode = engineManager->StartEngine(transactionId, algoInfo, inputInfo, outputInfo); in LoadAlgorithm()
159 HILOGE("[SaServerAdapter][transactionId:%lld]Failed to load algorithm.", transactionId); in LoadAlgorithm()
163 SaveTransaction(transactionId); in LoadAlgorithm()
167 int SaServerAdapter::SetOption(long long transactionId, in argument
178 GetOption(long long transactionId, int optionType, const DataInfo &dataInfo, DataInfo &outputInfo) GetOption() argument
190 SaveTransaction(long long transactionId) SaveTransaction() argument
196 UnloadAlgorithm(long long transactionId, const DataInfo &inputInfo) UnloadAlgorithm() argument
212 RemoveTransaction(long long transactionId) 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()
148 int SaAsyncHandler::StartAsyncTransaction(long long transactionId, int clientId) in StartAsyncTransaction() argument
150 CHK_RET(IsExistTransaction(transactionId), RETCODE_SUCCESS); in StartAsyncTransaction()
163 taskManager->RegisterListener(listener, transactionId); in StartAsyncTransaction()
164 SaveTransaction(transactionId); in StartAsyncTransaction()
168 StopAsyncTransaction(long long transactionId) StopAsyncTransaction() argument
[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()
182 HILOGE("[AdapterWrapper][transactionId:%lld]Failed to load algorithm, retCode[%d], aid[%d].", 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, optionTyp in SetOptionWrapper()
264 long long transactionId = adapter->GetTransactionId(clientInfo->sessionId); GetOptionWrapper() local
[all...]
/foundation/ai/ai_engine/services/server/communication_adapter/include/
H A Dsa_server_adapter.h70 * @param transactionId client ID + session ID
73 int GetSessionId(long long transactionId) const;
90 * @param [in] transactionId Client ID + Session ID.
96 int LoadAlgorithm(long long transactionId, const AlgorithmInfo &algoInfo, const DataInfo &inputInfo,
107 int SetOption(long long transactionId, int optionType, const DataInfo &dataInfo);
118 int GetOption(long long transactionId, int optionType, const DataInfo &dataInfo, DataInfo &outputInfo);
123 * @param [in] transactionId Client ID + Session ID.
127 int UnloadAlgorithm(long long transactionId, const DataInfo &inputInfo);
143 void SaveTransaction(long long transactionId);
144 void RemoveTransaction(long long transactionId);
[all...]
H A Dsa_async_handler.h70 * @param transactionId Transaction ID.
74 int StartAsyncTransaction(long long transactionId, int clientId);
79 * @param transactionId.
81 void StopAsyncTransaction(long long transactionId);
103 * Remove transaction ID from a set<transactionId> {@link TransactionIds}.
105 * @param transactionId transaction ID.
107 void RemoveTransaction(long long transactionId);
112 * @param transactionId transaction ID.
115 bool IsExistTransaction(long long transactionId);
118 * Save transaction ID in a set<transactionId> {
[all...]
/foundation/ai/ai_engine/services/server/server_executor/include/
H A Dserver_executor.h72 * @param [in] transactionId Transaction ID.
75 int RegisterListener(IFutureListener *listener, long long transactionId) override;
80 * @param [in] transactionId Transaction ID.
83 int UnRegisterListener(long long transactionId) override;
88 * @param [in] transactionId Transaction ID.
94 int StartEngine(long long transactionId, const AlgorithmInfo &algoInfo, const DataInfo &inputInfo,
100 * @param [in] transactionId Transaction ID.
104 int StopEngine(long long transactionId, const DataInfo &inputInfo) override;
109 * @param [in] transactionId Transaction ID.
114 int SetOption(long long transactionId, in
[all...]
H A Dengine_manager.h68 * @param [in] transactionId Transaction ID.
74 int StartEngine(long long transactionId, const AlgorithmInfo &algoInfo, const DataInfo &inputInfo,
80 * @param [in] transactionId Transaction ID.
84 int StopEngine(long long transactionId, const DataInfo &inputInfo);
89 * @param [in] transactionId Transaction ID.
92 std::shared_ptr<Engine> FindEngine(long long transactionId);
97 * @param [in] transactionId Transaction ID.
102 int SetOption(long long transactionId, int optionType, const DataInfo &inputInfo);
107 * @param [in] transactionId Transaction ID.
113 int GetOption(long long transactionId, in
[all...]
H A Di_engine_manager.h36 * @param [in] transactionId Transaction ID.
42 virtual int StartEngine(long long transactionId, const AlgorithmInfo &algoInfo, const DataInfo &inputInfo,
48 * @param [in] transactionId Transaction ID.
52 virtual int StopEngine(long long transactionId, const DataInfo &inputInfo) = 0;
57 * @param [in] transactionId Transaction ID.
62 virtual int SetOption(long long transactionId, int optionType, const DataInfo &inputInfo) = 0;
67 * @param [in] transactionId Transaction ID.
73 virtual int GetOption(long long transactionId, int optionType, const DataInfo &inputInfo,
H A Dfuture_factory.h57 * Register callback for the transactionId.
60 * @param [in] transactionId Transaction ID.
62 void RegisterListener(IFutureListener *listener, long long transactionId);
65 * Unregister the callback corresponding to transactionId.
67 * @param [in] transactionId Transaction ID.
69 void UnregisterListener(long long transactionId);
87 IFutureListener *FindListener(long long transactionId);
H A Di_async_task_manager.h39 * Register callback for the transactionId. You need to override this function to
43 * @param [in] transactionId Transaction ID.
46 virtual int RegisterListener(IFutureListener *listener, long long transactionId) = 0;
49 * Unregister the callback corresponding to transactionId. You need to override this function to
52 * @param [in] transactionId Transaction ID.
55 virtual int UnRegisterListener(long long transactionId) = 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, uint16_t maxCount);
39 uint16_t lcid, SdpPduId pduId, uint16_t transactionId, uint16_t maxCount, const Packet *attributePacket);
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.c41 static void SdpCallbackError(const BtAddr *address, uint16_t transactionId);
43 const BtAddr *addr, uint16_t transactionId, uint16_t parameterLength, const Packet *packet);
44 static void SdpParseSearchResponse(const BtAddr *addr, uint16_t lcid, uint16_t transactionId, Packet *packet);
45 static void SdpParseAttributeResponse(const BtAddr *addr, uint16_t lcid, uint16_t transactionId, Packet *packet);
46 static void SdpParseSearchAttributeResponse(const BtAddr *addr, uint16_t lcid, uint16_t transactionId, Packet *packet);
147 SdpClientRequest *SdpFindRequestByTransactionId(uint16_t transactionId) in SdpFindRequestByTransactionId() argument
158 if (request->transactionId == transactionId) { in SdpFindRequestByTransactionId()
172 static void SdpRemoveRequestByTransactionId(uint16_t transactionId) in SdpRemoveRequestByTransactionId() argument
176 request = SdpFindRequestByTransactionId(transactionId); in SdpRemoveRequestByTransactionId()
220 SdpCallbackError(const BtAddr *address, uint16_t transactionId) SdpCallbackError() argument
256 SdpSendRequestForAssemblePacket(uint16_t lcid, uint16_t transactionId, Packet *packet, const uint8_t *continuationState, uint8_t continuationStateLen) SdpSendRequestForAssemblePacket() argument
281 SdpGetCallback(const BtAddr *addr, uint16_t transactionId, void **context) SdpGetCallback() argument
313 uint16_t transactionId; SdpParseServerResponse() local
360 SdpParseServiceRecordHandleList( const BtAddr *addr, uint16_t transactionId, uint16_t totalServiceRecordCount, Packet *data, uint32_t *handleArray) SdpParseServiceRecordHandleList() argument
494 SdpParseAttributeList(const BtAddr *addr, uint16_t transactionId, Packet *data, SdpService *service) SdpParseAttributeList() argument
550 SdpParseAttributeListArray( const BtAddr *addr, uint16_t transactionId, Packet *data, SdpService *serviceArray) SdpParseAttributeListArray() argument
619 SdpParseResponseCommon( const BtAddr *addr, uint16_t lcid, uint16_t transactionId, Packet *packet, uint16_t length) SdpParseResponseCommon() argument
650 SdpParseErrorResponse( const BtAddr *addr, uint16_t transactionId, uint16_t parameterLength, const Packet *packet) SdpParseErrorResponse() argument
669 SdpParseSearchResponse(const BtAddr *addr, uint16_t lcid, uint16_t transactionId, Packet *packet) SdpParseSearchResponse() argument
734 SdpParseAttributeResponse(const BtAddr *addr, uint16_t lcid, uint16_t transactionId, Packet *packet) SdpParseAttributeResponse() argument
783 SdpParseSearchAttributeResponse(const BtAddr *addr, uint16_t lcid, uint16_t transactionId, Packet *packet) SdpParseSearchAttributeResponse() argument
[all...]
H A Dsdp_server.c71 static void SdpParseSearchRequest(uint16_t lcid, uint16_t transactionId, BufferInfo *bufferInfo);
72 static void SdpParseAttributeRequest(uint16_t lcid, uint16_t transactionId, BufferInfo *bufferInfo);
73 static void SdpParseSearchAttributeRequest(uint16_t lcid, uint16_t transactionId, BufferInfo *bufferInfo);
1048 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()
1068 LOG_INFO("[%{public}s][%{public}d] pduId[0x%x] transactionId[0x%02x] parameterLength[0x%02x]", in SdpParseClientRequest()
1072 transactionId, in SdpParseClientRequest()
1087 SdpParseSearchRequest(lcid, transactionId, &bufferInfo); in SdpParseClientRequest()
1090 SdpParseAttributeRequest(lcid, transactionId, in SdpParseClientRequest()
1105 SdpCreateSearchResponse( uint16_t lcid, uint16_t transactionId, uint8_t uuidArray[][20], int uuidNum, uint16_t maximumServiceRecordCount) SdpCreateSearchResponse() argument
1170 SdpParseSearchRequest(uint16_t lcid, uint16_t transactionId, BufferInfo *bufferInfo) SdpParseSearchRequest() argument
1311 SdpCreateAttributeResponse( uint16_t lcid, uint16_t transactionId, uint8_t *attributeList, int length, uint16_t maximumAttributeByteCount) SdpCreateAttributeResponse() argument
1356 SdpParseAttributeRequest(uint16_t lcid, uint16_t transactionId, BufferInfo *bufferInfo) SdpParseAttributeRequest() argument
1550 SdpCreateSearchAttributeResponse( uint16_t lcid, uint16_t transactionId, Packet *payloadPacket, uint16_t maximumAttributeByteCount) SdpCreateSearchAttributeResponse() argument
1574 SdpParseSearchAttributeRequestCommon( uint16_t lcid, uint16_t transactionId, uint16_t maximumAttributeByteCount, uint8_t *buffer, uint16_t offset) SdpParseSearchAttributeRequestCommon() argument
1602 SdpParseSearchAttributeRequest(uint16_t lcid, uint16_t transactionId, BufferInfo *bufferInfo) SdpParseSearchAttributeRequest() argument
[all...]
H A Dsdp_connect.c488 SdpSendRequest(lcid, request->transactionId, 0, NULL, request->packet); in SdpConfigRspCallbackTask()
865 SdpSendRequest(connect->lcid, request->transactionId, 0, NULL, request->packet); in SdpReceiveConfigResponseTask()
1157 SdpSendRequest(connect->lcid, request->transactionId, 0, NULL, request->packet); in SdpReceiveDataTask()
1200 void SdpSendErrorResponse(uint16_t lcid, uint16_t transactionId, uint16_t errorCode) in SdpSendErrorResponse() argument
1216 *(uint16_t *)(header + offset) = H2BE_16(transactionId); in SdpSendErrorResponse()
1235 static Packet *SdpBuildSearchFragmentResponse(uint16_t transactionId, size_t size, uint16_t totalServiceRecordCount, in SdpBuildSearchFragmentResponse() argument
1274 *(uint16_t *)(header + offset) = H2BE_16(transactionId); in SdpBuildSearchFragmentResponse()
1288 void SdpSendSearchFragmentResponse(uint16_t lcid, uint16_t transactionId, uint16_t maxCount, const Packet *searchPacket) in SdpSendSearchFragmentResponse() argument
1320 transactionId, size, totalServiceRecordCount, currentServiceRecordCount, fragmentPacket); in SdpSendSearchFragmentResponse()
1322 SdpSendErrorResponse(lcid, transactionId, SDP_INVALID_CONT_STAT in SdpSendSearchFragmentResponse()
1346 SdpSendSearchResponse(uint16_t lcid, uint16_t transactionId, uint16_t offset, uint8_t *buffer, uint16_t maxCount) SdpSendSearchResponse() argument
1412 SdpBuildAttributeFragmentResponse( SdpPduId pduId, uint16_t transactionId, size_t size, Packet *fragmentPacket) SdpBuildAttributeFragmentResponse() argument
1466 SdpSendAttributeFragmentResponse( uint16_t lcid, SdpPduId pduId, uint16_t transactionId, uint16_t maxCount, const Packet *attributePacket) SdpSendAttributeFragmentResponse() argument
1521 SdpSendAttributeResponse( uint16_t lcid, uint16_t transactionId, SdpPduId pduId, uint16_t maxCount, const Packet *packet) SdpSendAttributeResponse() argument
1572 SdpSendRequest(uint16_t lcid, uint16_t transactionId, uint8_t continuationStateLen, const uint8_t *continuationState, Packet *packet) SdpSendRequest() argument
[all...]
/foundation/ai/ai_engine/services/server/server_executor/source/
H A Dserver_executor.cpp82 int ServerExecutor::StartEngine(long long transactionId, const AlgorithmInfo &algoInfo, const DataInfo &inputInfo, in StartEngine() argument
88 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 UnRegisterListener(long long transactionId) UnRegisterListener() argument
[all...]
H A Dengine_manager.cpp57 int EngineManager::StartEngine(long long transactionId, const AlgorithmInfo &algoInfo, const DataInfo &inputInfo, in StartEngine() argument
70 HILOGE("[EngineManager][transactionId:%lld]Create engine failed, retCode=[%d].", in StartEngine()
71 transactionId, retCode); in StartEngine()
80 int retCode = plugin->GetPluginAlgorithm()->Prepare(transactionId, inputInfo, outputInfo); in StartEngine()
86 RecordClient(transactionId, engine); in StartEngine()
90 int EngineManager::StopEngine(long long transactionId, const DataInfo &inputInfo) in StopEngine() argument
92 std::shared_ptr<Engine> engine = FindEngine(transactionId); in StopEngine()
106 int retCode = plugin->GetPluginAlgorithm()->Release(isFullUnload, transactionId, inputInfo); in StopEngine()
127 UnRecordClient(transactionId); in StopEngine()
131 int EngineManager::SetOption(long long transactionId, in argument
146 GetOption(long long transactionId, int optionType, const DataInfo &inputInfo, DataInfo &outputInfo) GetOption() argument
162 FindEngine(long long transactionId) FindEngine() argument
173 RecordClient(long long transactionId, const std::shared_ptr<Engine> &engine) RecordClient() argument
179 UnRecordClient(long long transactionId) UnRecordClient() 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()
162 HILOGE("[FutureFactory][transactionId:%lld]No matched future found, seqId=%lld.", in ProcessResponse()
172 HILOGE("[FutureFactory][transactionId:%lld]No matched listener found.", response->GetTransactionId()); in ProcessResponse()
194 IFutureListener *FutureFactory::FindListener(long long transactionId) in FindListener() argument
198 auto findProc = listeners_.find(transactionId); in FindListener()
H A Dfuture.cpp28 Future::Future(IRequest *request, long long sequenceId, long long transactionId) in Future() argument
30 transactionId_(transactionId), in Future()
/foundation/ai/ai_engine/services/common/protocol/data_channel/source/
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()
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()
/foundation/ai/ai_engine/test/sample/include/
H A Dsample_plugin_2.h41 int Prepare(long long transactionId, const DataInfo &inputInfo, DataInfo &outputInfo) override;
43 int Release(bool isFullUnload, long long transactionId, const DataInfo &inputInfo) override;
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;
/foundation/ai/ai_engine/services/server/plugin/
H A Di_plugin.h70 * @param [in] transactionId Transaction ID.
75 virtual int Prepare(long long transactionId, const DataInfo &inputInfo, DataInfo &outputInfo) = 0;
81 * @param [in] transactionId Transaction ID.
85 virtual int Release(bool isFullUnload, long long transactionId, const DataInfo &inputInfo) = 0;
/foundation/ai/ai_engine/services/server/plugin/cv/image_classification/include/
H A Dic_plugin.h44 int32_t Prepare(long long transactionId, const DataInfo &inputInfo, DataInfo &outputInfo) override;
47 int32_t Release(bool isFullUnload, long long transactionId, const DataInfo &inputInfo) override;
/foundation/ai/ai_engine/services/server/plugin/asr/keyword_spotting/include/
H A Dkws_plugin.h51 int32_t Prepare(long long transactionId, const DataInfo &inputInfo, DataInfo &outputInfo) override;
56 int32_t Release(bool isFullUnload, long long transactionId, const DataInfo &inputInfo) override;

Completed in 12 milliseconds

123