|
@@ -36,7 +36,7 @@ blocks:
|
|
|
id: variable
|
|
|
parameters:
|
|
|
comment: ''
|
|
|
- value: '1203.47'
|
|
|
+ value: '11678.3'
|
|
|
states:
|
|
|
bus_sink: false
|
|
|
bus_source: false
|
|
@@ -143,14 +143,16 @@ blocks:
|
|
|
\ self, name=\"Serial Source Block\", in_sig=None, out_sig=[numpy.uint8]\n\
|
|
|
\ )\n self._serial_port = serial.Serial(\n port=port,\
|
|
|
\ baudrate=baud_rate, bytesize=serial.EIGHTBITS, timeout=timeout\n )\n\
|
|
|
+ \ # remove first bytes that may have unexpected values > 1, unclear why\n\
|
|
|
+ \ # seen [0b110000000, 0] and [0, 0b11111110] so far\n self._serial_port.read(2)\n\
|
|
|
\ self._buffer_max_length = buffer_max_length\n self._invert =\
|
|
|
\ invert\n\n def work(self, input_items, output_items):\n # pylint:\
|
|
|
\ disable=unused-argument\n buffer = self._serial_port.read(\n \
|
|
|
\ min(len(output_items[0]), self._buffer_max_length)\n )\n \
|
|
|
\ output_items[0][: len(buffer)] = numpy.frombuffer(buffer, dtype=\"u1\")\n\
|
|
|
- \ if self._invert:\n output_items[0] ^= 1\n assert\
|
|
|
- \ output_items[0][: len(buffer)].max() <= 1, \"invalid value\"\n return\
|
|
|
- \ len(buffer)\n"
|
|
|
+ \ if output_items[0][: len(buffer)].max() > 1:\n raise ValueError(output_items[0][:\
|
|
|
+ \ len(buffer)])\n if self._invert:\n output_items[0] ^= 1\n\
|
|
|
+ \ return len(buffer)\n"
|
|
|
affinity: ''
|
|
|
alias: ''
|
|
|
baud_rate: '115200'
|