static_storage.hpp

// Copyright 2020 Open Source Robotics Foundation, Inc.
//
// Licensed under the Apache License, Version 2.0 (the "License");
// you may not use this file except in compliance with the License.
// You may obtain a copy of the License at
//
//     http://www.apache.org/licenses/LICENSE-2.0
//
// Unless required by applicable law or agreed to in writing, software
// distributed under the License is distributed on an "AS IS" BASIS,
// WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
// See the License for the specific language governing permissions and
// limitations under the License.
 
#ifndef RCLCPP__WAIT_SET_POLICIES__STATIC_STORAGE_HPP_
#define RCLCPP__WAIT_SET_POLICIES__STATIC_STORAGE_HPP_
 
#include <array>
#include <memory>
#include <utility>
 
#include "rclcpp/client.hpp"
#include "rclcpp/guard_condition.hpp"
#include "rclcpp/macros.hpp"
#include "rclcpp/service.hpp"
#include "rclcpp/subscription_base.hpp"
#include "rclcpp/subscription_wait_set_mask.hpp"
#include "rclcpp/timer.hpp"
#include "rclcpp/visibility_control.hpp"
#include "rclcpp/wait_set_policies/detail/storage_policy_common.hpp"
#include "rclcpp/waitable.hpp"
 
namespace rclcpp
{
namespace wait_set_policies
{
 
 
template<
  std::size_t NumberOfSubscriptions,
  std::size_t NumberOfGuardCondtions,
  std::size_t NumberOfTimers,
  std::size_t NumberOfClients,
  std::size_t NumberOfServices,
  std::size_t NumberOfWaitables
>
class StaticStorage : public rclcpp::wait_set_policies::detail::StoragePolicyCommon<true>
{
protected:
  using is_mutable = std::false_type;
 
  class SubscriptionEntry
  {
public:
    std::shared_ptr<rclcpp::SubscriptionBase> subscription;
    rclcpp::SubscriptionWaitSetMask mask;
 
    SubscriptionEntry(
      std::shared_ptr<rclcpp::SubscriptionBase> subscription_in = nullptr,
      rclcpp::SubscriptionWaitSetMask mask_in = {})
    : subscription(std::move(subscription_in)),
      mask(mask_in)
    {}
  };
  using ArrayOfSubscriptions = std::array<
    SubscriptionEntry,
    NumberOfSubscriptions
  >;
  using SubscriptionsIterable = ArrayOfSubscriptions;
 
  using ArrayOfGuardConditions = std::array<
    std::shared_ptr<rclcpp::GuardCondition>,
    NumberOfGuardCondtions
  >;
  using GuardConditionsIterable = ArrayOfGuardConditions;
 
  using ArrayOfTimers = std::array<
    std::shared_ptr<rclcpp::TimerBase>,
    NumberOfTimers
  >;
  using TimersIterable = ArrayOfTimers;
 
  using ArrayOfClients = std::array<
    std::shared_ptr<rclcpp::ClientBase>,
    NumberOfClients
  >;
  using ClientsIterable = ArrayOfClients;
 
  using ArrayOfServices = std::array<
    std::shared_ptr<rclcpp::ServiceBase>,
    NumberOfServices
  >;
  using ServicesIterable = ArrayOfServices;
 
  struct WaitableEntry
  {
    WaitableEntry(
      std::shared_ptr<rclcpp::Waitable> waitable_in = nullptr,
      std::shared_ptr<void> associated_entity_in = nullptr) noexcept
    : waitable(std::move(waitable_in)),
      associated_entity(std::move(associated_entity_in))
    {}
 
    std::shared_ptr<rclcpp::Waitable> waitable;
    std::shared_ptr<void> associated_entity;
  };
  using ArrayOfWaitables = std::array<
    WaitableEntry,
    NumberOfWaitables
  >;
  using WaitablesIterable = ArrayOfWaitables;
 
