我每天都在学习dds,所以我的问题听起来怪怪的。我希望这是合理的。
我正在编写的dds包装器的要求之一是,如果它不能写,它会在某个超时时间后超时。我的问题:,我怎么能这样做?
在棱镜技术网站教程上,有关于如何使用WaitSet阻止读操作的解释,但是写呢?
下面是一些代码,包括问题:
dds::domain::DomainParticipant dp(0);
dds::topic::Topic<MyType> topic(dp, "MyTopic");
dds::pub::Publisher pub(dp);
dds::pub::DataWriter<MyType> dw(pub, topic);
MyType t;
dw.write(t); //how can I make this block for 5 seconds (tops), and then throw an error on failure?我注意到API DataWriter::wait_for_acknowledgements(int timeout)中存在一个函数,但这似乎是绑定到DataWriter对象,而不是绑定到特定的编写调用。我能把上面的电话绑起来吗?
发布于 2017-02-05 18:21:06
这是在QoS,cf可靠性,字段"max_blocking_time“中配置的。如何设置此值将取决于供应商的实现。通常,您得到当前的QoS,更新字段,写回QoS。请记住,在发生其他事情之前,必须设置某些QoS策略。可靠性是“先启用”(至少在我最熟悉的实现中),这意味着您需要创建禁用的数据写入器,更新QoS,然后启用写入器。
如果可以在应用程序之外设置QoS (例如通过XML ),那么您可以轻松地设置策略。否则,您需要在代码中这样做。
从规范中:
如果max_blocking_time没有存储写入值的空间,则DataWriter的值指示允许操作DataWriter::写阻塞的最长时间。默认的max_blocking_time=100ms。
https://stackoverflow.com/questions/42023478
复制相似问题