0

我正在 openDDS 中创建一个简单的消息程序。该程序使用发布者和订阅者。在发布者中，我写了一条消息：

DDS::ReturnCode_t error = message_writer->write(message, DDS::HANDLE_NIL);

当我尝试从 180 字节发送到 3012 字节时，写入器失败并显示：

错误 10 (== DDS::RETCODE_TIMEOUT)

，大约 260 条消息后（我正在尝试发送 1500 条消息）。我觉得奇怪的是，当我发送来自 1 <= x < 180 和 3012 > x > 102400+ 字节的消息时，它会起作用。

我收到了作家方面的错误。在我做的作家下面：

if (error != DDS::RETCODE_OK) { 
    std::cerr << "writer failed because of error" << error << std::endl; 
}

我的 idl 文件是这样的：

module Mess { 
    struct Mes { 
        string message; 
    };};

所以这使用了TAO字符串管理器。我将 char* 传递到消息中。

Messenger::Message message;

message.message = "some_Message";

然后像以前一样写消息

参与者：

DDS::DomainParticipant_var participant = dpf->create_participant(DOMAIN_ID, PARTICIPANT_QOS_DEFAULT, 0, OpenDDS::DCPS::DEFAULT_STATUS_MASK);

话题：

DDS::Topic_var topic = participant->create_topic("TopicName", type_name, TOPIC_QOS_DEFAULT, 0, OpenDDS::DCPS::DEFAULT_STATUS_MASK);

出版商：

DDS::Publisher_var publisher = participant->create_publisher(PUBLISHER_QOS_DEFAULT, 0, OpenDDS::DCPS::DEFAULT_STATUS_MASK);

作家：

DDS::DataWriter_var writer = publisher->create_datawriter(topic, DATAWRITER_QOS_DEFAULT, 0, OpenDDS::DCPS::DEFAULT_STATUS_MASK);

任何帮助都将不胜感激。谢谢！

4

1 回答 1

1

我发现了问题。原因是我的应用程序发布的速度比网络分发样本的速度要快。修复是在 DataWriter 上使用以下 Qos：

DDS::DataWriterQos dw_qos;
pub->get_default_datawriter_qos (dw_qos);
dw_qos.history.kind = DDS::KEEP_ALL_HISTORY_QOS;
dw_qos.reliability.kind = DDS::RELIABLE_RELIABILITY_QOS;
dw_qos.reliability.max_blocking_time.sec = 22;
dw_qos.reliability.max_blocking_time.nanosec = 0;
dw_qos.resource_limits.max_samples_per_instance = 5;
DDS::DataWriter_var dw = pub->create_datawriter(topic, dw_qos, 0, OpenDDS::DCPS::DEFAULT_STATUS_MASK);

此数据写入器具有以下行为：

最多可以排队 5 个等待交付给一个或多个订阅者的样本。

如果有 5 个样本待处理，则写入调用最多会阻塞 22 秒，以等待队列中的打开。

如果未发生打开，则 write 调用将返回 DDS::RETCODE_TIMEOUT 而不是 RETCODE_OK。

感谢所有的帮助！

于 2015-09-02T09:14:31.607 回答