.. _program_listing_file__tmp_ws_src_fastrtps_include_fastdds_rtps_writer_LocatorSelectorSender.hpp:

Program Listing for File LocatorSelectorSender.hpp
==================================================

|exhale_lsh| :ref:`Return to documentation for file <file__tmp_ws_src_fastrtps_include_fastdds_rtps_writer_LocatorSelectorSender.hpp>` (``/tmp/ws/src/fastrtps/include/fastdds/rtps/writer/LocatorSelectorSender.hpp``)

.. |exhale_lsh| unicode:: U+021B0 .. UPWARDS ARROW WITH TIP LEFTWARDS

.. code-block:: cpp

   #ifndef _FASTDDS_RTPS_WRITER_LOCATORSELECTORSENDER_HPP_
   #define _FASTDDS_RTPS_WRITER_LOCATORSELECTORSENDER_HPP_
   
   #include <fastdds/rtps/common/LocatorSelector.hpp>
   #include <fastdds/rtps/messages/RTPSMessageSenderInterface.hpp>
   #include <fastrtps/utils/collections/ResourceLimitedVector.hpp>
   
   #include <mutex>
   
   namespace eprosima {
   namespace fastrtps {
   namespace rtps {
   
   class RTPSWriter;
   
   class LocatorSelectorSender : public RTPSMessageSenderInterface
   {
   public:
   
       LocatorSelectorSender(
               RTPSWriter& writer,
               ResourceLimitedContainerConfig matched_readers_allocation
               )
           : locator_selector(matched_readers_allocation)
           , all_remote_readers(matched_readers_allocation)
           , all_remote_participants(matched_readers_allocation)
           , writer_(writer)
       {
       }
   
       bool destinations_have_changed() const override
       {
           return false;
       }
   
       GuidPrefix_t destination_guid_prefix() const override
       {
           return all_remote_participants.size() == 1 ? all_remote_participants.at(0) : c_GuidPrefix_Unknown;
       }
   
       const std::vector<GuidPrefix_t>& remote_participants() const override
       {
           return all_remote_participants;
       }
   
       const std::vector<GUID_t>& remote_guids() const override
       {
           return all_remote_readers;
       }
   
       bool send(
               CDRMessage_t* message,
               std::chrono::steady_clock::time_point max_blocking_time_point) const override;
   
       void lock() override
       {
           mutex_.lock();
       }
   
       void unlock() override
       {
           mutex_.unlock();
       }
   
       fastrtps::rtps::LocatorSelector locator_selector;
   
       ResourceLimitedVector<GUID_t> all_remote_readers;
   
       ResourceLimitedVector<GuidPrefix_t> all_remote_participants;
   
   private:
   
       RTPSWriter& writer_;
   
       std::recursive_mutex mutex_;
   };
   
   } // namespace rtps
   } // namespace fastrtps
   } // namespace eprosima
   #endif // _FASTDDS_RTPS_WRITER_LOCATORSELECTORSENDER_HPP_