Task.hpp

/*
 * Copyright 2017 ONERA
 *
 * This file is part of the MAUVE Runtime project.
 *
 * MAUVE Runtime is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License version 3 as
 * published by the Free Software Foundation.
 *
 * MAUVE Runtime is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with MAUVE.  If not, see <https://www.gnu.org/licenses/lgpl-3.0>.
 */
#ifndef MAUVE_RUNTIME_TASK_HPP
#define MAUVE_RUNTIME_TASK_HPP

#include <mqueue.h>
#include <pthread.h>
#include <signal.h>
#include <iostream>
#include <string>
#include <atomic>

#include "common.hpp"

#define TASK_MQ_MAX_MSG 10
#define TASK_SIG SIGUSR1

namespace mauve {
  namespace runtime {

    class AbstractComponent;
    class ComponentLogger;

    // ========================= Task =========================

    enum TaskStatus { CREATED, ACTIVATED, RUNNING };

    class Task final {

    public:
      Task(AbstractComponent * component);
      ~Task();

      AbstractComponent * get_component();

      inline TaskStatus get_status() const { return status; }

      pthread_t thread_id() const;
      time_ns_t get_time() const;

      bool activate();
      bool start(time_ns_t start_time, pthread_barrier_t * barrier = nullptr);
      bool stop();

      std::string to_string() const;

    protected:
      ComponentLogger* logger;

    private:
      static void *thread_start(void *data);

      void release();
      void run();

      AbstractComponent * component;
      std::atomic<TaskStatus> status;

      std::atomic<bool> finish;

      pthread_t pthread_id; // Useless
      pthread_t pt_id;      // Thread ID

      time_ns_t time;

      // barrier for configuration
      pthread_barrier_t barrier;
      // barrier for start
      std::atomic<pthread_barrier_t *> start_barrier;

      // Signal
      pid_t t_id;
      struct sigevent sev;
      timer_t timerid;
      struct itimerspec its;

    }; /* class Task */

  }
} /* namespace mauve */

#endif