wip
This commit is contained in:
parent
730c270c29
commit
6c44b0b681
@ -63,7 +63,6 @@ class ModbusComponent(Component):
|
|||||||
if wrote.isError():
|
if wrote.isError():
|
||||||
# self.log.exception(traceback.format_exception(type(wrote), wrote, wrote.__traceback__))
|
# self.log.exception(traceback.format_exception(type(wrote), wrote, wrote.__traceback__))
|
||||||
raise wrote
|
raise wrote
|
||||||
return True
|
|
||||||
|
|
||||||
def _decode(self, read, data_type="16bit_uint", *args, **kwargs):
|
def _decode(self, read, data_type="16bit_uint", *args, **kwargs):
|
||||||
decoder = BinaryPayloadDecoder.fromRegisters(read.registers, byteorder=self.byteorder, wordorder=self.wordorder)
|
decoder = BinaryPayloadDecoder.fromRegisters(read.registers, byteorder=self.byteorder, wordorder=self.wordorder)
|
||||||
@ -96,7 +95,7 @@ class ModbusComponent(Component):
|
|||||||
args = [s["dt"], *s.get("a", [])]
|
args = [s["dt"], *s.get("a", [])]
|
||||||
if not len(kwargs):
|
if not len(kwargs):
|
||||||
kwargs = s.get("k", {})
|
kwargs = s.get("k", {})
|
||||||
return self._write(register, self._encode(data, *args, **kwargs))
|
self._write(register, self._encode(data, *args, **kwargs))
|
||||||
|
|
||||||
# def _get(self, data):
|
# def _get(self, data):
|
||||||
# # print("MODBUS", str(int(QThread.currentThreadId())), flush=True)
|
# # print("MODBUS", str(int(QThread.currentThreadId())), flush=True)
|
||||||
|
|||||||
Loading…
Reference in New Issue
Block a user