address_mapping.h

#pragma once
 
//
// Copyright (c) 2019-2022 Ivan Baidakou (basiliscos) (the dot dmol at gmail dot com)
//
// Distributed under the MIT Software License
//
 
#include "arc.hpp"
#include "subscription.h"
#include <unordered_map>
#include <vector>
 
#if defined(_MSC_VER)
#pragma warning(push)
#pragma warning(disable : 4251)
#endif
 
namespace rotor {
 
struct ROTOR_API address_mapping_t {
    void set(actor_base_t &actor, const subscription_info_ptr_t &info) noexcept;
 
    address_ptr_t get_mapped_address(actor_base_t &actor, const void *) noexcept;
 
    template <typename Fn> void each_subscription(const actor_base_t &actor, Fn &&fn) const noexcept {
        auto it_mappings = actor_map.find(static_cast<const void *>(&actor));
        for (auto it : it_mappings->second) {
            fn(it.second);
        }
    }
 
    bool has_subscriptions(const actor_base_t &actor) const noexcept;
 
    bool empty() const noexcept { return actor_map.empty(); }
 
    void remove(const subscription_point_t &point) noexcept;
 
  private:
    using point_map_t = std::unordered_map<const void *, subscription_info_ptr_t>;
    using actor_map_t = std::unordered_map<const void *, point_map_t>;
    actor_map_t actor_map;
};
 
} // namespace rotor
 
#if defined(_MSC_VER)
#pragma warning(pop)
#endif