Skip to content

Commit

Permalink
Refs #20733: Properly fix key annotation handling
Browse files Browse the repository at this point in the history 
Signed-off-by: eduponz <[email protected]>
  • Loading branch information
@EduPonz
EduPonz committed Apr 29, 2024
1 parent f3feee5 commit b76cfdc
Show file tree
Hide file tree
Showing 5 changed files with 109 additions and 56 deletions.
91 changes: 60 additions & 31 deletions include/fastrtps/types/MemberDescriptor.h
View file
Original file line number Diff line number Diff line change
Expand Up @@ -18,16 +18,17 @@
#include <fastrtps/types/TypesBase.h>
#include <fastrtps/types/DynamicTypePtr.h>

namespace eprosima{
namespace fastrtps{
namespace types{
namespace eprosima {
namespace fastrtps {
namespace types {

class DynamicType;
class AnnotationDescriptor;

class MemberDescriptor
{
protected:

std::string name_; // Name of the member
MemberId id_; // MemberId, it should be filled automatically when the member is added.
DynamicType_ptr type_; // Member's Type.
Expand All @@ -43,11 +44,17 @@ class MemberDescriptor
friend class DynamicTypeMember;
friend class TypeObjectFactory;

bool is_default_value_consistent(const std::string& sDefaultValue) const;
bool is_default_value_consistent(
const std::string& sDefaultValue) const;

bool is_type_name_consistent(
const std::string& sName) const;

bool is_type_name_consistent(const std::string& sName) const;
void copy_annotations_from_type(
const DynamicType_ptr& type);

public:

RTPS_DllAPI MemberDescriptor();

RTPS_DllAPI MemberDescriptor(
Expand All @@ -57,37 +64,41 @@ class MemberDescriptor
RTPS_DllAPI MemberDescriptor(
MemberId id,
const std::string& name,
DynamicType_ptr type_);
DynamicType_ptr type);

RTPS_DllAPI MemberDescriptor(
MemberId id,
const std::string& name,
DynamicType_ptr type_,
DynamicType_ptr type,
const std::string& defaultValue);

RTPS_DllAPI MemberDescriptor(
MemberId id,
const std::string& name,
DynamicType_ptr type_,
DynamicType_ptr type,
const std::string& defaultValue,
const std::vector<uint64_t>& unionLabels,
bool isDefaultLabel);

RTPS_DllAPI MemberDescriptor(const MemberDescriptor* descriptor);
RTPS_DllAPI MemberDescriptor(
const MemberDescriptor* descriptor);

RTPS_DllAPI ~MemberDescriptor();

bool check_union_labels(const std::vector<uint64_t>& labels) const;
bool check_union_labels(
const std::vector<uint64_t>& labels) const;

RTPS_DllAPI ReturnCode_t copy_from(const MemberDescriptor* other);
RTPS_DllAPI ReturnCode_t copy_from(
const MemberDescriptor* other);

RTPS_DllAPI bool equals(const MemberDescriptor* other) const;
RTPS_DllAPI bool equals(
const MemberDescriptor* other) const;

RTPS_DllAPI TypeKind get_kind() const;

RTPS_DllAPI MemberId get_id() const;

RTPS_DllAPI uint32_t get_index() const;
RTPS_DllAPI uint32_t get_index() const;

RTPS_DllAPI std::string get_name() const;

Expand All @@ -105,39 +116,49 @@ class MemberDescriptor

RTPS_DllAPI bool is_default_union_value() const;

RTPS_DllAPI bool is_consistent(TypeKind parentKind) const;
RTPS_DllAPI bool is_consistent(
TypeKind parentKind) const;

RTPS_DllAPI void add_union_case_index(uint64_t value);
RTPS_DllAPI void add_union_case_index(
uint64_t value);

RTPS_DllAPI void set_id(MemberId id);
RTPS_DllAPI void set_id(
MemberId id);

RTPS_DllAPI void set_index(uint32_t index);
RTPS_DllAPI void set_index(
uint32_t index);

RTPS_DllAPI void set_name(const std::string& name);
RTPS_DllAPI void set_name(
const std::string& name);

RTPS_DllAPI void set_type(DynamicType_ptr type);
RTPS_DllAPI void set_type(
DynamicType_ptr type);

RTPS_DllAPI DynamicType_ptr get_type() const
{
return type_;
}

RTPS_DllAPI void set_default_union_value(bool bDefault);
RTPS_DllAPI void set_default_union_value(
bool bDefault);

RTPS_DllAPI void set_default_value(const std::string& value)
RTPS_DllAPI void set_default_value(
const std::string& value)
{
default_value_ = value;
}

// Annotations
ReturnCode_t apply_annotation(AnnotationDescriptor& descriptor);
ReturnCode_t apply_annotation(
AnnotationDescriptor& descriptor);

ReturnCode_t apply_annotation(
const std::string& annotation_name,
const std::string& key,
const std::string& value);

AnnotationDescriptor* get_annotation(const std::string& name) const;
AnnotationDescriptor* get_annotation(
const std::string& name) const;

// Annotations application
RTPS_DllAPI bool annotation_is_optional() const;
Expand Down Expand Up @@ -168,23 +189,31 @@ class MemberDescriptor
RTPS_DllAPI uint16_t annotation_get_bit_bound() const;

// Annotations setters
RTPS_DllAPI void annotation_set_optional(bool optional);
RTPS_DllAPI void annotation_set_optional(
bool optional);

RTPS_DllAPI void annotation_set_key(bool key);
RTPS_DllAPI void annotation_set_key(
bool key);

RTPS_DllAPI void annotation_set_must_understand(bool must_understand);
RTPS_DllAPI void annotation_set_must_understand(
bool must_understand);

RTPS_DllAPI void annotation_set_non_serialized(bool non_serialized);
RTPS_DllAPI void annotation_set_non_serialized(
bool non_serialized);

RTPS_DllAPI void annotation_set_value(const std::string& value);
RTPS_DllAPI void annotation_set_value(
const std::string& value);

RTPS_DllAPI void annotation_set_default(const std::string& default_value);
RTPS_DllAPI void annotation_set_default(
const std::string& default_value);

RTPS_DllAPI void annotation_set_default_literal();

RTPS_DllAPI void annotation_set_position(uint16_t position);
RTPS_DllAPI void annotation_set_position(
uint16_t position);

RTPS_DllAPI void annotation_set_bit_bound(uint16_t bit_bound);
RTPS_DllAPI void annotation_set_bit_bound(
uint16_t bit_bound);
};

} // namespace types
Expand Down
19 changes: 15 additions & 4 deletions src/cpp/dynamic-types/AnnotationDescriptor.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -90,12 +90,23 @@ bool AnnotationDescriptor::equals(

bool AnnotationDescriptor::key_annotation() const
{
auto it = value_.find(ANNOTATION_KEY_ID);
if (it == value_.end())
bool ret = false;

// Annotations @key and @Key have names "key" and "Key" respectively.
if (type_ && (type_->get_name() == ANNOTATION_KEY_ID || type_->get_name() == ANNOTATION_EPKEY_ID))
{
it = value_.find(ANNOTATION_EPKEY_ID); // Legacy "@Key"
// When an annotation is a key annotation, there is only one entry in value_.
// Its map key is "value" and its value is either "true" of "false".
// We cannot call get_value() directly because it is not const-qualified
auto it = value_.find("value");

if (it != value_.end())
{
ret = it->second == CONST_TRUE;
}
}
return (it != value_.end() && it->second == CONST_TRUE);

return ret;
}

ReturnCode_t AnnotationDescriptor::get_value(
Expand Down
11 changes: 2 additions & 9 deletions src/cpp/dynamic-types/DynamicType.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -191,7 +191,7 @@ ReturnCode_t DynamicType::copy_from_builder(
{
DynamicTypeMember* newMember = new DynamicTypeMember(it->second);
newMember->set_parent(this);
is_key_defined_ = newMember->key_annotation();
is_key_defined_ |= newMember->key_annotation();
member_by_id_.insert(std::make_pair(newMember->get_id(), newMember));
member_by_name_.insert(std::make_pair(newMember->get_name(), newMember));
}
Expand Down Expand Up @@ -245,14 +245,7 @@ TypeDescriptor* DynamicType::get_descriptor()

bool DynamicType::key_annotation() const
{
for (auto anIt = descriptor_->annotation_.begin(); anIt != descriptor_->annotation_.end(); ++anIt)
{
if ((*anIt)->key_annotation())
{
return true;
}
}
return false;
return descriptor_->annotation_get_key();
}

bool DynamicType::equals(
Expand Down
38 changes: 31 additions & 7 deletions src/cpp/dynamic-types/MemberDescriptor.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -31,6 +31,7 @@ MemberDescriptor::MemberDescriptor()
, index_(INDEX_INVALID)
, default_label_(false)
{
copy_annotations_from_type(type_);
}

MemberDescriptor::MemberDescriptor(
Expand All @@ -43,6 +44,7 @@ MemberDescriptor::MemberDescriptor(
, index_(index)
, default_label_(false)
{
copy_annotations_from_type(type_);
}

MemberDescriptor::MemberDescriptor(
Expand All @@ -55,51 +57,54 @@ MemberDescriptor::MemberDescriptor(
, default_label_(false)
{
copy_from(descriptor);
copy_annotations_from_type(type_);
}

MemberDescriptor::MemberDescriptor(
MemberId id,
const std::string& name,
DynamicType_ptr type_)
DynamicType_ptr type)
: name_(name)
, id_(id)
, type_(type_)
, type_(type)
, default_value_("")
, index_(INDEX_INVALID)
, default_label_(false)
{

copy_annotations_from_type(type_);
}

MemberDescriptor::MemberDescriptor(
MemberId id,
const std::string& name,
DynamicType_ptr type_,
DynamicType_ptr type,
const std::string& defaultValue)
: name_(name)
, id_(id)
, type_(type_)
, type_(type)
, default_value_(defaultValue)
, index_(INDEX_INVALID)
, default_label_(false)
{
copy_annotations_from_type(type_);
}

MemberDescriptor::MemberDescriptor(
MemberId id,
const std::string& name,
DynamicType_ptr type_,
DynamicType_ptr type,
const std::string& defaultValue,
const std::vector<uint64_t>& unionLabels,
bool isDefaultLabel)
: name_(name)
, id_(id)
, type_(type_)
, type_(type)
, default_value_(defaultValue)
, index_(INDEX_INVALID)
, default_label_(isDefaultLabel)
{
labels_ = unionLabels;
copy_annotations_from_type(type_);
}

MemberDescriptor::~MemberDescriptor()
Expand Down Expand Up @@ -411,6 +416,25 @@ bool MemberDescriptor::is_type_name_consistent(
return TypeDescriptor::is_type_name_consistent(sName);
}

void MemberDescriptor::copy_annotations_from_type(
const DynamicType_ptr& type)
{
if (type)
{
// Copy annotation from type
uint32_t num_annotations = type->get_annotation_count();
for (uint32_t i = 0; i < num_annotations; ++i)
{
AnnotationDescriptor ann;
type->get_annotation(ann, i);
AnnotationDescriptor* pNewDescriptor = new AnnotationDescriptor();
pNewDescriptor->copy_from(&ann);
annotation_.push_back(pNewDescriptor);
}
}

}

void MemberDescriptor::set_id(
MemberId id)
{
Expand Down
6 changes: 1 addition & 5 deletions src/cpp/rtps/xmlparser/XMLDynamicParser.cpp
View file
Original file line number Diff line number Diff line change
Expand Up @@ -1464,11 +1464,7 @@ p_dynamictypebuilder_t XMLParser::parseXMLMemberDynamicType(
{
if (strncmp(memberTopicKey, "true", 5) == 0)
{
memberBuilder->apply_annotation(types::ANNOTATION_KEY_ID, "key", "true");
if (p_dynamictype != nullptr)
{
p_dynamictype->apply_annotation(types::ANNOTATION_KEY_ID, "key", "true");
}
memberBuilder->apply_annotation(types::ANNOTATION_KEY_ID, "value", "true");
}
}

Expand Down

0 comments on commit b76cfdc

Please sign in to comment.