maxim/PRD_TU_MP550
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

add command

Browse Source
This commit is contained in:
Maxim
2025-02-07 15:31:16 +03:00
parent 2ff430c381
commit 077bdb40f4
5 changed files with 157 additions and 67 deletions
Download Patch File Download Diff File Expand all files Collapse all files

90
scripts/network.gd
View File

@@ -2,8 +2,7 @@ extends Node
# ЯУ-07 Блок
var unit = Yau07.YaU07.new('ЯУ-07Б')
var unit_fs_1 = Fs.FGOS.new()
#var unit_fs_2 = Fs.FGOS.new()
var unit_fs = Fs.FGOS.new()
var soc_unicast: Socket
var soc_brodcast: Socket
var ip_address_yau: String = Constants.ADDRESSES[0][1]
@@ -116,7 +115,7 @@ func _ready() -> void:
unit.connect('command_fail', Callable(self, 'on_command_fail'))
connect_fs_1()
connect_fs_2()
read_port_isa([0x106, 0x108])
read_port_isa([Constants.BASE_PORTS.UG+6, Constants.BASE_PORTS.UG+8, Constants.BASE_PORTS.EMS_G+8])
func _process(delta: float) -> void:
@@ -203,13 +202,13 @@ func state_machine_fs(client_fs):
if (state_fs == Constants.STATE.IDLE) or (state_fs == Constants.STATE.DONE):
if command_stack:
var pack: Array = command_stack.pop_front()
unit_fs_1.send_fs_data(pack, client_fs_1, peerstream_fs_1)
unit_fs.send_fs_data(pack, client_fs_1, peerstream_fs_1)
state_fs = Constants.STATE.SEND
if client_fs == client_fs_2:
if (state_fs_2 == Constants.STATE.IDLE) or (state_fs_2 == Constants.STATE.DONE):
if command_stack_2:
var pack: Array = command_stack_2.pop_front()
unit_fs_1.send_fs_data(pack, client_fs_2, peerstream_fs_2)
unit_fs.send_fs_data(pack, client_fs_2, peerstream_fs_2)
state_fs_2 = Constants.STATE.SEND
@@ -236,42 +235,53 @@ func disconnect_fs(client_for_leave):
func start_work_fs():
counter_fs_1 = 0
unit_fs_1.start_session(counter_fs_1, client_fs_1)
unit_fs.start_session(counter_fs_1, client_fs_1)
counter_fs_1 += 1
unit_fs_1.get_gen_state(counter_fs_1, client_fs_1)
unit_fs.get_gen_state(counter_fs_1, client_fs_1)
counter_fs_1 += 1
unit_fs_1.get_att_batch(counter_fs_1, client_fs_1)
unit_fs.get_att_batch(counter_fs_1, client_fs_1)
counter_fs_1 += 1
unit_fs_1.get_carrier(counter_fs_1, client_fs_1)
unit_fs.get_carrier(counter_fs_1, client_fs_1)
counter_fs_1 += 1
unit_fs_1.base_get_current_temp(counter_fs_1, client_fs_1)
unit_fs.get_base_current_temp(counter_fs_1, client_fs_1)
counter_fs_1 += 1
unit_fs.get_base_can_macro(counter_fs_1, client_fs_1)
counter_fs_1 += 1
func get_fs_gen_status(state_gen):
unit_fs_1.set_gen_state(state_gen, counter_fs_1, client_fs_1)
unit_fs.set_gen_state(state_gen, counter_fs_1, client_fs_1)
counter_fs_1 += 1
unit_fs_1.get_gen_state(counter_fs_1, client_fs_1)
unit_fs.get_gen_state(counter_fs_1, client_fs_1)
counter_fs_1 += 1
unit_fs_1.base_get_current_temp(counter_fs_1, client_fs_1)
unit_fs.get_base_current_temp(counter_fs_1, client_fs_1)
counter_fs_1 += 1
func set_fs_ferq_carrier(freq: int):
unit_fs_1.set_carrier(freq, counter_fs_1, client_fs_1)
unit_fs.set_carrier(freq, counter_fs_1, client_fs_1)
counter_fs_1 += 1
unit_fs_1.base_get_current_temp(counter_fs_1, client_fs_1)
unit_fs.get_base_current_temp(counter_fs_1, client_fs_1)
counter_fs_1 += 1
unit_fs_1.get_carrier(counter_fs_1, client_fs_1)
unit_fs.get_carrier(counter_fs_1, client_fs_1)
counter_fs_1 += 1
func set_fs_attenuation(attenuation: float):
unit_fs_1.set_att_batch(attenuation, counter_fs_1, client_fs_1)
unit_fs.set_att_batch(attenuation, counter_fs_1, client_fs_1)
counter_fs_1 += 1
unit_fs_1.get_att_batch(counter_fs_1, client_fs_1)
unit_fs.get_att_batch(counter_fs_1, client_fs_1)
counter_fs_1 += 1
unit_fs_1.base_get_current_temp(counter_fs_1, client_fs_1)
unit_fs.get_base_current_temp(counter_fs_1, client_fs_1)
counter_fs_1 += 1
func set_can_macro(can_frequency: int):
unit_fs.set_base_can_macro(can_frequency, counter_fs_1, client_fs_1)
counter_fs_1 += 1
unit_fs.get_base_current_temp(counter_fs_1, client_fs_1)
counter_fs_1 += 1
unit_fs.get_base_can_macro(counter_fs_1, client_fs_1)
counter_fs_1 += 1
@@ -299,39 +309,51 @@ func disconnect_fs_2(client_for_leave):
func start_work_fs_2():
counter_fs_2 = 0
unit_fs_1.start_session(counter_fs_2, client_fs_2)
unit_fs.start_session(counter_fs_2, client_fs_2)
counter_fs_2 += 1
unit_fs_1.get_gen_state(counter_fs_2, client_fs_2)
unit_fs.get_gen_state(counter_fs_2, client_fs_2)
counter_fs_2 += 1
unit_fs_1.get_att_batch(counter_fs_2, client_fs_2)
unit_fs.get_att_batch(counter_fs_2, client_fs_2)
counter_fs_2 += 1
unit_fs_1.get_carrier(counter_fs_2, client_fs_2)
unit_fs.get_carrier(counter_fs_2, client_fs_2)
counter_fs_2 += 1
unit_fs_1.base_get_current_temp(counter_fs_2, client_fs_2)
unit_fs.get_base_current_temp(counter_fs_2, client_fs_2)
counter_fs_2 += 1
#
unit_fs.get_base_can_macro(counter_fs_2, client_fs_2)
counter_fs_2 += 1
func get_fs_gen_status_2(state_gen):
unit_fs_1.set_gen_state(state_gen, counter_fs_2, client_fs_2)
unit_fs.set_gen_state(state_gen, counter_fs_2, client_fs_2)
counter_fs_2 += 1
unit_fs_1.get_gen_state(counter_fs_2, client_fs_2)
unit_fs.get_gen_state(counter_fs_2, client_fs_2)
counter_fs_2 += 1
unit_fs_1.base_get_current_temp(counter_fs_2, client_fs_2)
unit_fs.get_base_current_temp(counter_fs_2, client_fs_2)
counter_fs_2 += 1
func set_fs_ferq_carrier_2(freq: int):
unit_fs_1.set_carrier(freq, counter_fs_2, client_fs_2)
unit_fs.set_carrier(freq, counter_fs_2, client_fs_2)
counter_fs_2 += 1
unit_fs_1.base_get_current_temp(counter_fs_2, client_fs_2)
unit_fs.get_base_current_temp(counter_fs_2, client_fs_2)
counter_fs_2 += 1
unit_fs_1.get_carrier(counter_fs_2, client_fs_2)
unit_fs.get_carrier(counter_fs_2, client_fs_2)
counter_fs_2 += 1
func set_fs_attenuation_2(attenuation: float):
unit_fs_1.set_att_batch(attenuation, counter_fs_2, client_fs_2)
unit_fs.set_att_batch(attenuation, counter_fs_2, client_fs_2)
counter_fs_2 += 1
unit_fs_1.get_att_batch(counter_fs_2, client_fs_2)
unit_fs.get_att_batch(counter_fs_2, client_fs_2)
counter_fs_2 += 1
unit_fs_1.base_get_current_temp(counter_fs_2, client_fs_2)
unit_fs.get_base_current_temp(counter_fs_2, client_fs_2)
counter_fs_2 += 1
func set_can_macro_2(can_frequency: int):
unit_fs.set_base_can_macro(can_frequency, counter_fs_2, client_fs_2)
counter_fs_2 += 1
unit_fs.get_base_current_temp(counter_fs_2, client_fs_2)
counter_fs_2 += 1
unit_fs.get_base_can_macro(counter_fs_2, client_fs_2)
counter_fs_2 += 1