system.hpp

Go to the documentation of this file.

#ifndef IFW_CTD_SYSTEM_HPP_
#define IFW_CTD_SYSTEM_HPP_

#include <string>
#include <sys/sem.h>
#include <pthread.h>

#include "rad/Logger.hpp"

#include "ctd/defines/defines.hpp"


namespace ctd {
namespace system {

void Sleep(const float sleep_time);

double Time();

void SecondsToTimeSpec(const double time,
                       struct timespec& time_spec);

void SecondsToTimeVal(const double time,
                      struct timeval& time_val);

std::string IsoTime(const double time_since_epoch,
                    const uint8_t prec = 6);

std::string IsoTimeNow(const int8_t prec = 6);

void AssertPtr(const void* ptr,
               const std::string& object,
               const std::string& location);

std::string Platform();

std::string GenUniqueId(const std::string& prefix = "");

int64_t Random(const int64_t min_val,
               const int64_t max_val);

//int32_t ExecuteCommand(const std::string& command,
//                       std::string& std_out,
//                       std::string& std_err);

std::string ExecCommand(const std::string& command);

class Mutex {
public:
    static void Clear();

    explicit Mutex(const std::string& id);

    ~Mutex();

    const std::string& Id() const;

    void Lock(bool& timed_out,
              const double timeout = ctd::defines::NO_TIMEOUT);

    void Unlock();

  protected:

  private:
    static bool s_initialized;
    static bool s_debug_mode;
    static pthread_mutex_t s_gen_mutex;
    static void _take_gen_mutex();
    static void _release_gen_mutex();

    static std::map<std::string, std::shared_ptr<pthread_mutex_t> > s_mutexes;

    pthread_mutex_t* m_sem_ptr;
    std::string m_id;
    double m_timeout;
};

namespace testUtils {

std::string GetResDir(const std::string& module_path,
                      const std::string& res_dir = "test/resource");

void SetRootEnvVars(const std::string& module_path,
                    const std::string& res_dir = "test/resource");

} // namespace testUtils


#define BEGIN_CRIT_SEC(id) {            \
    ctd::system::Mutex tmpMutex(id); \

#define END_CRIT_SEC }

} // namespace ctd
} // namespace system

#endif // IFW_CTD_SYSTEM_HPP_