/foundation/ai/ai_engine/services/server/server_executor/source/ |
H A D | server_executor.cpp | 29 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 32 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 36 CHK_RET(tempInstance == nullptr, nullptr); in GetInstance() 85 CHK_RET(engineMgr_ == nullptr, RETCODE_ENGINE_MANAGER_NOT_INIT); in StartEngine() 93 CHK_RET(engineMgr_ == nullptr, RETCODE_ENGINE_MANAGER_NOT_INIT); in StopEngine() 101 CHK_RET(engineMgr_ == nullptr, RETCODE_ENGINE_MANAGER_NOT_INIT); in SetOption() 110 CHK_RET(engineMgr_ == nullptr, RETCODE_ENGINE_MANAGER_NOT_INIT); in GetOption() 118 CHK_RET(engineMgr_ == nullptr, RETCODE_ENGINE_MANAGER_NOT_INIT); in SyncExecute() 119 CHK_RET(request == nullptr, RETCODE_NULL_PARAM); in SyncExecute() 123 CHK_RET(engin in SyncExecute() [all...] |
H A D | future_factory.cpp | 39 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 42 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 109 CHK_RET(future == nullptr, RETCODE_OUT_OF_MEMORY); in CreateFuture() 157 CHK_RET(response == nullptr, RETCODE_NULL_PARAM); in ProcessResponse() 189 CHK_RET(findProc == futures_.end(), nullptr); in FetchFuture() 199 CHK_RET(findProc == listeners_.end(), nullptr); in FindListener()
|
H A D | async_msg_handler.cpp | 57 CHK_RET(futureFactory == nullptr, RETCODE_NULL_PARAM); in OnEvent() 84 CHK_RET(futureFactory == nullptr, RETCODE_NULL_PARAM); in SendRequest()
|
H A D | sync_msg_handler.cpp | 35 CHK_RET(pluginAlgorithm_ == nullptr, RETCODE_PLUGIN_LOAD_FAILED); in Process() 48 CHK_RET(response == nullptr, RETCODE_OUT_OF_MEMORY); in Process()
|
H A D | engine_worker.cpp | 54 CHK_RET(queue_.IsEmpty(), true); in OneAction()
|
H A D | engine_manager.cpp | 202 CHK_RET(threadPool == nullptr, RETCODE_OUT_OF_MEMORY); in CreateEngine() 210 CHK_RET(queuePool == nullptr, RETCODE_OUT_OF_MEMORY); in CreateEngine()
|
/foundation/ai/ai_engine/services/client/communication_adapter/source/ |
H A D | sa_client_adapter.cpp | 111 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 113 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 129 CHK_RET(threadPool == nullptr, RETCODE_OUT_OF_MEMORY); in InitAiServer() 132 CHK_RET(connectMgrThread_ == nullptr, RETCODE_OUT_OF_MEMORY); in InitAiServer() 161 CHK_RET(threadPool == nullptr, RETCODE_OUT_OF_MEMORY); in CloseAiServer() 173 CHK_RET(saClient == nullptr, RETCODE_NULL_PARAM); in LoadAlgorithm() 175 CHK_RET(saAsyncHandler == nullptr, RETCODE_OUT_OF_MEMORY); in LoadAlgorithm() 191 CHK_RET(client == nullptr, RETCODE_NULL_PARAM); in UnLoadAlgorithm() 193 CHK_RET(saAsyncHandler == nullptr, RETCODE_NULL_PARAM); in UnLoadAlgorithm() 210 CHK_RET(clien in SyncExecute() [all...] |
H A D | sa_async_handler.cpp | 65 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 67 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 81 CHK_RET(saClient == nullptr, RETCODE_NULL_PARAM); in RegisterAsyncClientCb() 89 CHK_RET(saClient == nullptr, RETCODE_NULL_PARAM); in UnRegisterAsyncClientCb() 97 CHK_RET(saClient == nullptr, RETCODE_NULL_PARAM); in RegisterServiceDeathCb() 105 CHK_RET(saClient == nullptr, RETCODE_NULL_PARAM); in UnRegisterServiceDeathCb()
|
H A D | sa_client.cpp | 95 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 98 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 102 CHK_RET(tempInstance == nullptr, nullptr); in GetInstance()
|
/foundation/ai/ai_engine/services/common/utils/ |
H A D | inf_cast_impl.h | 35 CHK_RET(p == nullptr, nullptr); in Create() 49 CHK_RET(p == nullptr, nullptr); in Create() 64 CHK_RET(p == nullptr, nullptr); in Create() 80 CHK_RET(p == nullptr, nullptr); in Create() 97 CHK_RET(p == nullptr, nullptr); in Create()
|
H A D | aie_macros.h | 27 #define CHK_RET(x, ret) \ macro
|
/foundation/ai/ai_engine/services/common/utils/encdec/source/ |
H A D | data_encoder.cpp | 33 CHK_RET((memBlock == nullptr), nullptr); in AllocateMemBlock() 61 CHK_RET(buffer_ == nullptr, RETCODE_OUT_OF_MEMORY); in Init() 68 CHK_RET(EncodeOneParameter(pos_) != RETCODE_SUCCESS, RETCODE_FAILURE); in GetSerializedData() 69 CHK_RET(buffer_ == nullptr || pos_ == 0, RETCODE_FAILURE); in GetSerializedData() 104 CHK_RET(!allocSuccess_, false); in ReallocBuffer()
|
/foundation/ai/ai_engine/services/common/platform/threadpool/source/ |
H A D | thread_pool.cpp | 28 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 31 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 73 CHK_RET(ptr == nullptr, nullptr); in Pop() 121 CHK_RET(static_cast<int32_t>(elapser.ElapseMilli()) > timeOut, false); in StopThreads() 130 CHK_RET(thread->IsHung(now), false); in StopThreads()
|
H A D | thread.cpp | 37 CHK_RET(thread_ == nullptr, RETCODE_FAILURE); in GetThreadId()
|
/foundation/ai/ai_engine/services/server/plugin_manager/source/ |
H A D | plugin_label.cpp | 33 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 36 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 40 CHK_RET(temp == nullptr, nullptr); in GetInstance()
|
H A D | plugin_manager.cpp | 48 CHK_RET(pluginMap_.end() == iter, nullptr); in FindPlugin() 118 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 121 CHK_RET(instance_ != nullptr, instance_); in GetInstance()
|
H A D | aie_plugin_info.cpp | 23 CHK_RET(type >= algorithmTypeNum || type < 0, ALGORITHM_ID_INVALID); in GetAlgorithmIdByType()
|
/foundation/ai/ai_engine/services/server/communication_adapter/source/ |
H A D | client_listener_handler.cpp | 70 CHK_RET(response == nullptr, true); in OneAction() 157 CHK_RET(threadPool == nullptr, RETCODE_OUT_OF_MEMORY); in StartAsyncProcessThread() 159 CHK_RET(asyncProcessThread_ != nullptr, RETCODE_ASYNC_CB_STARTED); in StartAsyncProcessThread() 160 CHK_RET(asyncProcessWorker_ != nullptr, RETCODE_ASYNC_CB_STARTED); in StartAsyncProcessThread() 163 CHK_RET(asyncProcessThread_ == nullptr, RETCODE_OUT_OF_MEMORY); in StartAsyncProcessThread()
|
H A D | sa_async_handler.cpp | 31 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 34 CHK_RET(instance_ != nullptr, instance_); in GetInstance() 73 CHK_RET(iter == clients_.end(), nullptr); in FindClientListenerHandler() 82 CHK_RET(handler == nullptr, nullptr); in AddClientListenerHandler() 150 CHK_RET(IsExistTransaction(transactionId), RETCODE_SUCCESS); in StartAsyncTransaction()
|
H A D | adapter_wrapper.cpp | 189 CHK_RET(saAsyncHandler == nullptr, RETCODE_NULL_PARAM); in LoadAlgoWrapper() 281 CHK_RET(saAsyncHandler == nullptr, RETCODE_NULL_PARAM); in RegisterCallbackWrapper() 303 CHK_RET(saAsyncHandler == nullptr, RETCODE_NULL_PARAM); in UnregisterCallbackWrapper()
|
/foundation/ai/ai_engine/services/client/client_executor/source/ |
H A D | client_factory.cpp | 65 CHK_RET(retCode != RETCODE_SUCCESS, retCode); in ClientInit() 275 CHK_RET(iter == sessionInfos_.end(), RETCODE_EMPTY_MAP); in GetSessionInfo() 284 CHK_RET(saAsyncHandler == nullptr, RETCODE_NULL_PARAM); in RegisterCb() 286 CHK_RET(retCode != RETCODE_SUCCESS, retCode); in RegisterCb() 300 CHK_RET(saAsyncHandler == nullptr, RETCODE_NULL_PARAM); in UnRegisterCb() 313 CHK_RET(saAsyncHandler == nullptr, RETCODE_NULL_PARAM); in RegisterDeadCb() 315 CHK_RET(retCode != RETCODE_SUCCESS, retCode); in RegisterDeadCb() 329 CHK_RET(saAsyncHandler == nullptr, RETCODE_NULL_PARAM); in UnRegisterDeadCb()
|
/foundation/ai/ai_engine/test/sample/source/ |
H A D | sample_plugin_2.cpp | 106 CHK_RET(response == nullptr, RETCODE_FAILURE); in AsyncProcess()
|
H A D | sample_plugin_1.cpp | 100 CHK_RET(response == nullptr, RETCODE_FAILURE); in SyncProcess()
|