Skip to content

Commit 82b68f5

Browse files
committed
Refs #23325. Update generated code.
Signed-off-by: Miguel Company <miguelcompany@eprosima.com>
1 parent 664b7f9 commit 82b68f5

5 files changed

Lines changed: 269 additions & 170 deletions

File tree

fastdds_python_examples/RPCExample/generated_code/calculator.i

Lines changed: 1 addition & 22 deletions
Original file line numberDiff line numberDiff line change
@@ -74,6 +74,7 @@
7474

7575
%import(module="fastdds") "fastdds/dds/rpc/exceptions/RpcException.hpp"
7676
%import(module="fastdds") "fastdds/dds/rpc/exceptions/RpcOperationError.hpp"
77+
%import(module="fastdds") "fastdds/dds/rpc/interfaces/RpcServer.hpp"
7778

7879
%exception {
7980
try
@@ -228,35 +229,13 @@ namespace swig {
228229

229230

230231
%shared_ptr(calculator_base::BasicCalculator);
231-
%shared_ptr(calculator_base::BasicCalculatorServer);
232-
%extend calculator_base::BasicCalculatorServer
233-
{
234-
void run()
235-
{
236-
Py_BEGIN_ALLOW_THREADS
237-
self->run();
238-
Py_END_ALLOW_THREADS
239-
}
240-
}
241-
242232
%shared_ptr(calculator_base::BasicCalculatorServer_IServerImplementation);
243233
%shared_ptr(calculator_base::BasicCalculatorServerImplementation);
244234
%feature("director") calculator_base::BasicCalculatorServerImplementation;
245235

246236

247237

248238
%shared_ptr(Calculator);
249-
%shared_ptr(CalculatorServer);
250-
%extend CalculatorServer
251-
{
252-
void run()
253-
{
254-
Py_BEGIN_ALLOW_THREADS
255-
self->run();
256-
Py_END_ALLOW_THREADS
257-
}
258-
}
259-
260239
%shared_ptr(CalculatorServer_IServerImplementation);
261240
%shared_ptr(CalculatorServerImplementation);
262241
%feature("director") CalculatorServerImplementation;

fastdds_python_examples/RPCExample/generated_code/calculatorClient.cxx

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -205,6 +205,7 @@ class BasicCalculatorClient : public BasicCalculator
205205
std::shared_ptr<T> result,
206206
std::promise<TResult>& promise)
207207
{
208+
result->info.related_sample_identity.writer_guid(requester_->get_requester_reader()->guid());
208209
if (fdds::RETCODE_OK == requester_->send_request((void*)&request, result->info))
209210
{
210211
std::lock_guard<std::mutex> _ (mtx_);
@@ -224,6 +225,7 @@ class BasicCalculatorClient : public BasicCalculator
224225
const RequestType& request,
225226
std::shared_ptr<T> result)
226227
{
228+
result->info.related_sample_identity.writer_guid(requester_->get_requester_reader()->guid());
227229
if (fdds::RETCODE_OK == requester_->send_request((void*)&request, result->info))
228230
{
229231
std::lock_guard<std::mutex> _ (mtx_);
@@ -719,6 +721,7 @@ class CalculatorClient : public Calculator
719721
std::shared_ptr<T> result,
720722
std::promise<TResult>& promise)
721723
{
724+
result->info.related_sample_identity.writer_guid(requester_->get_requester_reader()->guid());
722725
if (fdds::RETCODE_OK == requester_->send_request((void*)&request, result->info))
723726
{
724727
std::lock_guard<std::mutex> _ (mtx_);
@@ -738,6 +741,7 @@ class CalculatorClient : public Calculator
738741
const RequestType& request,
739742
std::shared_ptr<T> result)
740743
{
744+
result->info.related_sample_identity.writer_guid(requester_->get_requester_reader()->guid());
741745
if (fdds::RETCODE_OK == requester_->send_request((void*)&request, result->info))
742746
{
743747
std::lock_guard<std::mutex> _ (mtx_);

0 commit comments

Comments
 (0)