Restore exceptions for Connext and message timestamps on Windows (#765)

Signed-off-by: Andrea Sorbini <[email protected]>

rclpy/test/test_client.py

@@ -12,12 +12,14 @@
 # See the License for the specific language governing permissions and
 # limitations under the License.
 
+import platform
 import time
 import unittest
 
 from rcl_interfaces.srv import GetParameters
 import rclpy
 import rclpy.executors
+from rclpy.utilities import get_rmw_implementation_identifier
 
 # TODO(sloretz) Reduce fudge once wait_for_service uses node graph events
 TIME_FUDGE = 0.3
@@ -89,6 +91,9 @@ def test_concurrent_calls_to_service(self):
             self.node.destroy_client(cli)
             self.node.destroy_service(srv)
 
+    @unittest.skipIf(
+        get_rmw_implementation_identifier() == 'rmw_connextdds' and platform.system() == 'Windows',
+        reason='Source timestamp not implemented for Connext on Windows')
     def test_service_timestamps(self):
         cli = self.node.create_client(GetParameters, 'get/parameters')
         srv = self.node.create_service(

rclpy/test/test_node.py

@@ -13,6 +13,7 @@
 # limitations under the License.
 
 import pathlib
+import platform
 import time
 import unittest
 from unittest.mock import Mock
@@ -49,6 +50,7 @@
 from rclpy.qos import QoSProfile
 from rclpy.qos import QoSReliabilityPolicy
 from rclpy.time_source import USE_SIM_TIME_NAME
+from rclpy.utilities import get_rmw_implementation_identifier
 from test_msgs.msg import BasicTypes
 
 TEST_NODE = 'my_node'
@@ -144,6 +146,9 @@ def test_create_raw_subscription(self):
     def dummy_cb(self, msg):
         pass
 
+    @unittest.skipIf(
+        get_rmw_implementation_identifier() == 'rmw_connextdds' and platform.system() == 'Windows',
+        reason='Source timestamp not implemented for Connext on Windows')
     def test_take(self):
         basic_types_pub = self.node.create_publisher(BasicTypes, 'take_test', 1)
         sub = self.node.create_subscription(