  template<class ArrayOfExtraGuardConditions>
  explicit
  StaticStorage(
    const ArrayOfSubscriptions & subscriptions,
    const ArrayOfGuardConditions & guard_conditions,
    const ArrayOfExtraGuardConditions & extra_guard_conditions,
    const ArrayOfTimers & timers,
    const ArrayOfClients & clients,
    const ArrayOfServices & services,
    const ArrayOfWaitables & waitables,
    rclcpp::Context::SharedPtr context
  )
  : StoragePolicyCommon(
      subscriptions,
      guard_conditions,
      extra_guard_conditions,
      timers,
      clients,
      services,
      waitables,
      context),
    subscriptions_(subscriptions),
    guard_conditions_(guard_conditions),
    timers_(timers),
    clients_(clients),
    services_(services),
    waitables_(waitables)
  {}
 
  ~StaticStorage() = default;
 
  template<class ArrayOfExtraGuardConditions>
  void
  storage_rebuild_rcl_wait_set(const ArrayOfExtraGuardConditions & extra_guard_conditions)
  {
    this->storage_rebuild_rcl_wait_set_with_sets(
      subscriptions_,
      guard_conditions_,
      extra_guard_conditions,
      timers_,
      clients_,
      services_,
      waitables_
    );
 
    if(this->needs_pruning_) {
      // we need to throw here, as the indexing of the rcl_waitset is broken,
      // in case of invalid entries
 
      throw std::runtime_error(
            "StaticStorage::storage_rebuild_rcl_wait_set(): entity weak_ptr "
            "unexpectedly expired in static entity storage");
    }
  }
 
  // storage_add_subscription() explicitly not declared here
  // storage_remove_subscription() explicitly not declared here
  // storage_add_guard_condition() explicitly not declared here
  // storage_remove_guard_condition() explicitly not declared here
  // storage_add_timer() explicitly not declared here
  // storage_remove_timer() explicitly not declared here
  // storage_add_client() explicitly not declared here
  // storage_remove_client() explicitly not declared here
  // storage_add_service() explicitly not declared here
  // storage_remove_service() explicitly not declared here
  // storage_add_waitable() explicitly not declared here
  // storage_remove_waitable() explicitly not declared here
  // storage_prune_deleted_entities() explicitly not declared here
 
  void
  storage_acquire_ownerships()
  {
    // Explicitly do nothing.
  }
 
  void
  storage_release_ownerships()
  {
    // Explicitly do nothing.
  }
 
  size_t size_of_subscriptions() const
  {
    return subscriptions_.size();
  }
 
  size_t size_of_timers() const
  {
    return timers_.size();
  }
 
  size_t size_of_clients() const
  {
    return clients_.size();
  }
 
  size_t size_of_services() const
  {
    return services_.size();
  }
 
  size_t size_of_waitables() const
  {
    return waitables_.size();
  }
 
  typename ArrayOfSubscriptions::value_type
  subscriptions(size_t ii) const
  {
    return subscriptions_[ii];
  }
 
  typename ArrayOfTimers::value_type
  timers(size_t ii) const
  {
    return timers_[ii];
  }
 
  typename ArrayOfClients::value_type
  clients(size_t ii) const
  {
    return clients_[ii];
  }
 
  typename ArrayOfServices::value_type
  services(size_t ii) const
  {
    return services_[ii];
  }
 
  typename ArrayOfWaitables::value_type
  waitables(size_t ii) const
  {
    return waitables_[ii];
  }
 
  const ArrayOfSubscriptions subscriptions_;
  const ArrayOfGuardConditions guard_conditions_;
  const ArrayOfTimers timers_;
  const ArrayOfClients clients_;
  const ArrayOfServices services_;
  const ArrayOfWaitables waitables_;
};
 
}  // namespace wait_set_policies
}  // namespace rclcpp
 
#endif  // RCLCPP__WAIT_SET_POLICIES__STATIC_STORAGE_HPP_