Fix SDO writes of empty strings.

Author: willson556

canopen/sdo/client.py

@@ -215,7 +215,9 @@ def open(self, index, subindex=0, mode="rb", encoding="ascii",
                 raw_stream = BlockDownloadStream(self, index, subindex, size, request_crc_support=request_crc_support)
             else:
                 raw_stream = WritableStream(self, index, subindex, size, force_segment)
-            if buffering:
+            if buffering and ((size is None) or size > 0):
+                # BufferedWriter will omit the write if size is 0 and the expedited SDO will not be sent
+                # Therefore, skip the BufferedWriter if size is known to be 0
                 buffered_stream = io.BufferedWriter(raw_stream, buffer_size=buffer_size)
             else:
                 return raw_stream

test/test_sdo.py

@@ -68,6 +68,8 @@ def _send_message(self, can_id, data, remote=False):
         while self.data and self.data[0][0] == RX:
             self.network.notify(0x582, self.data.pop(0)[1], 0.0)
 
+        self.message_sent = True
+
     def setUp(self):
         network = canopen.Network()
         network.NOTIFIER_SHUTDOWN_TIMEOUT = 0.0
@@ -76,6 +78,8 @@ def setUp(self):
         node.sdo.RESPONSE_TIMEOUT = 0.01
         self.network = network
 
+        self.message_sent = False
+
     def test_expedited_upload(self):
         self.data = [
             (TX, b'\x40\x18\x10\x01\x00\x00\x00\x00'),
@@ -91,6 +95,7 @@ def test_expedited_upload(self):
         ]
         trans_type = self.network[2].sdo[0x1400]['Transmission type RPDO 1'].raw
         self.assertEqual(trans_type, 254)
+        self.assertTrue(self.message_sent)
 
     def test_size_not_specified(self):
         self.data = [
@@ -100,13 +105,23 @@ def test_size_not_specified(self):
         # Make sure the size of the data is 1 byte
         data = self.network[2].sdo.upload(0x1400, 2)
         self.assertEqual(data, b'\xfe')
+        self.assertTrue(self.message_sent)
 
     def test_expedited_download(self):
         self.data = [
             (TX, b'\x2b\x17\x10\x00\xa0\x0f\x00\x00'),
             (RX, b'\x60\x17\x10\x00\x00\x00\x00\x00')
         ]
         self.network[2].sdo[0x1017].raw = 4000
+        self.assertTrue(self.message_sent)
+
+    def test_expedited_download_zero_length(self):
+        self.data = [
+            (TX, b'\x33\x00\x20\x00\x00\x00\x00\x00'),
+            (RX, b'\x60\x00\x20\x00\x00\x00\x00\x00')
+        ]
+        self.network[2].sdo[0x2000].raw = ""
+        self.assertTrue(self.message_sent)
 
     def test_segmented_upload(self):
         self.data = [