Method DiskLocalCheckThread

src/Disks/DiskLocalCheckThread.cpp:21–28

static const auto DISK_CHECK_ERROR_RETRY_TIME = 3;

DiskLocalCheckThread::DiskLocalCheckThread(DiskLocal * disk_, ContextPtr context_, UInt64 local_disk_check_period_ms)
    : WithContext(context_)
    , disk(std::move(disk_))
    , check_period_ms(local_disk_check_period_ms)
    , log(getLogger("DiskLocalCheckThread"))
{
    task = getContext()->getSchedulePool().createTask(StorageID::createEmpty(), log->name(), [this] { run(); });
}

void DiskLocalCheckThread::startup()
{