Исправление. Вызов отсутствующего сигнала
This commit is contained in:
@@ -1,4 +1,4 @@
|
||||
class_name rep_network extends Node
|
||||
class_name Network extends Node
|
||||
|
||||
|
||||
const PROTOCOL_TYPES: = {'yau07tx': yau07.YaU07, 'json-capsrpb': capsrpb.CapsRpb, 'udp-json-mbcs': sch3.Sch3}
|
||||
@@ -7,6 +7,8 @@ const SERIAL_PROTO: = {'uart': spt25.SPT25 }
|
||||
|
||||
var tick: int = 0
|
||||
|
||||
signal socket_error(args)
|
||||
|
||||
class Serial extends SerialPort:
|
||||
func send_to(data: PackedByteArray): return write_raw(data)
|
||||
func _to_string() -> String: return 'последовательный порт \"%s\" @ %d (%s)' % [self.port, self.baudrate, 'открыт' if is_open() else 'закрыт']
|
||||
@@ -216,18 +218,18 @@ func _process(_delta: float) -> void:
|
||||
var unit = units[addr]
|
||||
match unit.process(tick):
|
||||
Error.OK: sock_unicast.send_to([addr[0], dst_ports[addr]], unit.tx_data.slice(0, unit.tx_len))
|
||||
Error.FAILED: emit_signal('socket_error', 'ошибка: %s %s:%d' % [unit, addr[0], addr[1]])
|
||||
Error.FAILED: emit_signal('socket_error', [unit, sock_unicast])
|
||||
for key in units_serial:
|
||||
var unit = units_serial[key]
|
||||
var serial = serials[key]
|
||||
match unit.process(tick):
|
||||
Error.OK: serial.send_to(unit.tx_data)
|
||||
Error.FAILED: emit_signal('socket_error', 'ошибка: \"%s\"' % unit.name)
|
||||
Error.FAILED: emit_signal('socket_error', [unit, serial])
|
||||
for sock_unit in tcp_sockets:
|
||||
var sock = sock_unit[0]
|
||||
var unit = sock_unit[1]
|
||||
match unit.process(tick):
|
||||
Error.OK: sock.send_to(unit.tx_data)
|
||||
Error.FAILED: emit_signal('socket_error', 'ошибка: %s' % unit)
|
||||
Error.FAILED: emit_signal('socket_error', [unit, sock])
|
||||
poll_receive_tcp(sock)
|
||||
poll_sockets.any(func(sock): poll_receive(sock))
|
||||
|
||||
Reference in New Issue
Block a user