Program Listing for File RTPSParticipantAllocationAttributes.hpp
↰ Return to documentation for file (/tmp/ws/src/fastrtps/include/fastdds/rtps/attributes/RTPSParticipantAllocationAttributes.hpp
)
// Copyright 2019 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_RTPSPARTICIPANTALLOCATIONATTRIBUTES_HPP_
#define _FASTDDS_RTPS_RTPSPARTICIPANTALLOCATIONATTRIBUTES_HPP_
#include <fastdds/rtps/builtin/data/ContentFilterProperty.hpp>
#include <fastrtps/utils/collections/ResourceLimitedContainerConfig.hpp>
namespace eprosima {
namespace fastrtps {
namespace rtps {
struct RemoteLocatorsAllocationAttributes
{
bool operator ==(
const RemoteLocatorsAllocationAttributes& b) const
{
return (this->max_unicast_locators == b.max_unicast_locators) &&
(this->max_multicast_locators == b.max_multicast_locators);
}
size_t max_unicast_locators = 4u;
size_t max_multicast_locators = 1u;
};
struct SendBuffersAllocationAttributes
{
bool operator ==(
const SendBuffersAllocationAttributes& b) const
{
return (this->preallocated_number == b.preallocated_number) &&
(this->dynamic == b.dynamic);
}
size_t preallocated_number = 0u;
bool dynamic = false;
};
struct VariableLengthDataLimits
{
bool operator ==(
const VariableLengthDataLimits& b) const
{
return (this->max_properties == b.max_properties) &&
(this->max_user_data == b.max_user_data) &&
(this->max_partitions == b.max_partitions) &&
(this->max_datasharing_domains == b.max_datasharing_domains);
}
size_t max_properties = 0;
size_t max_user_data = 0;
size_t max_partitions = 0;
size_t max_datasharing_domains = 0;
};
struct RTPSParticipantAllocationAttributes
{
RemoteLocatorsAllocationAttributes locators;
ResourceLimitedContainerConfig participants;
ResourceLimitedContainerConfig readers;
ResourceLimitedContainerConfig writers;
SendBuffersAllocationAttributes send_buffers;
VariableLengthDataLimits data_limits;
fastdds::rtps::ContentFilterProperty::AllocationConfiguration content_filter;
ResourceLimitedContainerConfig total_readers() const
{
return total_endpoints(readers);
}
ResourceLimitedContainerConfig total_writers() const
{
return total_endpoints(writers);
}
bool operator ==(
const RTPSParticipantAllocationAttributes& b) const
{
return (this->locators == b.locators) &&
(this->participants == b.participants) &&
(this->readers == b.readers) &&
(this->writers == b.writers) &&
(this->send_buffers == b.send_buffers) &&
(this->data_limits == b.data_limits);
}
private:
ResourceLimitedContainerConfig total_endpoints(
const ResourceLimitedContainerConfig& endpoints) const
{
constexpr size_t max = (std::numeric_limits<size_t>::max)();
size_t initial;
size_t maximum;
size_t increment;
initial = participants.initial * endpoints.initial;
maximum = (participants.maximum == max || endpoints.maximum == max)
? max : participants.maximum * endpoints.maximum;
increment = (std::max)(participants.increment, endpoints.increment);
return { initial, maximum, increment };
}
};
const RTPSParticipantAllocationAttributes c_default_RTPSParticipantAllocationAttributes
= RTPSParticipantAllocationAttributes();
} /* namespace rtps */
} /* namespace fastrtps */
} /* namespace eprosima */
#endif /* _FASTDDS_RTPS_RTPSPARTICIPANTALLOCATIONATTRIBUTES_HPP_ */