| /foundation/ai/ai_engine/services/server/communication_adapter/source/ |
| D | sa_server.c | 96 static int UnParcelAlgorithmInfo(IpcIo *request, AlgorithmInfo *algorithmInfo) in UnParcelAlgorithmInfo() argument 102 if (algorithmInfo == NULL) { in UnParcelAlgorithmInfo() 106 ReadInt64(request, &(algorithmInfo->clientVersion)); in UnParcelAlgorithmInfo() 107 ReadBool(request, &(algorithmInfo->isAsync)); in UnParcelAlgorithmInfo() 108 ReadInt32(request, &(algorithmInfo->algorithmType)); in UnParcelAlgorithmInfo() 109 ReadInt64(request, &(algorithmInfo->algorithmVersion)); in UnParcelAlgorithmInfo() 110 ReadBool(request, &(algorithmInfo->isCloud)); in UnParcelAlgorithmInfo() 111 ReadInt32(request, &(algorithmInfo->operateId)); in UnParcelAlgorithmInfo() 112 ReadInt32(request, &(algorithmInfo->requestId)); in UnParcelAlgorithmInfo() 117 algorithmInfo->extendLen = dataInfo.length; in UnParcelAlgorithmInfo() [all …]
|
| /foundation/ai/ai_engine/services/client/client_executor/include/ |
| D | client_factory.h | 47 const AlgorithmInfo &algorithmInfo, IServiceDeadCb *cb); 60 int ClientPrepare(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, 104 int ClientAsyncProcess(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, 116 int ClientSyncProcess(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, 129 int ClientRelease(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, 141 bool AddSessionInfo(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo); 150 const AlgorithmInfo &algorithmInfo) = 0; 152 virtual int LoadAlgorithm(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, 154 virtual int AsyncExecute(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, 156 virtual int SyncExecute(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, [all …]
|
| D | i_aie_client.inl | 31 const AlgorithmInfo &algorithmInfo, IServiceDeadCb *cb) argument 36 return client->ClientInit(configInfo, clientInfo, algorithmInfo, cb); 39 inline int AieClientPrepare(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, argument 45 return client->ClientPrepare(clientInfo, algorithmInfo, inputInfo, outputInfo, cb); 48 inline int AieClientAsyncProcess(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, argument 54 return client->ClientAsyncProcess(clientInfo, algorithmInfo, inputInfo); 82 inline int AieClientRelease(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, argument 88 return client->ClientRelease(clientInfo, algorithmInfo, inputInfo); 91 inline int AieClientSyncProcess(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, argument 97 return client->ClientSyncProcess(clientInfo, algorithmInfo, inputInfo, outputInfo);
|
| /foundation/ai/ai_engine/services/client/client_executor/source/ |
| D | client_factory.cpp | 44 const AlgorithmInfo &algorithmInfo, IServiceDeadCb *cb) in ClientInit() argument 54 bool isFirstSession = AddSessionInfo(clientInfo, algorithmInfo); in ClientInit() 57 retCode = InitAiServer(configInfo, clientInfo, algorithmInfo); in ClientInit() 73 int ClientFactory::ClientPrepare(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, in ClientPrepare() argument 84 if (algorithmInfo.isAsync) { in ClientPrepare() 98 retCode = LoadAlgorithm(clientInfo, algorithmInfo, inputInfo, outputInfo); in ClientPrepare() 107 …ClientFactory::ClientAsyncProcess(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, in ClientAsyncProcess() argument 116 if (!algorithmInfo.isAsync) { in ClientAsyncProcess() 121 int retCode = AsyncExecute(clientInfo, algorithmInfo, inputInfo); in ClientAsyncProcess() 175 … ClientFactory::ClientSyncProcess(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, in ClientSyncProcess() argument [all …]
|
| /foundation/ai/ai_engine/services/client/communication_adapter/source/ |
| D | sa_client_adapter.cpp | 125 const AlgorithmInfo &algorithmInfo) in InitAiServer() argument 168 int SaClientAdapter::LoadAlgorithm(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, in LoadAlgorithm() argument 176 if (algorithmInfo.isAsync && saAsyncHandler->GetAsyncCbSize() == 1) { in LoadAlgorithm() 183 return saClient->LoadAlgorithm(clientInfo, algorithmInfo, inputInfo, outputInfo); in LoadAlgorithm() 186 … SaClientAdapter::UnLoadAlgorithm(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, in UnLoadAlgorithm() argument 194 if (algorithmInfo.isAsync && saAsyncHandler->IsCallbackEmpty()) { in UnLoadAlgorithm() 202 return client->UnloadAlgorithm(clientInfo, algorithmInfo, inputInfo); in UnLoadAlgorithm() 205 int SaClientAdapter::SyncExecute(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, in SyncExecute() argument 212 return client->SyncExecuteAlgorithm(clientInfo, algorithmInfo, inputInfo, outputInfo); in SyncExecute() 215 int SaClientAdapter::AsyncExecute(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, in AsyncExecute() argument [all …]
|
| D | sa_client.cpp | 141 int SaClient::LoadAlgorithm(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, in LoadAlgorithm() argument 148 return LoadAlgorithmProxy(*proxy_, clientInfo, algorithmInfo, inputInfo, outputInfo); in LoadAlgorithm() 151 int SaClient::SyncExecuteAlgorithm(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, in SyncExecuteAlgorithm() argument 158 return SyncExecAlgorithmProxy(*proxy_, clientInfo, algorithmInfo, inputInfo, outputInfo); in SyncExecuteAlgorithm() 161 …t SaClient::AsyncExecuteAlgorithm(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, in AsyncExecuteAlgorithm() argument 169 return AsyncExecuteAlgorithmProxy(*proxy_, clientInfo, algorithmInfo, inputInfo); in AsyncExecuteAlgorithm() 172 int SaClient::UnloadAlgorithm(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, in UnloadAlgorithm() argument 180 return UnloadAlgorithmProxy(*proxy_, clientInfo, algorithmInfo, inputInfo); in UnloadAlgorithm()
|
| D | sa_client_proxy.cpp | 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, algorithmInfo.isAsync); in ParcelAlgorithmInfo() 103 WriteInt32(request, algorithmInfo.algorithmType); in ParcelAlgorithmInfo() 104 WriteInt64(request, algorithmInfo.algorithmVersion); in ParcelAlgorithmInfo() 105 WriteBool(request, algorithmInfo.isCloud); in ParcelAlgorithmInfo() 106 WriteInt32(request, algorithmInfo.operateId); in ParcelAlgorithmInfo() 107 WriteInt32(request, algorithmInfo.requestId); in ParcelAlgorithmInfo() 109 DataInfo dataInfo {algorithmInfo.extendMsg, algorithmInfo.extendLen}; in ParcelAlgorithmInfo()
|
| /foundation/ai/ai_engine/services/client/communication_adapter/include/ |
| D | sa_client_adapter.h | 64 const AlgorithmInfo &algorithmInfo) override; 82 int LoadAlgorithm(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, 95 int UnLoadAlgorithm(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, 107 int SyncExecute(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, 121 int AsyncExecute(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo,
|
| D | sa_client.h | 92 int LoadAlgorithm(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, 103 int UnloadAlgorithm(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, 115 int SyncExecuteAlgorithm(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo, 129 int AsyncExecuteAlgorithm(const ClientInfo &clientInfo, const AlgorithmInfo &algorithmInfo,
|
| /foundation/ai/ai_engine/test/function/share_memory/ |
| D | share_memory_test.cpp | 51 void FreeAlgorithmInfo(AlgorithmInfo *algorithmInfo) in FreeAlgorithmInfo() argument 53 if (algorithmInfo != nullptr && algorithmInfo->extendMsg != nullptr) { in FreeAlgorithmInfo() 54 free(algorithmInfo->extendMsg); in FreeAlgorithmInfo() 55 algorithmInfo->extendMsg = nullptr; in FreeAlgorithmInfo() 56 algorithmInfo->extendLen = 0; in FreeAlgorithmInfo()
|