lbug 0.16.1

An in-process property graph database management system built for query speed and scalability
Documentation 
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
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66

#include "common/task_system/terminal_progress_bar_display.h"

#include "common/assert.h"

namespace lbug {
namespace common {

void TerminalProgressBarDisplay::updateProgress(uint64_t /*queryID*/, double newPipelineProgress,
    uint32_t newNumPipelinesFinished) {
    DASSERT(0.0 <= newPipelineProgress && newPipelineProgress <= 1.0);

    // There can still be data races as the comparison + update of cur/old progress is not done
    // atomically
    // However this error does not build up over time and we don't require perfect progress bar
    // accuracy
    // So we implement it this way with atomics (instead of mutexes) for better performance
    uint32_t curPipelineProgress = (uint32_t)(newPipelineProgress * 100.0);
    uint32_t oldPipelineProgress = (uint32_t)(pipelineProgress * 100.0);
    if (curPipelineProgress > oldPipelineProgress ||
        newNumPipelinesFinished > numPipelinesFinished) {
        pipelineProgress.store(newPipelineProgress);
        numPipelinesFinished.store(newNumPipelinesFinished);
        printProgressBar();
    }
}

void TerminalProgressBarDisplay::finishProgress(uint64_t /*queryID*/) {
    if (printing) {
        std::cout << "\033[2A\033[2K\033[1B\033[2K\033[1A";
        std::cout.flush();
    }
    printing = false;
    numPipelines = 0;
    numPipelinesFinished = 0;
    pipelineProgress = 0;
}

void TerminalProgressBarDisplay::printProgressBar() {
    // If a different thread is already printing the progress skip the current update
    // As we do not require the displayed value to be perfectly up to date
    bool falseValue{false};
    if (currentlyPrintingProgress.compare_exchange_strong(falseValue, true)) {
        setGreenFont();
        if (printing) {
            if (pipelineProgress == 0) {
                std::cout << "\033[1A\033[2K\033[1A";
                printing = false;
            } else {
                std::cout << "\033[1A";
            }
        }
        if (!printing) {
            std::cout << "Pipelines Finished: " << numPipelinesFinished << "/" << numPipelines
                      << "\n";
            printing = true;
        }
        std::cout << "Current Pipeline Progress: " << uint32_t(pipelineProgress * 100.0) << "%"
                  << "\n";
        setDefaultFont();
        std::cout.flush();
        currentlyPrintingProgress.store(false);
    }
}

} // namespace common
} // namespace lbug