diff --git a/tasks/seq/broken_example_disabled/data/test.txt b/tasks/seq/broken_example_disabled/data/test.txt deleted file mode 100644 index 105d7d9ad..000000000 --- a/tasks/seq/broken_example_disabled/data/test.txt +++ /dev/null @@ -1 +0,0 @@ -100 \ No newline at end of file diff --git a/tasks/seq/broken_example_disabled/func_tests/main.cpp b/tasks/seq/broken_example_disabled/func_tests/main.cpp deleted file mode 100644 index 54ddb2c42..000000000 --- a/tasks/seq/broken_example_disabled/func_tests/main.cpp +++ /dev/null @@ -1,73 +0,0 @@ -#include - -#include -#include -#include -#include -#include -#include - -#include "core/task/include/task.hpp" -#include "core/util/include/util.hpp" -#include "seq/example/include/ops_seq.hpp" - -TEST(nesterov_a_test_task_seq, test_matmul_50) { - constexpr size_t kCount = 50; - - // Create data - std::vector in(kCount * kCount, 0); - std::vector out(kCount * kCount, 0); - - for (size_t i = 0; i < kCount; i++) { - in[(i * kCount) + i] = 1; - } - - // Create task_data - auto task_data_seq = std::make_shared(); - task_data_seq->inputs.emplace_back(reinterpret_cast(in.data())); - task_data_seq->inputs_count.emplace_back(in.size()); - task_data_seq->outputs.emplace_back(reinterpret_cast(out.data())); - task_data_seq->outputs_count.emplace_back(out.size()); - - // Create Task - nesterov_a_test_task_seq::TestTaskSequential test_task_sequential(task_data_seq); - ASSERT_EQ(test_task_sequential.Validation(), true); - test_task_sequential.PreProcessing(); - test_task_sequential.Run(); - test_task_sequential.PostProcessing(); - EXPECT_EQ(in, out); -} - -TEST(nesterov_a_test_task_seq, test_matmul_100_from_file) { - std::string line; - std::ifstream test_file(ppc::util::GetAbsolutePath("seq/example/data/test.txt")); - if (test_file.is_open()) { - getline(test_file, line); - } - test_file.close(); - - const size_t count = std::stoi(line); - - // Create data - std::vector in(count * count, 0); - std::vector out(count * count, 0); - - for (size_t i = 0; i < count; i++) { - in[(i * count) + i] = 1; - } - - // Create task_data - auto task_data_seq = std::make_shared(); - task_data_seq->inputs.emplace_back(reinterpret_cast(in.data())); - task_data_seq->inputs_count.emplace_back(in.size()); - task_data_seq->outputs.emplace_back(reinterpret_cast(out.data())); - task_data_seq->outputs_count.emplace_back(out.size()); - - // Create Task - nesterov_a_test_task_seq::TestTaskSequential test_task_sequential(task_data_seq); - ASSERT_EQ(test_task_sequential.Validation(), true); - test_task_sequential.PreProcessing(); - test_task_sequential.Run(); - test_task_sequential.PostProcessing(); - EXPECT_EQ(in, out); -} diff --git a/tasks/seq/broken_example_disabled/include/ops_seq.hpp b/tasks/seq/broken_example_disabled/include/ops_seq.hpp deleted file mode 100644 index 728bde58d..000000000 --- a/tasks/seq/broken_example_disabled/include/ops_seq.hpp +++ /dev/null @@ -1,23 +0,0 @@ -#pragma once - -#include -#include - -#include "core/task/include/task.hpp" - -namespace nesterov_a_test_task_seq { - -class TestTaskSequential : public ppc::core::Task { - public: - explicit TestTaskSequential(ppc::core::TaskDataPtr task_data) : Task(std::move(task_data)) {} - bool PreProcessingImpl() override; - bool ValidationImpl() override; - bool RunImpl() override; - bool PostProcessingImpl() override; - - private: - std::vector input_, output_; - int rc_size_{}; -}; - -} // namespace nesterov_a_test_task_seq \ No newline at end of file diff --git a/tasks/seq/broken_example_disabled/perf_tests/main.cpp b/tasks/seq/broken_example_disabled/perf_tests/main.cpp deleted file mode 100644 index 3dfe18048..000000000 --- a/tasks/seq/broken_example_disabled/perf_tests/main.cpp +++ /dev/null @@ -1,93 +0,0 @@ -#include - -#include -#include -#include -#include -#include - -#include "core/perf/include/perf.hpp" -#include "core/task/include/task.hpp" -#include "seq/example/include/ops_seq.hpp" - -TEST(nesterov_a_test_task_seq, test_pipeline_run) { - constexpr int kCount = 500; - - // Create data - std::vector in(kCount * kCount, 0); - std::vector out(kCount * kCount, 0); - - for (size_t i = 0; i < kCount; i++) { - in[(i * kCount) + i] = 1; - } - - // Create task_data - auto task_data_seq = std::make_shared(); - task_data_seq->inputs.emplace_back(reinterpret_cast(in.data())); - task_data_seq->inputs_count.emplace_back(in.size()); - task_data_seq->outputs.emplace_back(reinterpret_cast(out.data())); - task_data_seq->outputs_count.emplace_back(out.size()); - - // Create Task - auto test_task_sequential = std::make_shared(task_data_seq); - - // Create Perf attributes - auto perf_attr = std::make_shared(); - perf_attr->num_running = 10; - const auto t0 = std::chrono::high_resolution_clock::now(); - perf_attr->current_timer = [&] { - auto current_time_point = std::chrono::high_resolution_clock::now(); - auto duration = std::chrono::duration_cast(current_time_point - t0).count(); - return static_cast(duration) * 1e-9; - }; - - // Create and init perf results - auto perf_results = std::make_shared(); - - // Create Perf analyzer - auto perf_analyzer = std::make_shared(test_task_sequential); - perf_analyzer->PipelineRun(perf_attr, perf_results); - ppc::core::Perf::PrintPerfStatistic(perf_results); - ASSERT_EQ(in, out); -} - -TEST(nesterov_a_test_task_seq, test_task_run) { - constexpr int kCount = 500; - - // Create data - std::vector in(kCount * kCount, 0); - std::vector out(kCount * kCount, 0); - - for (size_t i = 0; i < kCount; i++) { - in[(i * kCount) + i] = 1; - } - - // Create task_data - auto task_data_seq = std::make_shared(); - task_data_seq->inputs.emplace_back(reinterpret_cast(in.data())); - task_data_seq->inputs_count.emplace_back(in.size()); - task_data_seq->outputs.emplace_back(reinterpret_cast(out.data())); - task_data_seq->outputs_count.emplace_back(out.size()); - - // Create Task - auto test_task_sequential = std::make_shared(task_data_seq); - - // Create Perf attributes - auto perf_attr = std::make_shared(); - perf_attr->num_running = 10; - const auto t0 = std::chrono::high_resolution_clock::now(); - perf_attr->current_timer = [&] { - auto current_time_point = std::chrono::high_resolution_clock::now(); - auto duration = std::chrono::duration_cast(current_time_point - t0).count(); - return static_cast(duration) * 1e-9; - }; - - // Create and init perf results - auto perf_results = std::make_shared(); - - // Create Perf analyzer - auto perf_analyzer = std::make_shared(test_task_sequential); - perf_analyzer->TaskRun(perf_attr, perf_results); - ppc::core::Perf::PrintPerfStatistic(perf_results); - ASSERT_EQ(in, out); -} diff --git a/tasks/seq/broken_example_disabled/src/ops_seq.cpp b/tasks/seq/broken_example_disabled/src/ops_seq.cpp deleted file mode 100644 index 23639db05..000000000 --- a/tasks/seq/broken_example_disabled/src/ops_seq.cpp +++ /dev/null @@ -1,42 +0,0 @@ -#include "seq/example/include/ops_seq.hpp" - -#include -#include -#include - -bool nesterov_a_test_task_seq::TestTaskSequential::PreProcessingImpl() { - // Init value for input and output - unsigned int input_size = task_data->inputs_count[0]; - auto *in_ptr = reinterpret_cast(task_data->inputs[0]); - input_ = std::vector(in_ptr, in_ptr + input_size); - - unsigned int output_size = task_data->outputs_count[0]; - output_ = std::vector(output_size, 0); - - rc_size_ = static_cast(std::sqrt(input_size)); - return true; -} - -bool nesterov_a_test_task_seq::TestTaskSequential::ValidationImpl() { - // Check equality of counts elements - return task_data->inputs_count[0] == task_data->outputs_count[0]; -} - -bool nesterov_a_test_task_seq::TestTaskSequential::RunImpl() { - // Multiply matrices - for (int i = 0; i < rc_size_; ++i) { - for (int j = 0; j < rc_size_; ++j) { - for (int k = 0; k < rc_size_; ++k) { - output_[(i * rc_size_) + j] += input_[(i * rc_size_) + k] * input_[(k * rc_size_) + j]; - } - } - } - return true; -} - -bool nesterov_a_test_task_seq::TestTaskSequential::PostProcessingImpl() { - for (size_t i = 0; i < output_.size(); i++) { - reinterpret_cast(task_data->outputs[0])[i] = output_[i]; - } - return true; -}