octopos.h

Go to the documentation of this file.

// Copyright 2017 Space HAUC Command and Data Handling
// This file is part of octopOS which is released under AGPLv3.
// See file LICENSE.txt or go to <http://www.gnu.org/licenses/> for full
// license details.

#ifndef INCLUDE_OCTOPOS_H_
#define INCLUDE_OCTOPOS_H_

#include <signal.h>

#include <unordered_map>
#include <mutex>                                                                  // NOLINT
#include <string>
#include <vector>
#include <tuple>
#include <sstream>
#include <iterator>
#include <memory>
#include <utility>

#include "utility.h"                                                              // NOLINT
#include "tentacle.h"                                                             // NOLINT


class octopOS {
 public:
    static octopOS& getInstance();

    octopOS(octopOS const&) = delete;

    void operator=(octopOS const &) = delete;

    ~octopOS();

    std::pair<unsigned, key_t> create_new_topic
        (std::string name, unsigned size);

    static void* listen_for_child(void* tentacle_index_dynamic);

    bool propagate_to_subscribers(std::string name);

    std::pair<unsigned, key_t> subscribe_to_topic(std::string name,
        unsigned tentacle, octopOS_id_t subscriber_id, long size = -1);           // NOLINT

    static void sig_handler(int sig);

 private:
    static long get_id(tentacle::role_t role);                                    // NOLINT

    void topic_reader_in();

    void topic_reader_out();

    void topic_writer_in();

    void topic_writer_out();

    static int shmid;
    static int tentacle_ids[NUMMODULES];
    static std::vector<int> semids;
    static std::vector<tentacle*> tentacles;
    static intptr_t *shared_ptr, *shared_end_ptr;

    static std::unordered_map<std::string,
               std::tuple<unsigned,
                      key_t,
                      std::vector<std::pair<octopOS_id_t, unsigned>>
                        >
                   > topic_data;

    static std::mutex topic_data_rdlock, topic_data_rdtry,
        topic_data_wrlock, topic_data_lock;
    static unsigned topic_data_readers, topic_data_writers;

    octopOS();
};

#endif  // INCLUDE_OCTOPOS_H_