add error message on invalid connection header

ros2dart · Jun 25, 2021 · fef3b9b · fef3b9b
1 parent 10d89e6
commit fef3b9b
Showing 1 changed file with 4 additions and 0 deletions.
diff --git a/lib/src/impl/publisher_impl.dart b/lib/src/impl/publisher_impl.dart
@@ -128,6 +128,10 @@ class PublisherImpl<T extends RosMessage> {
         validateSubHeader(writer, header, topic, type, messageClass.md5sum);
 
     if (!validated) {
+      final reader = ByteDataReader(endian: Endian.little);
+      reader.add(writer.toBytes());
+      log.dartros.error(
+          'Subscriber connection header invalid ${deserializeStringFields(reader)}');
       socket.add(writer.toBytes());
       await socket.flush();
       await socket.close();