fabian/actsim-cluster-agent
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

fixed task completeness was not checked before upload

Browse source
This commit is contained in:
Fabian Posch 2024-01-09 21:27:39 -05:00
parent e85ce57b82
commit a5a989b359
2 changed files with 8 additions and 7 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
include/actsim_agent/worker.hpp
View file

@ -46,7 +46,7 @@ class Worker {
private: private:
void thread_run(); void thread_run();
void perform_task(std::unique_ptr<Task>& task, bool& success); bool perform_task(std::unique_ptr<Task>& task);
std::unique_ptr<std::thread> worker_thread; std::unique_ptr<std::thread> worker_thread;
std::atomic<db::uuid_t> current_task; std::atomic<db::uuid_t> current_task;

13
src/actsim_agent/worker.cpp
View file

@ -60,17 +60,18 @@ void Worker::thread_run() {
if (queue_empty) continue; if (queue_empty) continue;
// everything is good, perform the given task // everything is good, perform the given task
bool success; bool complete = this->perform_task(task);
this->perform_task(task, success);
// if everything worked, push the task to be uploaded // if the task was finished, push the task to be uploaded
this->interface.push_finished(std::move(task)); // we need this since the task might have been interrupted
// half way though
if (complete) this->interface.push_finished(std::move(task));
} }
} }
void Worker::perform_task(std::unique_ptr<Task>& task, bool& success) { bool Worker::perform_task(std::unique_ptr<Task>& task) {
std::cout << "Worker ping" << std::endl; std::cout << "Worker ping" << std::endl;
usleep(100000); usleep(100000);
success = true;
task->get_uuid(); task->get_uuid();
return true;
} }