Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Streaming tests using flexible-msg #11102

Merged
merged 5 commits into from
Nov 15, 2022
Merged

Streaming tests using flexible-msg #11102

merged 5 commits into from
Nov 15, 2022

Conversation

maloel
Copy link
Collaborator

@maloel maloel commented Nov 14, 2022

No description provided.

@maloel maloel requested a review from OhadMeir November 14, 2022 11:11
{
return json::from_cbor( _data.begin(), _data.end() );
}
DDS_THROW( runtime_error, "non-json flexible data is still unsupported" );
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CBOR is supported now, maybe "Custom data is not supported yet"

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Well, it's a function called json_data() and if we add other formats, they won't be supported either...

py::enum_< durability >( m, "durability" )
.value( "volatile", eprosima::fastdds::dds::DurabilityQosPolicyKind::VOLATILE_DURABILITY_QOS )
.value( "transient_local", eprosima::fastdds::dds::DurabilityQosPolicyKind::TRANSIENT_LOCAL_DURABILITY_QOS )
.value( "transient", eprosima::fastdds::dds::DurabilityQosPolicyKind::TRANSIENT_DURABILITY_QOS );
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

We are not using TRANSIENT, if adding values we don't use there is also PERSISTENT durability

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It's not about whether it's being used or not; it's about whether it's available. PERSISTENT is not supported, so I did not add.

else:
raise RuntimeError( "invalid 'name' argument: " + type(name) )
self.writer = dds.topic_writer( self.handle )
self.writer.run( qos or dds.topic_writer.qos( dds.reliability.reliable, dds.durability.transient_local ) )
Copy link
Contributor

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Why transient_local?

Copy link
Collaborator Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

It's a left-over from my experiments trying to make it work with the single line. I don't think it's needed any more, but for now harmless. I'll remove later.

@maloel maloel merged commit 0772565 into IntelRealSense:dds Nov 15, 2022
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
Development

Successfully merging this pull request may close these issues.

2 participants