Client repeatedly receives the first response

[allbluelai]

Is there an already existing issue for this?

• I have searched the existing issues

Expected behavior

Client receives response correctly

Current behavior

Server output:

$ ./DDSCalculatorServer
Press a key + ENTER to close the server
Server result: 0 + 3 = 3
Server result: 2 + 5 = 7
Server result: 4 + 7 = 11
Server result: 6 + 9 = 15
Server result: 8 + 11 = 19
Server result: 10 + 13 = 23
Server result: 12 + 15 = 27
Server result: 14 + 17 = 31
Server result: 16 + 19 = 35
Server result: 18 + 21 = 39
Server result: 20 + 23 = 43
Server result: 22 + 25 = 47
Server result: 24 + 27 = 51
Server result: 26 + 29 = 55
Server result: 28 + 31 = 59
Server result: 30 + 33 = 63
Server result: 32 + 35 = 67
Server result: 34 + 37 = 71
Server result: 36 + 39 = 75
Server result: 38 + 41 = 79
^C

Server correctly gives the calculation results.

Client output:

$ ./DDSCalculatorClient
Client result: 0 + 3 = 3
Client result: 2 + 5 = 3
Client result: 4 + 7 = 7
Client result: 6 + 9 = 11
Client result: 8 + 11 = 15
Client result: 10 + 13 = 19
Client result: 12 + 15 = 23
Client result: 14 + 17 = 27
Client result: 16 + 19 = 31
Client result: 18 + 21 = 35
Client result: 20 + 23 = 39
Client result: 22 + 25 = 43
Client result: 24 + 27 = 47
Client result: 26 + 29 = 51
Client result: 28 + 31 = 55
Client result: 30 + 33 = 59
Client result: 32 + 35 = 63
Client result: 34 + 37 = 67
Client result: 36 + 39 = 71
Client result: 38 + 41 = 75

Starting from the second request, subsequent responses are incorrect. Client repeatedly receives the first request.

Steps to reproduce

Download fastrtps.repos and

vcs import --input fastrtps.repos .

My workspace is as follows:

$ tree -L 1
.
├── build.sh
├── fastcdr
├── fastddsgen
├── fastrtps
├── fastrtps.repos
├── foonathan_memory_vendor
├── install
└── RequestReplyExample

6 directories, 2 files

Add the following codes to CalculatorClient.cpp:

auto lambda = [](int index) {
  CalculatorClient client;
  client.init();
  int32_t count = 0;
  while (count < 20) {
    int32_t x = count * index;
    int32_t y = count * index + 3;
    int64_t z = client.request(OperationType::ADDITION, x, y);

    std::cout << "Client result: " << x << " + " << y << " = " << z
              << std::endl;
    count++;
    std::this_thread::sleep_for(std::chrono::milliseconds((index + 1) * 100));
  }

  client.deinit();
};

std::vector<std::thread> vec(1);
vec[0] = std::thread(lambda, 2);
for (size_t i = 0; i < vec.size(); i++) {
  vec[i].join();
}

Build all libraries and install them. Here, I use the following script:

#!/bin/bash

clear

set -e

current_path=$(pwd)

mkdir -p ${current_path}/foonathan_memory_vendor/build
cd ${current_path}/foonathan_memory_vendor/build
cmake .. -DCMAKE_INSTALL_PREFIX=${current_path}/install
make install


mkdir -p ${current_path}/fastcdr/build
cd ${current_path}/fastcdr/build
cmake .. -DCMAKE_INSTALL_PREFIX=${current_path}/install
make install


mkdir -p ${current_path}/fastrtps/build
cd ${current_path}/fastrtps/build
cmake .. -DCMAKE_INSTALL_PREFIX=${current_path}/install -DCMAKE_PREFIX_PATH=${current_path}/install
make install


mkdir -p ${current_path}/RequestReplyExample/build
cd ${current_path}/RequestReplyExample/build
cmake .. -DCMAKE_INSTALL_PREFIX=${current_path}/install -DCMAKE_PREFIX_PATH=${current_path}/install
make

Fast DDS version/commit

v2.14.3

Platform/Architecture

Other. Please specify in Additional context section.

Transport layer

Default configuration, UDPv4 & SHM

Additional context

$ uname -a
Linux john 6.5.0-45-generic #45~22.04.1-Ubuntu SMP PREEMPT_DYNAMIC Mon Jul 15 16:40:02 UTC 2 x86_64 x86_64 x86_64 GNU/Linux

XML configuration file

No response

Relevant log output

No response

Network traffic capture

No response

[JesusPoderoso]

Hi @allbluelai, thanks for the report.

This example was not meant to be run as your modification, so the condition variable boolean value was not updated when the reply was received.
If you add this expression listener_.received_reply = false; in this line, you will obtain the expected behavior.

As long as the example works as designed, I am moving this ticket to the support section according to the Fast DDS CONTRIBUTING guidelines.

[allbluelai]

Hello, @JesusPoderoso
It works great for me. Thanks for your help.