diff options
Diffstat (limited to 'runtimes/neurun/core/include/exec/ExecutionObservers.h')
-rw-r--r-- | runtimes/neurun/core/include/exec/ExecutionObservers.h | 65 |
1 files changed, 65 insertions, 0 deletions
diff --git a/runtimes/neurun/core/include/exec/ExecutionObservers.h b/runtimes/neurun/core/include/exec/ExecutionObservers.h new file mode 100644 index 000000000..61c8bf1b2 --- /dev/null +++ b/runtimes/neurun/core/include/exec/ExecutionObservers.h @@ -0,0 +1,65 @@ +/* + * Copyright (c) 2019 Samsung Electronics Co., Ltd. All Rights Reserved + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +#ifndef __NEURUN_EXEC_OBSREVERS_H__ +#define __NEURUN_EXEC_OBSREVERS_H__ + +#include "exec/IFunction.h" +#include "model/Operation.h" +#include "backend/ExecTime.h" +#include "util/ITimer.h" +#include "IExecutor.h" + +namespace neurun +{ +namespace exec +{ +class IExecutionObserver +{ +public: + /// @brief Invoked just before model (not individual operation) execution begins + virtual void handleBegin(IExecutor *) { return; } + + virtual void handleBegin(IExecutor *, const model::Operation *, const backend::Backend *) = 0; + virtual void handleEnd(IExecutor *, const model::Operation *, const backend::Backend *) = 0; + + /// @brief Invoked just after model (not individual operation) execution ends + virtual void handleEnd(IExecutor *) { return; } + + virtual ~IExecutionObserver() = default; +}; + +class ProfileObserver : public IExecutionObserver +{ +public: + explicit ProfileObserver(std::shared_ptr<backend::ExecTime> et) : _et(std::move(et)) {} + void handleBegin(IExecutor *, const model::Operation *, const backend::Backend *) override; + void handleEnd(IExecutor *, const model::Operation *, const backend::Backend *) override; + + void handleEnd(IExecutor *) override { uploadExecTime(); } + +private: + void uploadExecTime() { _et->uploadOperationsExecTime(); } + +private: + std::unique_ptr<util::ITimer> _timer; + std::shared_ptr<backend::ExecTime> _et; +}; + +} // namespace exec +} // namespace neurun + +#endif // __NEURUN_EXEC_OBSREVERS_H__ |