searchcore/src/vespa/searchcore/proton/metrics/job_tracked_flush_task.cpp


1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25

// Copyright Vespa.ai. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.

#include "job_tracked_flush_task.h"

using searchcorespi::FlushTask;

namespace proton {

JobTrackedFlushTask::JobTrackedFlushTask(std::shared_ptr<IJobTracker> tracker, FlushTask::UP task)
    : _tracker(std::move(tracker)),
      _task(std::move(task))
{
}

JobTrackedFlushTask::~JobTrackedFlushTask() = default;

void
JobTrackedFlushTask::run()
{
    _tracker->start();
    _task->run();
    _tracker->end();
}

}