testRsyncAsyncProcess.cpp

Go to the documentation of this file.

/**
 * @file
 * @ingroup daq_test
 * @copyright (c) Copyright ESO 2022
 * All Rights Reserved
 * ESO (eso.org) is an Intergovernmental Organisation, and therefore special legal conditions apply.
 *
 * @brief daq::ParseRsyncProgress
 *
 */
#include <thread>
 
#include <gtest/gtest.h>
 
#include <daq/process/rsyncAsyncProcess.hpp>
 
using namespace std::chrono_literals;
using daq::ParseRsyncProgress;
 
TEST(TestParseRsyncProgress, Invalid) {
    EXPECT_FALSE(ParseRsyncProgress(""));
    EXPECT_FALSE(ParseRsyncProgress("a"));
    EXPECT_FALSE(ParseRsyncProgress("120"));
    EXPECT_FALSE(ParseRsyncProgress("120 1 z :::"));
    EXPECT_FALSE(ParseRsyncProgress("a b c d"));
    EXPECT_FALSE(ParseRsyncProgress("  0   0%    0.00aB/s    0:00:00"))
        << "aB/s should not be accepted";
    EXPECT_FALSE(ParseRsyncProgress("  0   0%    0.00aaaaa    0:00:00"))
        << "bad unit should not be accepted";
    EXPECT_FALSE(ParseRsyncProgress("  0   0%    0,00kB/s    0:00:00"))
        << "Comma separated speed should not be accepted";
    EXPECT_FALSE(ParseRsyncProgress("  0   0%    0,00kB/s    0;00;00"))
        << "Semi-colon separated time should not be accepted";
    EXPECT_FALSE(ParseRsyncProgress("  0   0%    0,00kB/s    0.00.00"))
        << "Period separated time should not be accepted";
}
 
TEST(TestParseRsyncProgress, Initial) {
    auto p = ParseRsyncProgress("  0   0%    0.00kB/s    0:00:00");
    EXPECT_EQ(p->transferred, 0u);
    EXPECT_NEAR(p->progress, 0.f, 0.01);
    EXPECT_NEAR(p->speed, 0.f, 0.01);
    EXPECT_EQ(p->remaining, 0s);
}
 
TEST(TestParseRsyncProgress, Mid1) {
    auto p = ParseRsyncProgress("      361234432  33%  344.50MB/s    0:00:02");
    EXPECT_EQ(p->transferred, 361'234'432u);
    EXPECT_NEAR(p->progress, 0.33f, 0.01);
    EXPECT_NEAR(p->speed, 344.5 * 1024 * 1024, 0.01);
    EXPECT_EQ(p->remaining, 2s);
}
 
TEST(TestParseRsyncProgress, Mid2) {
    auto p = ParseRsyncProgress("6881280   0%  200.09kB/s    1:28:51");
    EXPECT_EQ(p->transferred, 6'881'280u);
    EXPECT_NEAR(p->progress, 0.0f, 0.01);
    EXPECT_NEAR(p->speed, 200.09 * 1024, 0.01);
    EXPECT_EQ(p->remaining, 1h + 28min + 51s);
}
 
TEST(TestParseRsyncProgress, Final) {
    auto p = ParseRsyncProgress("      200000  100%  344.50MB/s    0:00:00 (xfr#1 to-chk=0/1)");
    EXPECT_EQ(p->transferred, 200'000u);
    EXPECT_NEAR(p->progress, 1.f, 0.01);
    EXPECT_NEAR(p->speed, 344.5 * 1024.0f * 1024.0f, 0.01);
    EXPECT_EQ(p->remaining, 0s);
}