Add generic interfaces for RPC servers (#241)

* Refs #23325. Update swig file for RPC interfaces.

Signed-off-by: Miguel Company <miguelcompany@eprosima.com>

* Refs #23325. Update generated code.

Signed-off-by: Miguel Company <miguelcompany@eprosima.com>

---------

Signed-off-by: Miguel Company <miguelcompany@eprosima.com>

Author: MiguelCompany

fastdds_python/src/swig/fastdds/dds/rpc/interfaces.i

@@ -16,4 +16,11 @@
 #include "fastdds/dds/rpc/interfaces.hpp"
 %}
 
+%include "std_shared_ptr.i"
+
+%shared_ptr(eprosima::fastdds::dds::rpc::RpcServer);
+%ignore eprosima::fastdds::dds::rpc::RpcServer::execute_request;
+
+%include "fastdds/dds/rpc/interfaces/RpcRequest.hpp"
+%include "fastdds/dds/rpc/interfaces/RpcServer.hpp"
 %include "fastdds/dds/rpc/interfaces/RpcStatusCode.hpp"

fastdds_python_examples/RPCExample/generated_code/calculator.i

@@ -29,6 +29,13 @@
 
 // If using windows in debug, it would try to use python_d, which would not be found.
 %begin %{
+/*
+ * From: https://github.com/swig/swig/issues/2638
+ * When a module uses a type in a module that is defined in a different module,
+ * a false positive memory leak is detected.
+ * The following line silences this warning.
+ */
+#define SWIG_PYTHON_SILENT_MEMLEAK
 #ifdef _MSC_VER
 #define SWIG_PYTHON_INTERPRETER_NO_DEBUG
 #endif
@@ -74,6 +81,7 @@
 
 %import(module="fastdds") "fastdds/dds/rpc/exceptions/RpcException.hpp"
 %import(module="fastdds") "fastdds/dds/rpc/exceptions/RpcOperationError.hpp"
+%import(module="fastdds") "fastdds/dds/rpc/interfaces/RpcServer.hpp"
 
 %exception {
     try
@@ -228,35 +236,13 @@ namespace swig {
 
 
 %shared_ptr(calculator_base::BasicCalculator);
-%shared_ptr(calculator_base::BasicCalculatorServer);
-%extend calculator_base::BasicCalculatorServer
-{
-    void run()
-    {
-        Py_BEGIN_ALLOW_THREADS
-        self->run();
-        Py_END_ALLOW_THREADS
-    }
-}
-
 %shared_ptr(calculator_base::BasicCalculatorServer_IServerImplementation);
 %shared_ptr(calculator_base::BasicCalculatorServerImplementation);
 %feature("director") calculator_base::BasicCalculatorServerImplementation;
 
 
 
 %shared_ptr(Calculator);
-%shared_ptr(CalculatorServer);
-%extend CalculatorServer
-{
-    void run()
-    {
-        Py_BEGIN_ALLOW_THREADS
-        self->run();
-        Py_END_ALLOW_THREADS
-    }
-}
-
 %shared_ptr(CalculatorServer_IServerImplementation);
 %shared_ptr(CalculatorServerImplementation);
 %feature("director") CalculatorServerImplementation;

fastdds_python_examples/RPCExample/generated_code/calculatorClient.cxx

@@ -205,6 +205,7 @@ class BasicCalculatorClient : public BasicCalculator
             std::shared_ptr<T> result,
             std::promise<TResult>& promise)
     {
+        result->info.related_sample_identity.writer_guid(requester_->get_requester_reader()->guid());
         if (fdds::RETCODE_OK == requester_->send_request((void*)&request, result->info))
         {
             std::lock_guard<std::mutex> _ (mtx_);
@@ -224,6 +225,7 @@ class BasicCalculatorClient : public BasicCalculator
             const RequestType& request,
             std::shared_ptr<T> result)
     {
+        result->info.related_sample_identity.writer_guid(requester_->get_requester_reader()->guid());
         if (fdds::RETCODE_OK == requester_->send_request((void*)&request, result->info))
         {
             std::lock_guard<std::mutex> _ (mtx_);
@@ -719,6 +721,7 @@ class CalculatorClient : public Calculator
             std::shared_ptr<T> result,
             std::promise<TResult>& promise)
     {
+        result->info.related_sample_identity.writer_guid(requester_->get_requester_reader()->guid());
         if (fdds::RETCODE_OK == requester_->send_request((void*)&request, result->info))
         {
             std::lock_guard<std::mutex> _ (mtx_);
@@ -738,6 +741,7 @@ class CalculatorClient : public Calculator
             const RequestType& request,
             std::shared_ptr<T> result)
     {
+        result->info.related_sample_identity.writer_guid(requester_->get_requester_reader()->guid());
         if (fdds::RETCODE_OK == requester_->send_request((void*)&request, result->info))
         {
             std::lock_guard<std::mutex> _ (mtx_);