Program Listing for File RTPSParticipant.h
↰ Return to documentation for file (/tmp/ws/src/fastrtps/include/fastdds/rtps/participant/RTPSParticipant.h
)
// Copyright 2016 Proyectos y Sistemas de Mantenimiento SL (eProsima).
//
// 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 _FASTDDS_RTPS_RTPSParticipant_H_
#define _FASTDDS_RTPS_RTPSParticipant_H_
#include <cstdint>
#include <cstdlib>
#include <memory>
#include <fastrtps/fastrtps_dll.h>
#include <fastdds/rtps/common/Guid.h>
#include <fastdds/rtps/attributes/RTPSParticipantAttributes.h>
#include <fastdds/rtps/builtin/data/ContentFilterProperty.hpp>
#include <fastdds/statistics/IListeners.hpp>
#include <fastrtps/qos/ReaderQos.h>
#include <fastrtps/qos/WriterQos.h>
namespace eprosima {
namespace fastdds {
namespace dds {
namespace builtin {
class TypeLookupManager;
} // namespace builtin
} // namespace dds
} // namespace fastdds
namespace fastrtps {
class TopicAttributes;
namespace rtps {
class RTPSParticipantImpl;
class RTPSParticipantListener;
class RTPSWriter;
class RTPSReader;
class WriterProxyData;
class ReaderProxyData;
class EndpointAttributes;
class WriterAttributes;
class ReaderAttributes;
class ResourceEvent;
class WLP;
class RTPS_DllAPI RTPSParticipant
{
friend class RTPSParticipantImpl;
friend class RTPSDomain;
friend class RTPSDomainImpl;
private:
RTPSParticipant(
RTPSParticipantImpl* pimpl);
virtual ~RTPSParticipant();
public:
const GUID_t& getGuid() const;
void announceRTPSParticipantState();
// //!Method to loose the next change (ONLY FOR TEST). //TODO remove this method because is only for testing
// void loose_next_change();
void stopRTPSParticipantAnnouncement();
void resetRTPSParticipantAnnouncement();
bool newRemoteWriterDiscovered(
const GUID_t& pguid,
int16_t userDefinedId);
bool newRemoteReaderDiscovered(
const GUID_t& pguid,
int16_t userDefinedId);
uint32_t getRTPSParticipantID() const;
bool registerWriter(
RTPSWriter* Writer,
const TopicAttributes& topicAtt,
const WriterQos& wqos);
bool registerReader(
RTPSReader* Reader,
const TopicAttributes& topicAtt,
const ReaderQos& rqos,
const fastdds::rtps::ContentFilterProperty* content_filter = nullptr);
void update_attributes(
const RTPSParticipantAttributes& patt);
bool updateWriter(
RTPSWriter* Writer,
const TopicAttributes& topicAtt,
const WriterQos& wqos);
bool updateReader(
RTPSReader* Reader,
const TopicAttributes& topicAtt,
const ReaderQos& rqos,
const fastdds::rtps::ContentFilterProperty* content_filter = nullptr);
std::vector<std::string> getParticipantNames() const;
const RTPSParticipantAttributes& getRTPSParticipantAttributes() const;
uint32_t getMaxMessageSize() const;
uint32_t getMaxDataSize() const;
ResourceEvent& get_resource_event() const;
WLP* wlp() const;
bool get_new_entity_id(
EntityId_t& entityId);
void set_check_type_function(
std::function<bool(const std::string&)>&& check_type);
fastdds::dds::builtin::TypeLookupManager* typelookup_manager() const;
void set_listener(
RTPSParticipantListener* listener);
uint32_t get_domain_id() const;
void enable();
#if HAVE_SECURITY
bool is_security_enabled_for_writer(
const WriterAttributes& writer_attributes);
bool is_security_enabled_for_reader(
const ReaderAttributes& reader_attributes);
#endif // if HAVE_SECURITY
#ifdef FASTDDS_STATISTICS
bool add_statistics_listener(
std::shared_ptr<fastdds::statistics::IListener> listener,
uint32_t kind);
bool remove_statistics_listener(
std::shared_ptr<fastdds::statistics::IListener> listener,
uint32_t kind);
void set_enabled_statistics_writers_mask(
uint32_t enabled_writers);
#endif // FASTDDS_STATISTICS
private:
RTPSParticipantImpl* mp_impl;
};
} // namespace rtps
} /* namespace rtps */
} /* namespace eprosima */
#endif /* _FASTDDS_RTPS_RTPSParticipant_H_ */