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

History queue not updated #458

Closed
yjaeger83 opened this issue Jun 17, 2024 · 5 comments
Closed

History queue not updated #458

yjaeger83 opened this issue Jun 17, 2024 · 5 comments

Comments

@yjaeger83
Copy link

yjaeger83 commented Jun 17, 2024

Hello,

We are currently using ddsrouter with different Qos. We recently upgraded from version 1.0.0 to version 2.2.0 and we are facing an issue.
We did not change the consumer code (ddsparticipant using the "take" functions) but it seems that the values that have QoS set to transient local are kept inside the history (although the history policy is KEEP_LAST).
For example, if the history-depth is set to 5, our consuming component retrieves the 5 oldest elements (with Qos transient local) from the history and all new values seemed to be dropped and never make it to the calling code.

version: v4.0
specs:
    qos:
        history-depth: 5
participants:
    - name: participant_1
      kind: local
      domain: 2
    - name: participant_2
      kind: wan
      connection-addresses:
        - domain: cpu-proxy-crypto
          port: 15222
          transport: udp
      listening-addresses:
        - domain: vm-dcs.2410
          port: 15222
          transport: udp
@juanlofer-eprosima
Copy link
Contributor

juanlofer-eprosima commented Jun 17, 2024

Hello @yjaeger83 , could you please provide a concrete example of messages sent by your publisher, messages expected to be received by your subscriber, and actual messages received by your subscriber? I'm afraid we were not able to fully understand the problem.
Also, could you please clarify what are the history and durability configurations for your publisher and subscriber?

@yjaeger83
Copy link
Author

Hello,
The history policy of our publisher and subscriber is KEEP_LAST with a history depth of 1.

@yjaeger83
Copy link
Author

yjaeger83 commented Jun 17, 2024

We are only transferring text messages in our topics. When history-depth is set to 5 in the ddsRouters configuration (on both sides), then for the topics that are set to be transient local, we will receive 5 updates of those topics, the subsequent updates of those topics are somehow dropped or ignored.
For example if topic1 (with qos= transient local) is sent sequencially with following values "test1", "test2", "test3", "test4", "test5", "test6", the subscriber will only receive "test1", "test2", "test3", "test4", "test5". All subsequent values of topic1 are either not sent by the publisher or not received by the subscriber.

@juanlofer-eprosima
Copy link
Contributor

Hi @yjaeger83 , thank you for the detailed information, we were able to reproduce the issue.
The fix will be introduced in the following PR and included in the upcoming product release.

Cheers!

@yjaeger83
Copy link
Author

Thank you @juanlofer-eprosima for your quick reaction.

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

No branches or pull requests

2 participants