scan_worker.cpp

Go to the documentation of this file.

#include "scan_worker.hpp"
#include "scanner_engine.hpp"
 
#include <iostream>
 
ScanWorker::ScanWorker() = default;
 
ScanWorker::~ScanWorker()
{
    request_cancel();
    join();
}
 
void ScanWorker::start(const std::string& path,
                       CompletionCallback cb,
                       ProgressCallback progress_cb)
{
    if (running_)
        return;
 
    cancel_requested_ = false;
    running_ = true;
 
    thread_ = std::thread([this, path, cb, progress_cb]()
    {
        ScanReport report;
 
        try
        {
            ScannerEngine engine;
 
            report = engine.run_scan(
                path,
                [this, progress_cb](const ScanProgress& p)
                {
                    if (cancel_requested_)
                        return;
 
                    if (progress_cb)
                        progress_cb(p);
                },
                [this]()
                {
                    return cancel_requested_.load();
                }
            );
        }
        catch (const std::exception& e)
        {
            report.logs.push_back(
                std::string("ScanWorker exception: ") + e.what());
        }
        catch (...)
        {
            report.logs.push_back("ScanWorker unknown exception");
        }
 
        running_ = false;
 
        if (!cancel_requested_ && cb)
            cb(report);
    });
}
 
bool ScanWorker::running() const
{
    return running_;
}
 
void ScanWorker::join()
{
    if (thread_.joinable())
        thread_.join();
}
 
void ScanWorker::request_cancel()
{
    cancel_requested_ = true;
}
 
bool ScanWorker::cancel_requested() const
{
    return cancel_requested_;
}