| /ohos5.0/foundation/ai/ai_engine/services/common/protocol/data_channel/source/ |
| H A D | response.cpp | 132 IResponse *IResponse::Create(IRequest *request) in Create()
137 void IResponse::Destroy(IResponse *&response) in Destroy()
142 int IResponse::GetRequestId() const in GetRequestId()
147 long long IResponse::GetTransactionId() const in GetTransactionId()
157 int IResponse::GetRetCode() const in GetRetCode()
162 void IResponse::SetRetCode(int retCode) in SetRetCode()
167 uid_t IResponse::GetClientUid() const in GetClientUid()
177 const std::string &IResponse::GetRetDesc() const in GetRetDesc()
187 const DataInfo &IResponse::GetResult() const in GetResult()
192 void IResponse::SetResult(const DataInfo &result) in SetResult()
[all …]
|
| /ohos5.0/foundation/ai/ai_engine/services/common/protocol/data_channel/include/ |
| H A D | i_response.h | 29 class IResponse {
30 FORBID_COPY_AND_ASSIGN(IResponse);
31 FORBID_CREATE_BY_SELF(IResponse);
38 static IResponse *Create(IRequest *request);
45 static void Destroy(IResponse *&response);
|
| /ohos5.0/foundation/ai/ai_engine/services/server/server_executor/source/ |
| H A D | sync_msg_handler.cpp | 43 IResponse *response = nullptr; in Process()
47 response = IResponse::Create(task.request); in Process()
60 IResponse::Destroy(response); in Process()
76 int SyncMsgHandler::SendRequest(IRequest *request, SimpleEventNotifier<IResponse> ¬ifier) in SendRequest()
96 int SyncMsgHandler::ReceiveResponse(int timeOut, SimpleEventNotifier<IResponse> ¬ifier, in ReceiveResponse()
97 IResponse *&response) in ReceiveResponse()
|
| H A D | future.cpp | 44 IResponse::Destroy(response_); in ~Future()
48 IResponse *Future::GetResponse(int timeOut) const in GetResponse()
84 void Future::SetResponse(FutureStatus status, IResponse *response) in SetResponse()
87 IResponse::Destroy(response_); in SetResponse()
|
| H A D | engine.cpp | 122 int Engine::SyncExecute(IRequest *request, IResponse *&response) in SyncExecute()
140 SimpleEventNotifier<IResponse> notifier(IResponse::Destroy); in SyncExecute()
|
| /ohos5.0/foundation/ai/ai_engine/services/server/communication_adapter/source/ |
| H A D | client_listener_handler.cpp | 45 void AsyncProcessWorker::IpcIoResponse(IResponse *response, IpcIo &io, char *data, int length) in IpcIoResponse()
69 IResponse *response = handler_->FetchCallbackRecord(); in OneAction()
71 ResGuard<IResponse> guard(response); in OneAction()
112 IResponse::Destroy(response); in ~ClientListenerHandler()
116 IResponse *ClientListenerHandler::FetchCallbackRecord() in FetchCallbackRecord()
118 IResponse *response = nullptr; in FetchCallbackRecord()
143 void ClientListenerHandler::AddCallbackRecord(IResponse *response) in AddCallbackRecord()
|
| H A D | future_listener.cpp | 46 IResponse *response = future->GetResponse(0); in OnReply()
|
| H A D | sa_server_adapter.cpp | 235 IResponse *response = nullptr; in SyncExecute()
237 ResGuard<IResponse> guardRes(response); in SyncExecute()
|
| /ohos5.0/foundation/ai/ai_engine/services/server/communication_adapter/include/ |
| H A D | client_listener_handler.h | 45 void IpcIoResponse(IResponse *response, IpcIo &io, char *data, int length);
57 IResponse *FetchCallbackRecord();
64 void AddCallbackRecord(IResponse *response);
83 using ResponseList = std::list<IResponse*>;
|
| H A D | sa_async_handler.h | 41 void PushAsyncResponse(int clientId, IResponse *response);
|
| /ohos5.0/foundation/ai/ai_engine/services/server/server_executor/include/ |
| H A D | sync_msg_handler.h | 59 int SendRequest(IRequest *request, SimpleEventNotifier<IResponse> ¬ifier);
69 … int ReceiveResponse(int timeOut, SimpleEventNotifier<IResponse> ¬ifier, IResponse *&response);
|
| H A D | future.h | 39 IResponse *GetResponse(int timeOut) const override;
64 void SetResponse(FutureStatus status, IResponse *response);
79 IResponse *response_;
|
| H A D | task.h | 30 SimpleEventNotifier<IResponse> *notifier;
44 Task(IHandler *handler, IRequest *request, SimpleEventNotifier<IResponse> *notifier) in Task()
|
| H A D | i_sync_task_manager.h | 35 virtual int SyncExecute(IRequest *request, IResponse *&response) = 0;
|
| H A D | i_future.h | 39 virtual IResponse *GetResponse(int timeOut) const = 0;
|
| H A D | async_msg_handler.h | 50 int OnEvent(PluginEvent event, IResponse *response) override;
|
| H A D | engine.h | 73 int SyncExecute(IRequest *request, IResponse *&response);
|
| /ohos5.0/foundation/ai/ai_engine/services/server/plugin/ |
| H A D | i_plugin_callback.h | 28 class IResponse; variable
41 virtual int OnEvent(PluginEvent event, IResponse *response) = 0;
|
| H A D | i_plugin.h | 56 virtual int SyncProcess(IRequest *request, IResponse *&response) = 0;
|
| /ohos5.0/foundation/ai/ai_engine/test/sample/source/ |
| H A D | sample_plugin_2.cpp | 91 int SamplePlugin2::SyncProcess(IRequest *request, IResponse *&response) in SyncProcess()
105 IResponse *response = IResponse::Create(request); in AsyncProcess()
|
| H A D | sample_plugin_1.cpp | 91 int SamplePlugin1::SyncProcess(IRequest *request, IResponse *&response) in SyncProcess()
99 response = IResponse::Create(request); in SyncProcess()
|
| /ohos5.0/foundation/ai/ai_engine/services/server/plugin/cv/image_classification/include/ |
| H A D | ic_plugin.h | 45 int32_t SyncProcess(IRequest *request, IResponse *&response) override;
53 …int32_t DoProcess(intptr_t handle, const ICPluginConfig &config, IRequest *request, IResponse *&re…
|
| /ohos5.0/foundation/ai/ai_engine/services/server/plugin/cv/image_classification/source/ |
| H A D | ic_plugin.cpp | 274 int32_t ICPlugin::SyncProcess(IRequest *request, IResponse *&response) in SyncProcess()
324 …::DoProcess(intptr_t handle, const ICPluginConfig &config, IRequest *request, IResponse *&response) in DoProcess()
332 response = IResponse::Create(request); in DoProcess()
|
| /ohos5.0/foundation/ai/ai_engine/test/sample/include/ |
| H A D | sample_plugin_1.h | 35 int SyncProcess(IRequest *request, IResponse *&response) override;
|
| H A D | sample_plugin_2.h | 37 int SyncProcess(IRequest *request, IResponse *&response) override;
|