view.hpp

Go to the documentation of this file.

#pragma once

#include <cstdint>
#include <iostream>
#include <memory>
#include <vector>

#include "detail/derecho_internal.hpp"
#include "derecho_modes.hpp"
#include "detail/derecho_sst.hpp"
#include "detail/multicast_group.hpp"
#include <derecho/sst/sst.hpp>
#include <derecho/mutils-serialization/SerializationMacros.hpp>
#include <derecho/mutils-serialization/SerializationSupport.hpp>

namespace derecho {
enum PORT_TYPE { GMS = 1,
                 RPC,
                 SST,
                 RDMC };

class SubView : public mutils::ByteRepresentable {
public:
    Mode mode;
    std::vector<node_id_t> members;
    std::vector<int> is_sender;
    std::vector<std::tuple<ip_addr_t, uint16_t, uint16_t, uint16_t, uint16_t>> member_ips_and_ports;
    std::vector<node_id_t> joined;
    std::vector<node_id_t> departed;
    int32_t my_rank;
    const std::string profile;
    int rank_of(const node_id_t& who) const;
    int sender_rank_of(uint32_t rank) const;
    uint32_t num_senders() const;
    SubView(int32_t num_members);

    DEFAULT_SERIALIZATION_SUPPORT(SubView, mode, members, is_sender,
                                  member_ips_and_ports, joined, departed, profile);
    SubView(Mode mode, const std::vector<node_id_t>& members,
            std::vector<int> is_sender,
            const std::vector<std::tuple<ip_addr_t, uint16_t, uint16_t, uint16_t, uint16_t>>& member_ips_and_ports,
            const std::vector<node_id_t>& joined,
            const std::vector<node_id_t>& departed,
            const std::string &profile)
            : mode(mode),
              members(members),
              is_sender(is_sender),
              member_ips_and_ports(member_ips_and_ports),
              joined(joined),
              departed(departed),
              my_rank(-1),
              profile(profile) {}

    SubView(Mode mode, const std::vector<node_id_t>& members,
            std::vector<int> is_sender,
            const std::vector<std::tuple<ip_addr_t, uint16_t, uint16_t, uint16_t, uint16_t>>& member_ips_and_ports,
            std::string profile);

    void init_joined_departed(const SubView& previous_subview);
};

class View : public mutils::ByteRepresentable {
public:
    const int32_t vid;
    const std::vector<node_id_t> members;
    const std::vector<std::tuple<ip_addr_t, uint16_t, uint16_t, uint16_t, uint16_t>> member_ips_and_ports;
    std::vector<char> failed;  //Note: std::vector<bool> is broken, so we pretend these char values are C-style booleans
    int32_t num_failed;
    std::vector<node_id_t> joined;
    std::vector<node_id_t> departed;
    const int32_t num_members;
    int32_t my_rank;
    bool is_adequately_provisioned = true;
    int32_t next_unassigned_rank;
    std::unique_ptr<MulticastGroup> multicast_group;
    std::shared_ptr<DerechoSST> gmsSST;
    std::vector<std::type_index> subgroup_type_order;
    std::map<subgroup_type_id_t, std::vector<subgroup_id_t>> subgroup_ids_by_type_id;
    std::vector<std::vector<SubView>> subgroup_shard_views;
    std::map<subgroup_id_t, uint32_t> my_subgroups;
    std::map<node_id_t, uint32_t> node_id_to_rank;

    bool i_know_i_am_leader = false;  // I am the leader (and know it)

    SubView make_subview(const std::vector<node_id_t>& with_members, const Mode mode = Mode::ORDERED, const std::vector<int>& is_sender = {}, std::string profile = "default") const;

    int rank_of(const std::tuple<ip_addr_t, uint16_t, uint16_t, uint16_t, uint16_t>& who) const;
    int rank_of(const node_id_t& who) const;
    int find_rank_of_leader() const;
    bool i_am_leader() const;
    bool i_am_new_leader();
    void merge_changes();
    void wedge();

    int subview_rank_of_shard_leader(subgroup_id_t subgroup_id, uint32_t shard_index) const;

    std::string debug_string() const;

    DEFAULT_SERIALIZATION_SUPPORT(View, vid, members, member_ips_and_ports,
                                  failed, num_failed, joined, departed,
                                  num_members, next_unassigned_rank,
                                  subgroup_ids_by_type_id, subgroup_shard_views, my_subgroups);

    View(const int32_t vid, const std::vector<node_id_t>& members,
         const std::vector<std::tuple<ip_addr_t, uint16_t, uint16_t, uint16_t, uint16_t>>& member_ips_and_ports,
         const std::vector<char>& failed, const int32_t num_failed,
         const std::vector<node_id_t>& joined,
         const std::vector<node_id_t>& departed, const int32_t num_members,
         const int32_t next_unassigned_rank,
         const std::map<subgroup_type_id_t, std::vector<subgroup_id_t>>& subgroup_ids_by_type_id,
         const std::vector<std::vector<SubView>>& subgroup_shard_views,
         const std::map<subgroup_id_t, uint32_t>& my_subgroups);

    View(const int32_t vid, const std::vector<node_id_t>& members,
         const std::vector<std::tuple<ip_addr_t, uint16_t, uint16_t, uint16_t, uint16_t>>& member_ips_and_ports,
         const std::vector<char>& failed,
         const std::vector<node_id_t>& joined,
         const std::vector<node_id_t>& departed, const int32_t my_rank,
         const int32_t next_unassigned_rank,
         const std::vector<std::type_index>& subgroup_type_order);
};

}  // namespace derecho