snooze_pos.cpp

Go to the documentation of this file.

/*****************************************************************************
** Platform Check
*****************************************************************************/

#include <ecl/config.hpp>
#if defined(ECL_IS_POSIX)

/*****************************************************************************
** Includes
*****************************************************************************/

#include <ecl/time_lite/functions.hpp>
#include "../../include/ecl/time/snooze_pos.hpp"

/*****************************************************************************
** Namespaces
*****************************************************************************/

namespace ecl {

/*****************************************************************************
** Implementation [Snooze]
*****************************************************************************/

Snooze::Snooze() {
        period(Duration(0,10000000));
}

Snooze::Snooze(const Duration &time, const bool& validate) { period(time, validate); }

void Snooze::period(const Duration &time, const bool& validate) {
        validate_times = validate;
        time_period.tv_sec = time.sec();
        time_period.tv_nsec = time.nsec();
    wrap_value_ns = 1000000000L-time_period.tv_nsec;
    initialise();
}

void Snooze::initialise() {
        epoch_time(time_value);
}

void Snooze::operator()() {

    add_period();
    validate();
    sleep_until(time_value);
}

void Snooze::add_period() {

        // Nanoseconds
    if ( time_value.tv_nsec > wrap_value_ns ) { // wrap
        time_value.tv_nsec = time_value.tv_nsec - wrap_value_ns;
        time_value.tv_sec += 1;
    } else {
        time_value.tv_nsec += time_period.tv_nsec;
    }
    // Seconds
    time_value.tv_sec += time_period.tv_sec;

    if ( validate_times ) {
        validate();
    }
}

void Snooze::validate() {

        TimeStructure time_current;
    epoch_time(time_current);

    if ( time_current.tv_sec > time_value.tv_sec ) {
        // Revalidate
        time_value.tv_sec = time_current.tv_sec;
        time_value.tv_nsec = time_current.tv_nsec;
        add_period();
    }  else if ( time_current.tv_sec == time_value.tv_sec ) {
        if ( time_current.tv_nsec > time_value.tv_nsec ) {
                // Revalidate
            time_value.tv_sec = time_current.tv_sec;
            time_value.tv_nsec = time_current.tv_nsec;
            add_period();
        }
    }
}

} // namespace ecl

#endif /* ECL_IS_POSIX */