cif::ProgressImpl Struct Reference

Public Member Functions
	ProgressImpl (int64_t inMax, const std::string &inAction)
void	Run ()
void	Stop ()
void	PrintProgress ()
void	PrintDone ()

Public Attributes
int64_t	mMax
std::atomic< int64_t >	mConsumed
int64_t	mLastConsumed = 0
int	mSpinnerIndex = 0
std::string	mAction
std::string	mMessage
std::mutex	mMutex
std::thread	mThread
std::chrono::time_point< std::chrono::system_clock >	mStart = std::chrono::system_clock::now()
bool	mStop = false

Detailed Description

Definition at line 138 of file utilities.cpp.

Constructor & Destructor Documentation

ProgressImpl()

cif::ProgressImpl::ProgressImpl ( int64_t  inMax, const std::string &  inAction  )

inline

Definition at line 140 of file utilities.cpp.

        : mMax(inMax)
        , mConsumed(0)
        , mAction(inAction)
        , mMessage(inAction)
        , mThread(std::bind(&ProgressImpl::Run, this))
    {
    }

Member Function Documentation

PrintDone()

void cif::ProgressImpl::PrintDone

(

)

Definition at line 328 of file utilities.cpp.

{
    std::chrono::duration<double> elapsed = std::chrono::system_clock::now() - mStart;

    std::ostringstream msgstr;
    msgstr << mAction << " done in " << elapsed << " seconds";
    auto msg = msgstr.str();

    uint32_t width = get_terminal_width();

    if (msg.length() < width)
        msg += std::string(width - msg.length(), ' ');

    std::cout << '\r' << msg << std::endl;
}

PrintProgress()

void cif::ProgressImpl::PrintProgress

(

)

Definition at line 206 of file utilities.cpp.

{
    //  const char* kBlocks[] = {
    //      " ",                // 0
    //      u8"\u258F",         // 1
    //      u8"\u258E",         // 2
    //      u8"\u258D",         // 3
    //      u8"\u258C",         // 4
    //      u8"\u258B",         // 5
    //      u8"\u258A",         // 6
    //      u8"\u2589",         // 7
    //      u8"\u2588",         // 8
    //  };

    const char *kBlocks[] = {
        " ", // 0
        " ", // 1
        " ", // 2
        "-", // 3
        "-", // 4
        "-", // 5
        "=", // 6
        "=", // 7
        "=", // 8
    };

    uint32_t width = get_terminal_width();

    std::string msg;
    msg.reserve(width + 1);
    if (mMessage.length() <= 20)
    {
        msg = mMessage;
        if (msg.length() < 20)
            msg.append(20 - msg.length(), ' ');
    }
    else
        msg = mMessage.substr(0, 17) + "...";

    msg += " |";

    int64_t consumed = mConsumed;
    float progress = static_cast<float>(consumed) / mMax;
    int pi = static_cast<int>(std::ceil(progress * 33 * 8));
    //  int tw = width - 28;
    //  int twd = static_cast<int>(tw * progress + 0.5f);
    //  msg.append(twd, '=');
    //  msg.append(tw - twd, ' ');

    for (int i = 0; i < 33; ++i)
    {
        if (pi <= 0)
            msg += kBlocks[0];
        else if (pi >= 8)
            msg += kBlocks[8];
        else
            msg += kBlocks[pi];
        pi -= 8;
    }

    msg.append("| ");

    const char kSpinner[] = {' ', '.', 'o', 'O', '0', 'O', 'o', '.'};
    const size_t kSpinnerCount = sizeof(kSpinner);

    if (mLastConsumed < consumed)
    {
        mLastConsumed = consumed;
        mSpinnerIndex = (mSpinnerIndex + 1) % kSpinnerCount;
    }

    const char spinner[2] = {kSpinner[mSpinnerIndex], 0};
    msg.append(spinner);

    //  int perc = static_cast<int>(100 * progress);
    //  if (perc < 100)
    //      msg += ' ';
    //  if (perc < 10)
    //      msg += ' ';
    //  msg += to_string(perc);
    //  msg += '%';

    std::cout << '\r' << msg;
    std::cout.flush();
}

Run()

void cif::ProgressImpl::Run

(

)

Definition at line 172 of file utilities.cpp.

{
    using namespace std::literals;

    bool printedAny = false;

    try
    {
        for (;;)
        {
            std::this_thread::sleep_for(2s);

            std::unique_lock lock(mMutex);

            if (mStop or mConsumed == mMax)
                break;

            auto elapsed = std::chrono::system_clock::now() - mStart;

            if (elapsed < std::chrono::seconds(5))
                continue;

            PrintProgress();
            printedAny = true;
        }
    }
    catch (...)
    {
    }

    if (printedAny)
        PrintDone();
}

Stop()

void cif::ProgressImpl::Stop ( )

inline

Definition at line 150 of file utilities.cpp.

    {
        mStop = true;
        if (mThread.joinable())
            mThread.join();
    }

Member Data Documentation

mAction

std::string cif::ProgressImpl::mAction

Definition at line 164 of file utilities.cpp.

mConsumed

std::atomic<int64_t> cif::ProgressImpl::mConsumed

Definition at line 161 of file utilities.cpp.

mLastConsumed

int64_t cif::ProgressImpl::mLastConsumed = 0

Definition at line 162 of file utilities.cpp.

mMax

int64_t cif::ProgressImpl::mMax

Definition at line 160 of file utilities.cpp.

mMessage

std::string cif::ProgressImpl::mMessage

Definition at line 164 of file utilities.cpp.

mMutex

std::mutex cif::ProgressImpl::mMutex

Definition at line 165 of file utilities.cpp.

mSpinnerIndex

int cif::ProgressImpl::mSpinnerIndex = 0

Definition at line 163 of file utilities.cpp.

mStart

std::chrono::time_point<std::chrono::system_clock> cif::ProgressImpl::mStart = std::chrono::system_clock::now()

Definition at line 168 of file utilities.cpp.

mStop

bool cif::ProgressImpl::mStop = false

Definition at line 169 of file utilities.cpp.

mThread

std::thread cif::ProgressImpl::mThread

Definition at line 166 of file utilities.cpp.

---

The documentation for this struct was generated from the following file:

• libcifpp/src/utilities.cpp