revert bug fix in the mainline.

fujitatomoya · fujitatomoya · commit 6d7bbbba750a · 2025-03-25T14:12:57.000-07:00
Signed-off-by: Tomoya.Fujita &lt;tomoya.fujita825@gmail.com&gt;
diff --git a/ddspipe_core/src/cpp/communication/rpc/RpcBridge.cpp b/ddspipe_core/src/cpp/communication/rpc/RpcBridge.cpp
@@ -296,6 +296,9 @@ void RpcBridge::transmit_(
         std::unique_ptr<IRoutingData> data;
         utils::ReturnCode ret = reader->take(data);
 
+        RpcPayloadData& rpc_data = dynamic_cast<RpcPayloadData&>(*data);
+
+
         // Will never return \c RETCODE_NO_DATA, otherwise would have finished before
         if (!ret)
         {
@@ -306,8 +309,6 @@ void RpcBridge::transmit_(
                                                                     << ". Skipping data and continue.");
             continue;
         }
-    
-        RpcPayloadData& rpc_data = dynamic_cast<RpcPayloadData&>(*data);
 
         if (RpcTopic::is_request_topic(reader->topic()))
         {

Original file line number	Diff line number	Diff line change
`@@ -296,6 +296,9 @@ void RpcBridge::transmit_(`
`296`	`296`	`std::unique_ptr<IRoutingData> data;`
`297`	`297`	`utils::ReturnCode ret = reader->take(data);`
`298`	`298`
	`299`	`+ RpcPayloadData& rpc_data = dynamic_cast<RpcPayloadData&>(*data);`
	`300`	`+`
	`301`	`+`
`299`	`302`	`// Will never return \c RETCODE_NO_DATA, otherwise would have finished before`
`300`	`303`	`if (!ret)`
`301`	`304`	`{`
`@@ -306,8 +309,6 @@ void RpcBridge::transmit_(`
`306`	`309`	`<< ". Skipping data and continue.");`
`307`	`310`	`continue;`
`308`	`311`	`}`
`309`		`-`
`310`		`- RpcPayloadData& rpc_data = dynamic_cast<RpcPayloadData&>(*data);`
`311`	`312`
`312`	`313`	`if (RpcTopic::is_request_topic(reader->topic()))`
`313`	`314`	`{`