infra: add libs

Reviewed-on: #8

.gitmodules

@@ -0,0 +1,6 @@
+[submodule "libs/rtl_libs"]
+	path = libs/rtl_libs
+	url = https://git.radiophotonics.ru/baulin.fa/rtl_libs.git
+[submodule "libs/verilog-axi"]
+	path = libs/verilog-axi
+	url = https://github.com/alexforencich/verilog-axi.git

designs/reflectometer_base/README.md

@@ -0,0 +1,145 @@
+# Рефлектометр
+
+Модуль представляет собой законченную встраиваемую систему рефлектометра, объединяющую:
+
+- контроллер управления
+- генератор импульсов (DAC path)
+- сэмплер данных (ADC path)
+- аккумулятор и обработчик данных
+
+Система предназначена для формирования импульсов, синхронного сбора отраженного сигнала, накопления результатов и передачи обработанных данных во внешнюю систему.
+
+Данный модуль является полноценным интегрируемым блоком, который может использоваться как самостоятельная аппаратная подсистема внутри более крупного проекта.
+
+---
+
+## Назначение системы
+
+Основная задача системы:
+
+1. Получить параметры измерения через AXI Stream
+2. Сформировать последовательность импульсов на DAC
+3. Выполнить синходную выборку данных с ADC
+4. Накопить и обработать результаты
+5. Передать итоговые данные обратно через AXI Stream
+
+Таким образом реализуется полный цикл измерения без необходимости внешнего управления отдельными блоками.
+
+---
+
+## Состав системы
+
+### Controller
+
+Принимает входные команды по AXI Stream (Ethernet RX), декодирует параметры измерения и управляет всеми внутренними модулями системы.
+
+Формирует:
+
+- запуск генератора (`dac_start`)
+- запуск аккумулятора (`adc_start`)
+- параметры импульсов DAC
+- параметры выборки ADC
+- локальные reset-сигналы
+
+---
+
+### Generator
+
+Формирует последовательность импульсов на DAC с заданными:
+
+- амплитудой
+- длительностью
+- периодом
+- количеством повторений
+
+Для каждого импульса инициирует запуск выборки в сэмплере.
+
+---
+
+### Sampler
+
+Выполняет синхронный сбор данных с ADC по запросу генератора.
+
+Поддерживает:
+
+- фильтрацию `out_of_range`
+- упаковку данных
+- преобразование типа кода ( прямой или дополнительный)
+
+---
+
+### Accumulator
+
+Получает поток данных от сэмплера, выполняет накопление, усреднение и оконную обработку, после чего формирует пакеты для передачи результата.
+
+---
+
+## Управление системой
+
+Пользователь взаимодействует только с контроллером через AXI Stream-интерфейс.
+
+Прямое управление генератором, сэмплером и аккумулятором не требуется.
+
+---
+
+## Clock Domain Crossing (CDC)
+
+Система работает в нескольких тактовых доменах:
+
+- Ethernet RX (`gmii_rx_clk`)
+- Ethernet TX (`gmii_tx_clk`)
+- DAC (`dac_clk`)
+- ADC (`adc_clk`)
+
+Для корректной синхронизации между DAC и ADC используются специальные CDC-регистры для сигналов:
+
+- `sample_req`
+- `sample_done`
+
+Это обеспечивает безопасную передачу handshake-сигналов между тактовыми доменами.
+
+---
+
+## Список параметров
+
+### DAC_DATA_WIDTH
+Ширина выходных данных отправляемых на ЦАП.
+
+### ZERO_LEVEL
+Уровень сигнала в состоянии отсутствия импульса (базовый уровень сигнала).
+
+Типовые значения:
+
+- `8192` — середина диапазона ЦАП
+- `0` — нулевой уровень
+
+### ADC_DATA_WIDTH
+Ширина входных данных, получаемых с АЦП.
+
+### PACK_FACTOR
+Количество отсчетов, собираемых в один выходной пакет.
+
+### PROCESS_MODE
+Режим интерпретации входного кода:
+
+- `0` — прямой код
+- `1` — дополнительный код
+
+### ACCUM_WIDTH 
+Размер данных для аккумуляции, должен быть степенью числа 2. По умолчанию - 32
+
+### N_MAX 
+Максимальное число окон в последовательности. Должно быть степенью числа 2. Влияет на размер используемой памяти.
+
+### WINDOW_SIZE 
+Размер окна усреднения
+
+### PACKET_SIZE 
+Размер выходного пакета
+
+---
+
+## Сборка
+```make all``` - собрать все до битстрима
+
+```make vivado``` - открыть проект в Vivado

rtl/generator/README.md

@@ -0,0 +1,91 @@
+# Генератор
+
+Модуль выполняет задачу формирования последовательности импульсов заданной амплитуды, длительности и периода.  
+Дополнительно реализован механизм синхронизации с модулем сэмплера через сигналы `sample_req` и `sample_done`, позволяющий запускать сбор данных для каждого импульса и ожидать подтверждения завершения выборки перед переходом к следующему импульсу.
+
+---
+
+## Список параметров
+
+### DATA_WIDTH
+Ширина выходных данных генератора.
+
+### ZERO_LEVEL
+Уровень сигнала в состоянии отсутствия импульса (базовый уровень сигнала).
+
+Типовые значения:
+
+- `8192` — середина диапазона ЦАП
+- `0` — нулевой уровень
+
+---
+
+## Список входных портов
+
+### clk_in
+Сигнал тактирования модуля.
+
+### rst
+Сброс модуля и остановка генерации.
+
+### start
+Сигнал запуска последовательности импульсов.
+
+При его активации модуль фиксирует все входные параметры и начинает генерацию.
+
+Повторный запуск во время активной генерации блокируется с помощью внутреннего сигнала `enable`.
+
+### [31:0] pulse_width
+Длительность активной части импульса (в тактах).
+
+### [31:0] pulse_period
+Полный период импульса (в тактах).
+
+### [DATA_WIDTH-1:0] pulse_height
+Амплитуда импульса.
+
+### [15:0] pulse_num
+Количество импульсов, которое необходимо сгенерировать.
+
+### sample_done
+Сигнал подтверждения от сэмплера о завершении выборки данных для текущего импульса.
+
+---
+
+## Список выходных портов
+
+pulse
+Выходной сигнал разрешения записи сигнала 
+
+[DATA_WIDTH-1:0] pulse_height_out
+Выходное значение амплитуды сигнала.
+
+Во время активной части импульса равно `pulse_height`, вне импульса — `ZERO_LEVEL`.
+
+sample_req
+Сигнал запроса на запуск выборки в модуле сэмплера.
+
+Поднимается в начале каждого нового импульса и снимается после получения `sample_done`.
+
+---
+
+## Логика работы
+
+После прихода сигнала `start` модуль:
+
+- фиксирует входные параметры генерации
+- сбрасывает внутренние счетчики
+- поднимает `enable = 1`
+- формирует первый `sample_req`
+
+После этого начинается последовательная генерация импульсов.
+
+---
+
+## Симуляция
+Тесты запускаются автоматически через make.
+```
+cd tests
+make sim
+```
+При успешном завершении теста высвечивается "ALL PASSED".

rtl/generator/tests/generator_tb.sv

@@ -88,11 +88,19 @@ module generator_tb;
         pulse_height = 14'h3FF;
         start = 1;
 
+       repeat(1) @(posedge clk);
+        start = 0;
+        
+        repeat(5) @(posedge clk);
+        start = 1;
+        pulse_height = 14'h155;
+
        repeat(1) @(posedge clk);
         start = 0;
         
         repeat(50) @(posedge clk);
 
+
         $display("\n=== TEST FINISHED ===");
         $finish;
     end

rtl/sampler/README.md

@@ -1,23 +1,139 @@
 # Сэмплер
-Модуль выполняет задачу сбора данных с выхода АЦП, их обработку, упаковку, и передачу дальше с помощью AXI Stream интерфейса.
 
-## Cписок параметров
-DATA_WIDTH - ширина входных данных, получаемых с АЦП.
-PACK_FACTOR - количество отсчетов, собираемых в один выходной пакет.
-PROCESS_MODE - режим интерпретации входного кода. 0 - прямой код, 1 - дополнительный код.
+Модуль выполняет задачу сбора данных с выхода АЦП, их обработки, упаковки и передачи дальше с помощью AXI Stream интерфейса.  
+Дополнительно реализован механизм синхронизации с внешним генератором через сигналы `sample_req` и `sample_done`, позволяющий запускать сбор строго по запросу и подтверждать завершение выборки.
+
+---
+
+## Список параметров
+
+DATA_WIDTH
+Ширина входных данных, получаемых с АЦП.
+
+PACK_FACTOR
+Количество отсчетов, собираемых в один выходной пакет.
+
+PROCESS_MODE
+Режим интерпретации входного кода:
+
+- `0` — прямой код
+- `1` — дополнительный код
+
+---
 
 ## Список входных портов
-clk_in - сигнал тактирования выходного интерфейса.
-rst - сброс модуля и остановка подачи импульсов.
-[DATA_WIDTH-1:0] data_in - входной сигнал с АЦП.
-out_of_range - флаг выхода значений данных за допустимый диапазон. 0 - валидны, 1 - не валидны.
+
+clk_in
+Сигнал тактирования выходного интерфейса.
+
+rst
+Сброс модуля и остановка работы.
+
+[DATA_WIDTH-1:0] data_in
+Входной сигнал с АЦП.
+
+out_of_range
+Флаг выхода значений данных за допустимый диапазон:
+
+- `0` — данные валидны
+- `1` — данные невалидны и игнорируются
+
+[31:0] smp_num
+Количество валидных отсчетов, которое необходимо собрать после получения запроса на выборку.
+
+sample_req
+Сигнал запроса на запуск выборки.  
+При его активации модуль начинает сбор данных и переходит в активное состояние (`enable = 1`).
+
+---
 
 ## Список выходных портов
-[DATA_WIDTH*PACK_FACTOR-1:0]  m_axis_tdata - урезанный axis формат, выходные данные. Ширина шины считается исходя из битности данных и фактора упаковки.
-m_axis_tvalid - урезанный axis формат, валидность выходных данных.
+
+[DATA_WIDTH*PACK_FACTOR-1:0] m_axis_tdata
+Урезанный AXI Stream формат, выходные данные.  
+Ширина шины определяется как произведение битности данных и фактора упаковки.
+
+m_axis_tvalid
+Урезанный AXI Stream формат, сигнал валидности выходных данных.  
+Формируется при готовности очередного пакета.
+
+sample_done
+Сигнал завершения выборки.  
+Поднимается после того, как модуль собрал количество валидных отсчетов, равное `smp_num`.
+
+---
 
 ## Логика работы
-На каждом такте принимаются data_in (значение АЦП) и out_of_range (флаг выхода значений данных за допустимый диапазон). Если out_of_range = 1, то данные игнорируются и не попадают во внутренний буффер. В противном случае, модуль накапливает данные во внутреннем буффере, идет его заполнение до количества данных, равное PACK_FACTOR. Когда буффер оказывается заполненным, он выдает пакет упакованных данных, сопровождая их импульсом m_axis_tvalid (готовность пакета). Если PROCESS_MODE = 1, данные выдаются в дополнительном коде, если PROCESS_MODE = 0 - в прямом.
+
+На каждом такте принимаются:
+
+- `data_in` — значение АЦП
+- `out_of_range` — флаг допустимости значения
+
+Если `out_of_range = 1`, данные считаются невалидными, игнорируются и не попадают во внутренний буфер.
+
+Если `out_of_range = 0`, данные считаются корректными и используются для дальнейшей обработки.
+
+---
+
+### Преобразование данных
+
+Если `PROCESS_MODE = 1`, входные данные интерпретируются как дополнительный код и преобразуются перед упаковкой.
+
+Если `PROCESS_MODE = 0`, данные передаются без преобразования (прямой код).
+
+---
+
+### Запуск выборки
+
+Сбор данных начинается только после прихода сигнала `sample_req`.
+
+При этом:
+
+- фиксируется значение `smp_num`
+- внутренний счетчик собранных отсчетов обнуляется
+- модуль переходит в активное состояние (`enable = 1`)
+
+Пока `enable = 1`, модуль принимает только валидные отсчеты и считает их.
+
+---
+
+### Упаковка данных
+
+Внутренний буфер заполняется до количества данных, равного `PACK_FACTOR`.
+
+#### Если `PACK_FACTOR = 1`
+
+Каждый валидный отсчет сразу формирует выходной пакет:
+
+- данные передаются в `m_axis_tdata`
+- формируется импульс `m_axis_tvalid`
+
+#### Если `PACK_FACTOR > 1`
+
+Данные последовательно накапливаются во внутреннем сдвиговом буфере.
+
+Когда буфер полностью заполнен:
+
+- формируется пакет упакованных данных
+- поднимается `m_axis_tvalid`
+
+После этого начинается сбор следующего пакета.
+
+---
+
+### Завершение выборки
+
+Когда количество собранных валидных отсчетов достигает значения `smp_num`:
+
+- поднимается сигнал `sample_done`
+- внутренние счетчики сбрасываются
+- буфер очищается
+- `enable` сбрасывается в `0`
+
+Это означает полное завершение текущего цикла выборки.
+
+---
 
 ## Симуляция
 Тесты запускаются автоматически через make.

software/gui.py

@@ -1,736 +0,0 @@
-# shitpost
-
-import sys
-import math
-import socket
-import platform
-
-from PyQt6 import uic
-from dataclasses import dataclass
-from PyQt6.QtCore import QProcess, QTimer
-from PyQt6.QtCore import QObject, QThread, pyqtSignal
-
-from PyQt6.QtCore import Qt
-import pyqtgraph as pg
-from PyQt6.QtWidgets import QApplication, QMainWindow
-
-
-@dataclass
-class ReflectometerConfig:
-    ip: str
-    send_port: int
-    recv_port: int
-
-    dac_bits: int
-    data_width: int
-    window_size: int
-    packet_size: int
-
-    pulse_width: int
-    pulse_period: int
-    pulse_height: int
-    pulse_num: int
-
-    adc_dac_ratio: float = 0.52
-    socket_timeout_sec: float = 2.0
-
-
-class ReflectometerWorker(QObject):
-    data_ready = pyqtSignal(list)
-    status = pyqtSignal(str)
-    error = pyqtSignal(str)
-    finished = pyqtSignal()
-
-    def __init__(self, config: ReflectometerConfig):
-        super().__init__()
-        self.config = config
-        self._stop_requested = False
-        self._sock = None
-
-    def stop(self):
-        self._stop_requested = True
-
-        if self._sock is not None:
-            try:
-                self._sock.close()
-            except OSError:
-                pass
-
-    def run(self):
-        try:
-            self._validate_config()
-
-            self.status.emit("Открытие UDP-сокета...")
-
-            self._sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM)
-            self._sock.setsockopt(socket.SOL_SOCKET, socket.SO_REUSEADDR, 1)
-            self._sock.settimeout(self.config.socket_timeout_sec)
-            self._sock.bind(("0.0.0.0", self.config.recv_port))
-
-            dest = (self.config.ip, self.config.send_port)
-
-            self.status.emit("Отправка soft reset...")
-            self._sock.sendto((0x0F00).to_bytes(2, "big"), dest)
-
-            self.status.emit("Отправка параметров...")
-            ctrl_data = self._format_ctrl_data()
-            self._sock.sendto(ctrl_data, dest)
-
-            self.status.emit("Отправка start...")
-            self._sock.sendto((0xF000).to_bytes(2, "big"), dest)
-
-            self.status.emit("Приём данных...")
-            data = self._recv_data()
-
-            if self._stop_requested:
-                self.status.emit("Операция остановлена")
-                return
-
-            self.data_ready.emit(data)
-            self.status.emit(f"Получено samples: {len(data)}")
-
-        except Exception as e:
-            if not self._stop_requested:
-                self.error.emit(str(e))
-
-        finally:
-            if self._sock is not None:
-                try:
-                    self._sock.close()
-                except OSError:
-                    pass
-
-            self.finished.emit()
-
-    def _format_ctrl_data(self) -> bytes:
-        output = bytearray()
-
-        output += 0b10001000.to_bytes(1, "little")
-
-        pulse_period_adc = (
-            int(self.config.pulse_period * self.config.adc_dac_ratio)
-            // self.config.window_size
-        ) * self.config.window_size
-
-        output += self.config.pulse_width.to_bytes(4, "little")
-        output += self.config.pulse_period.to_bytes(4, "little")
-        output += self.config.pulse_num.to_bytes(2, "little")
-        output += self.config.pulse_height.to_bytes(2, "little")
-        output += pulse_period_adc.to_bytes(4, "little")
-
-        if len(output) != 17:
-            raise ValueError("Config data should be 128 bits + 8 bit header")
-
-        return bytes(output)
-
-    def _recv_data(self) -> list[int]:
-        packet_count = math.ceil(
-            (
-                self.config.adc_dac_ratio
-                * self.config.pulse_period
-                / self.config.window_size
-                * self.config.data_width
-            )
-            / self.config.packet_size
-        )
-
-        expected_length = math.ceil(
-            self.config.adc_dac_ratio
-            * self.config.pulse_period
-            / self.config.window_size
-        )
-
-        recv_buf = []
-
-        for pkt_cnt in range(packet_count):
-            if self._stop_requested:
-                break
-
-            try:
-                packet, _ = self._sock.recvfrom(65536)
-            except socket.timeout:
-                raise TimeoutError(f"Таймаут приёма UDP-пакета #{pkt_cnt + 1}")
-
-            if len(packet) % self.config.data_width != 0:
-                raise ValueError(
-                    f"Некорректный размер UDP-пакета: {len(packet)} байт"
-                )
-
-            for i in range(0, len(packet), self.config.data_width):
-                sample = int.from_bytes(
-                    packet[i:i + self.config.data_width],
-                    "little",
-                )
-                recv_buf.append(sample)
-
-        if len(recv_buf) < expected_length:
-            raise ValueError(
-                f"Data underflow: получено {len(recv_buf)}, ожидалось {expected_length}"
-            )
-
-        return recv_buf[:expected_length - 1]
-
-    def _validate_config(self):
-        if self.config.pulse_period <= 0:
-            raise ValueError("pulse_period должен быть больше 0")
-
-        if self.config.pulse_num <= 0:
-            raise ValueError("pulse_num должен быть больше 0")
-
-        if self.config.window_size <= 0:
-            raise ValueError("window_size должен быть больше 0")
-
-        if self.config.packet_size <= 0:
-            raise ValueError("packet_size должен быть больше 0")
-
-        if self.config.data_width <= 0:
-            raise ValueError("data_width должен быть больше 0")
-
-        if self.config.pulse_period % self.config.window_size != 0:
-            raise ValueError("pulse_period должен быть кратен window_size")
-
-        if self.config.pulse_width >= 2**32 - 1:
-            raise ValueError("pulse_width слишком большой")
-
-        if self.config.pulse_period >= 2**32 - 1:
-            raise ValueError("pulse_period слишком большой")
-
-        if self.config.pulse_num >= 2**16 - 1:
-            raise ValueError("pulse_num слишком большой")
-
-        if self.config.pulse_height > 2**self.config.dac_bits - 1:
-            raise ValueError("pulse_height слишком большой")
-
-
-class MainWindow(QMainWindow):
-    def __init__(self):
-        super().__init__()
-
-        uic.loadUi("reflectometer.ui", self)
-
-        self.ping_process = None
-
-        self.ping_timeout_timer = QTimer(self)
-        self.ping_timeout_timer.setSingleShot(True)
-        self.ping_timeout_timer.timeout.connect(self.on_ping_timeout)
-
-        self.button_ping.clicked.connect(self.check_ping)
-
-        # settings
-        self.pulse_period = 0
-        self.pulse_height = 0
-        self.pulse_width = 0
-        self.pulse_num = 0
-
-        self.dac_dw = 14
-        self.adc_dw = 12
-        self.nmax = 4096
-        self.packet_size = 1024
-        self.window_size = 65
-        self.adc_dac_ration = 0.52
-        self.accum_width = 32
-
-        # setup
-
-        self.setup_pulse_controls()
-        self.setup_global_settings()
-
-        self.update_pulse_limits()
-
-        self.data = []
-
-        self.adc_dac_ratio = 0.52
-
-        self.measurement_thread = None
-        self.measurement_worker = None
-
-        self.setup_graph()
-        self.setup_network_settings()
-
-        self.button_start.clicked.connect(self.run_measurement)
-        self.button_graph_autoscale.clicked.connect(self.reset_graph_autoscale)
-
-    # ping utils
-
-    def check_ping(self):
-        ip = self.line_ip.text().strip()
-
-        if not ip:
-            self.label_ping_status.setText("set ip!!")
-            return
-
-        if "_" in self.line_ip.displayText():
-            self.label_ping_status.setText("IP invalid")
-            return
-
-        if self.ping_process is not None:
-            if self.ping_process.state() != QProcess.ProcessState.NotRunning:
-                self.label_ping_status.setText("Ping inflight")
-                return
-
-        self.label_ping_status.setText("ping...")
-        self.button_ping.setEnabled(False)
-
-        self.ping_process = QProcess(self)
-
-        self.ping_process.finished.connect(self.on_ping_finished)
-        self.ping_process.errorOccurred.connect(self.on_ping_error)
-
-        system_name = platform.system().lower()
-
-        if system_name == "windows":
-            program = "ping"
-            arguments = ["-n", "1", "-w", "2000", ip]
-        else:
-            program = "ping"
-            arguments = ["-c", "1", "-W", "2", ip]
-
-        self.ping_process.start(program, arguments)
-        # fallback
-        self.ping_timeout_timer.start(2000)
-
-    def on_ping_finished(self, exit_code, exit_status):
-        self.ping_timeout_timer.stop()
-        self.button_ping.setEnabled(True)
-
-        if exit_code == 0:
-            self.label_ping_status.setText("алё✅")
-        else:
-            self.label_ping_status.setText("не алё❌")
-
-    def on_ping_error(self):
-        self.ping_timeout_timer.stop()
-        self.button_ping.setEnabled(True)
-        self.label_ping_status.setText("ping unavail")
-
-    def on_ping_timeout(self):
-        if self.ping_process is not None:
-            if self.ping_process.state() != QProcess.ProcessState.NotRunning:
-                self.ping_process.kill()
-
-        self.button_ping.setEnabled(True)
-
-    # pulse controls
-    def setup_pulse_controls(self):
-        self._bind_slider_and_spinbox(
-            name="pulse_period",
-            slider=self.slider_pulse_period,
-            box=self.box_pulse_period,
-            normalize_value=self.normalize_pulse_period,
-        )
-
-        self._bind_slider_and_spinbox(
-            name="pulse_height",
-            slider=self.slider_pulse_height,
-            box=self.box_pulse_height,
-        )
-
-        self._bind_slider_and_spinbox(
-            name="pulse_width",
-            slider=self.slider_pulse_width,
-            box=self.box_pulse_width,
-        )
-
-        self._bind_slider_and_spinbox(
-            name="pulse_num",
-            slider=self.slider_pulse_num,
-            box=self.box_pulse_num,
-        )
-
-    def _bind_slider_and_spinbox(self, name, slider, box, normalize_value=None):
-        """
-        Связывает QSlider и QSpinBox по значению.
-        Значение автоматически записывается в self.<name>.
-        """
-
-        minimum = min(slider.minimum(), box.minimum())
-        maximum = max(slider.maximum(), box.maximum())
-
-        slider.setRange(minimum, maximum)
-        box.setRange(minimum, maximum)
-
-        def normalize(value):
-            if normalize_value is None:
-                return value
-
-            return normalize_value(value)
-
-        value = normalize(box.value())
-
-        slider.setValue(value)
-        box.setValue(value)
-        setattr(self, name, value)
-
-        def update_value(new_value):
-            new_value = normalize(new_value)
-
-            if slider.value() != new_value:
-                slider.setValue(new_value)
-
-            if box.value() != new_value:
-                box.setValue(new_value)
-
-            setattr(self, name, new_value)
-
-        slider.valueChanged.connect(update_value)
-        box.valueChanged.connect(update_value)
-
-    def normalize_pulse_period(self, value):
-        step = max(1, getattr(self, "window_size",
-                   self.box_window_size.value()))
-
-        snapped_value = round(value / step) * step
-
-        minimum = self.box_pulse_period.minimum()
-        maximum = self.box_pulse_period.maximum()
-
-        return max(minimum, min(snapped_value, maximum))
-
-    def _set_max_for_pair(self, slider, box, maximum):
-        slider.setMaximum(maximum)
-        box.setMaximum(maximum)
-
-        value = min(box.value(), maximum)
-        box.setValue(value)
-        slider.setValue(value)
-
-    def set_max_pulse_period(self, maximum):
-        self._set_max_for_pair(
-            slider=self.slider_pulse_period,
-            box=self.box_pulse_period,
-            maximum=maximum,
-        )
-        self.pulse_period = self.box_pulse_period.value()
-
-    def set_max_pulse_height(self, maximum):
-        self._set_max_for_pair(
-            slider=self.slider_pulse_height,
-            box=self.box_pulse_height,
-            maximum=maximum,
-        )
-        self.pulse_height = self.box_pulse_height.value()
-
-    def set_max_pulse_width(self, maximum):
-        self._set_max_for_pair(
-            slider=self.slider_pulse_width,
-            box=self.box_pulse_width,
-            maximum=maximum,
-        )
-        self.pulse_width = self.box_pulse_width.value()
-
-    def set_max_pulse_num(self, maximum):
-        self._set_max_for_pair(
-            slider=self.slider_pulse_num,
-            box=self.box_pulse_num,
-            maximum=maximum,
-        )
-        self.pulse_num = self.box_pulse_num.value()
-
-    # settings
-
-    def setup_global_settings(self):
-        self._bind_spinbox_setting(
-            name="dac_dw",
-            box=self.box_dac_dw,
-        )
-
-        self._bind_spinbox_setting(
-            name="adc_dw",
-            box=self.box_adc_dw,
-        )
-
-        self._bind_spinbox_setting(
-            name="nmax",
-            box=self.box_nmax,
-        )
-
-        self._bind_spinbox_setting(
-            name="window_size",
-            box=self.box_window_size,
-            after_change=self.on_window_size_changed,
-        )
-
-        self._bind_spinbox_setting(
-            name="packet_size",
-            box=self.box_packet_size,
-        )
-
-        self._bind_spinbox_setting(
-            name="adc_dac_ratio",
-            box=self.box_adc_dac_ratio,
-        )
-
-        self._bind_spinbox_setting(
-            name="accum_width",
-            box=self.box_accum_width,
-        )
-
-        self._bind_spinbox_setting(
-            name="recv_port",
-            box=self.box_recv_port,
-        )
-
-        self._bind_spinbox_setting(
-            name="send_port",
-            box=self.box_send_port,
-        )
-
-        # применяем шаг для pulse_period сразу при старте
-        self.update_pulse_period_step()
-
-    def _bind_spinbox_setting(self, name, box, after_change=None):
-        """
-        Связывает QSpinBox с полем self.<name>.
-        Например:
-        box_dac_dw -> self.dac_dw
-        box_window_size -> self.window_size
-        """
-
-        value = box.value()
-        setattr(self, name, value)
-
-        def on_value_changed(new_value):
-            setattr(self, name, new_value)
-
-            self.update_pulse_limits()
-
-            if after_change is not None:
-                after_change(new_value)
-
-        box.valueChanged.connect(on_value_changed)
-
-    def update_pulse_limits(self):
-        # re-calc limits
-
-        # nmax -> pulse_period limit
-        self.set_max_pulse_period(self.nmax * self.window_size)
-        self.set_max_pulse_width(self.nmax * self.window_size)
-        # accum_width + adc_width -> max pulse num
-
-        self.set_max_pulse_num(
-            2 ** (self.accum_width - self.adc_dw - math.ceil(math.log2(self.window_size))) - 1)
-        # dac_width -> max pulse height
-        self.set_max_pulse_height(2 ** self.dac_dw - 1)
-
-        self.slider_pulse_period.setMinimum(self.window_size)
-        self.box_pulse_period.setMinimum(self.window_size)
-
-    def on_window_size_changed(self, new_value):
-        self.update_pulse_period_step()
-
-    def update_pulse_period_step(self):
-        # set window_size step
-
-        step = max(1, self.window_size)
-
-        self.box_pulse_period.setSingleStep(step)
-        self.slider_pulse_period.setSingleStep(step)
-        self.slider_pulse_period.setPageStep(step)
-
-        self.snap_pulse_period_to_step(step)
-
-    def snap_pulse_period_to_step(self, step):
-        """
-        Подгоняет текущее значение pulse_period к ближайшему кратному window_size.
-
-        Это нужно потому, что QSlider при перетаскивании мышкой
-        всё равно может дать любое промежуточное значение.
-        """
-
-        current_value = self.box_pulse_period.value()
-
-        snapped_value = round(current_value / step) * step
-
-        minimum = self.box_pulse_period.minimum()
-        maximum = self.box_pulse_period.maximum()
-
-        snapped_value = max(minimum, min(snapped_value, maximum))
-
-        self.box_pulse_period.setValue(snapped_value)
-        self.slider_pulse_period.setValue(snapped_value)
-        self.pulse_period = snapped_value
-
-    # graph
-    def setup_graph(self):
-        self.graph_widget = pg.PlotWidget()
-        self.graph_widget.setLabel("left", "ADC value")
-        self.graph_widget.setLabel("bottom", "Sample")
-        self.graph_widget.showGrid(x=True, y=True)
-
-        self.graph_curve = self.graph_widget.plot(
-            [],
-            name="Data",
-        )
-
-        self.reference_curve = self.graph_widget.plot(
-            [],
-            name="Reference",
-        )
-
-        self.graph_layout.addWidget(self.graph_widget)
-        self.graph_curve = self.graph_widget.plot(
-            [], pen=pg.mkPen(width=2, color="b"))
-        self.reference_curve = self.graph_widget.plot(
-            [], pen=pg.mkPen(style=Qt.PenStyle.DashLine, color="g"))
-
-        self.checkbox_draw_reference.stateChanged.connect(
-            self.update_reference_graph)
-
-    def setup_network_settings(self):
-        self._bind_spinbox_setting(
-            name="recv_port",
-            box=self.box_recv_port,
-        )
-
-        self._bind_spinbox_setting(
-            name="send_port",
-            box=self.box_send_port,
-        )
-
-    def run_measurement(self):
-        if self.measurement_thread is not None:
-            if self.measurement_thread.isRunning():
-                self.set_measurement_status("Измерение выполняется")
-                return
-
-        config = self.build_reflectometer_config()
-
-        self.data = []
-        self.graph_curve.setData([])
-
-        self.measurement_thread = QThread(self)
-        self.measurement_worker = ReflectometerWorker(config)
-
-        self.measurement_worker.moveToThread(self.measurement_thread)
-
-        self.measurement_thread.started.connect(self.measurement_worker.run)
-
-        self.measurement_worker.status.connect(self.set_measurement_status)
-        self.measurement_worker.error.connect(self.on_measurement_error)
-        self.measurement_worker.data_ready.connect(self.on_data_received)
-
-        self.measurement_worker.finished.connect(self.measurement_thread.quit)
-        self.measurement_worker.finished.connect(
-            self.measurement_worker.deleteLater)
-
-        self.measurement_thread.finished.connect(
-            self.measurement_thread.deleteLater)
-        self.measurement_thread.finished.connect(self.on_measurement_finished)
-
-        self.measurement_thread.start()
-
-    def build_reflectometer_config(self) -> ReflectometerConfig:
-        ip = self.line_ip.text().strip()
-
-        if not ip:
-            raise ValueError("IP адрес не задан")
-
-        data_width = self.accum_width // 8
-
-        return ReflectometerConfig(
-            ip=ip,
-            send_port=self.send_port,
-            recv_port=self.recv_port,
-
-            dac_bits=self.dac_dw,
-            data_width=data_width,
-            window_size=self.window_size,
-            packet_size=self.packet_size,
-
-            pulse_width=self.pulse_width,
-            pulse_period=self.pulse_period,
-            pulse_height=self.pulse_height,
-            pulse_num=self.pulse_num,
-
-            adc_dac_ratio=self.adc_dac_ratio,
-        )
-
-    def on_data_received(self, data: list[int]):
-        self.data = data
-        # normalize
-        for i in range(len(data)):
-            self.data[i] /= (self.window_size * self.pulse_num)
-            self.data[i] -= 2 ** (self.adc_dw - 1) + 1
-
-        self.draw_main_graph()
-        self.update_reference_graph()
-
-        if data:
-            self.set_measurement_status(
-                f"Готово. smp: {len(data)}, min: {min(data)}, max: {max(data)}"
-            )
-        else:
-            self.set_measurement_status("Данные пустые")
-
-    def on_measurement_error(self, message: str):
-        self.set_measurement_status(f"Ошибка: {message}")
-
-    def on_measurement_finished(self):
-        self.measurement_worker = None
-        self.measurement_thread = None
-
-    def stop_measurement(self):
-        if self.measurement_worker is not None:
-            self.measurement_worker.stop()
-
-    def set_measurement_status(self, text: str):
-        self.label_status.setText(text)
-
-    def draw_main_graph(self):
-        if not self.data:
-            self.graph_curve.setData([])
-            return
-
-        x = list(range(len(self.data)))
-        self.graph_curve.setData(x, self.data)
-
-    def update_reference_graph(self):
-        """
-        Рисует или очищает эталонный график.
-        Вызывается после получения данных и при переключении checkbox_draw_reference.
-        """
-
-        if not self.checkbox_draw_reference.isChecked():
-            self.reference_curve.setData([])
-            return
-
-        if not self.data:
-            self.reference_curve.setData([])
-            return
-
-        reference_data = self.build_reference_data(len(self.data))
-
-        if not reference_data:
-            self.reference_curve.setData([])
-            return
-
-        x = list(range(len(reference_data)))
-        self.reference_curve.setData(x, reference_data)
-
-    def build_reference_data(self, length: int) -> list[int]:
-        reference = [0] * length
-
-        actual_pulse_width = round(
-            (self.pulse_width * self.adc_dac_ratio) / self.window_size)
-
-        reference[0:actual_pulse_width] = [
-            (self.pulse_height / 2 ** (self.dac_dw - self.adc_dw)) - 2 ** (self.adc_dw - 1), ] * (actual_pulse_width - 1)
-
-        return reference
-
-    def reset_graph_autoscale(self):
-        self.graph_widget.enableAutoRange(axis="xy", enable=True)
-        self.graph_widget.autoRange()
-
-
-def main():
-    app = QApplication(sys.argv)
-
-    window = MainWindow()
-    window.show()
-
-    sys.exit(app.exec())
-
-
-if __name__ == "__main__":
-    main()

software/reflectometer.ui

@@ -1,505 +0,0 @@
-<?xml version="1.0" encoding="UTF-8"?>
-<ui version="4.0">
- <class>MainWindow</class>
- <widget class="QMainWindow" name="MainWindow">
-  <property name="geometry">
-   <rect>
-    <x>0</x>
-    <y>0</y>
-    <width>1023</width>
-    <height>708</height>
-   </rect>
-  </property>
-  <property name="windowTitle">
-   <string>Reflectometer PREMIUM</string>
-  </property>
-  <widget class="QWidget" name="centralwidget">
-   <layout class="QHBoxLayout" name="horizontalLayout" stretch="4,2">
-    <item>
-     <layout class="QVBoxLayout" name="graph_layout"/>
-    </item>
-    <item>
-     <layout class="QVBoxLayout" name="settings_layout">
-      <item>
-       <widget class="QTabWidget" name="tabWidget">
-        <property name="currentIndex">
-         <number>1</number>
-        </property>
-        <widget class="QWidget" name="tab">
-         <attribute name="title">
-          <string>Настройки</string>
-         </attribute>
-         <layout class="QVBoxLayout" name="verticalLayout_2">
-          <item>
-           <widget class="QScrollArea" name="scrollArea">
-            <property name="widgetResizable">
-             <bool>true</bool>
-            </property>
-            <widget class="QWidget" name="scrollAreaWidgetContents">
-             <property name="geometry">
-              <rect>
-               <x>0</x>
-               <y>0</y>
-               <width>294</width>
-               <height>621</height>
-              </rect>
-             </property>
-             <layout class="QVBoxLayout" name="verticalLayout">
-              <item>
-               <widget class="QLabel" name="label_2">
-                <property name="font">
-                 <font>
-                  <pointsize>12</pointsize>
-                 </font>
-                </property>
-                <property name="text">
-                 <string>Аппаратные параметры</string>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QSpinBox" name="box_dac_dw">
-                <property name="suffix">
-                 <string> bits</string>
-                </property>
-                <property name="prefix">
-                 <string>DAC data width: </string>
-                </property>
-                <property name="minimum">
-                 <number>8</number>
-                </property>
-                <property name="maximum">
-                 <number>32</number>
-                </property>
-                <property name="value">
-                 <number>14</number>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QSpinBox" name="box_adc_dw">
-                <property name="suffix">
-                 <string> bits</string>
-                </property>
-                <property name="prefix">
-                 <string>ADC data width: </string>
-                </property>
-                <property name="minimum">
-                 <number>8</number>
-                </property>
-                <property name="maximum">
-                 <number>32</number>
-                </property>
-                <property name="value">
-                 <number>12</number>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QSpinBox" name="box_accum_width">
-                <property name="suffix">
-                 <string> bits</string>
-                </property>
-                <property name="prefix">
-                 <string>Accum width: </string>
-                </property>
-                <property name="minimum">
-                 <number>16</number>
-                </property>
-                <property name="maximum">
-                 <number>64</number>
-                </property>
-                <property name="singleStep">
-                 <number>8</number>
-                </property>
-                <property name="value">
-                 <number>32</number>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QDoubleSpinBox" name="box_adc_dac_ratio">
-                <property name="prefix">
-                 <string>ADC:DAC clk ratio: </string>
-                </property>
-                <property name="minimum">
-                 <double>0.200000000000000</double>
-                </property>
-                <property name="maximum">
-                 <double>3.000000000000000</double>
-                </property>
-                <property name="singleStep">
-                 <double>0.010000000000000</double>
-                </property>
-                <property name="value">
-                 <double>0.520000000000000</double>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QSpinBox" name="box_nmax">
-                <property name="prefix">
-                 <string>N Max: </string>
-                </property>
-                <property name="minimum">
-                 <number>512</number>
-                </property>
-                <property name="maximum">
-                 <number>65536</number>
-                </property>
-                <property name="value">
-                 <number>4096</number>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QSpinBox" name="box_window_size">
-                <property name="prefix">
-                 <string>Window size: </string>
-                </property>
-                <property name="minimum">
-                 <number>1</number>
-                </property>
-                <property name="maximum">
-                 <number>1024</number>
-                </property>
-                <property name="value">
-                 <number>65</number>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QSpinBox" name="box_packet_size">
-                <property name="suffix">
-                 <string> bytes</string>
-                </property>
-                <property name="prefix">
-                 <string>Packet size: </string>
-                </property>
-                <property name="minimum">
-                 <number>1</number>
-                </property>
-                <property name="maximum">
-                 <number>1572</number>
-                </property>
-                <property name="value">
-                 <number>1024</number>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="Line" name="line_2">
-                <property name="orientation">
-                 <enum>Qt::Orientation::Horizontal</enum>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QLabel" name="label">
-                <property name="font">
-                 <font>
-                  <pointsize>12</pointsize>
-                 </font>
-                </property>
-                <property name="text">
-                 <string>Подключение</string>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QLabel" name="label_3">
-                <property name="text">
-                 <string>IP устройства:</string>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QLineEdit" name="line_ip">
-                <property name="inputMask">
-                 <string>999.999.999.999</string>
-                </property>
-                <property name="text">
-                 <string>192.168.0.2</string>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QLabel" name="label_4">
-                <property name="text">
-                 <string>Порт отправки:</string>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QSpinBox" name="box_send_port">
-                <property name="minimum">
-                 <number>80</number>
-                </property>
-                <property name="maximum">
-                 <number>65536</number>
-                </property>
-                <property name="value">
-                 <number>8080</number>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QLabel" name="label_5">
-                <property name="text">
-                 <string>Порт приёма:</string>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QSpinBox" name="box_recv_port">
-                <property name="minimum">
-                 <number>80</number>
-                </property>
-                <property name="maximum">
-                 <number>65536</number>
-                </property>
-                <property name="value">
-                 <number>8080</number>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QLabel" name="label_6">
-                <property name="font">
-                 <font>
-                  <pointsize>12</pointsize>
-                 </font>
-                </property>
-                <property name="text">
-                 <string>Тест</string>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QPushButton" name="button_ping">
-                <property name="text">
-                 <string>алё</string>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <widget class="QLabel" name="label_ping_status">
-                <property name="text">
-                 <string>...</string>
-                </property>
-                <property name="alignment">
-                 <set>Qt::AlignmentFlag::AlignCenter</set>
-                </property>
-               </widget>
-              </item>
-              <item>
-               <spacer name="verticalSpacer">
-                <property name="orientation">
-                 <enum>Qt::Orientation::Vertical</enum>
-                </property>
-                <property name="sizeHint" stdset="0">
-                 <size>
-                  <width>20</width>
-                  <height>40</height>
-                 </size>
-                </property>
-               </spacer>
-              </item>
-             </layout>
-            </widget>
-           </widget>
-          </item>
-         </layout>
-        </widget>
-        <widget class="QWidget" name="tab_2">
-         <attribute name="title">
-          <string>Управление</string>
-         </attribute>
-         <layout class="QVBoxLayout" name="verticalLayout_3">
-          <item>
-           <widget class="QLabel" name="label_7">
-            <property name="font">
-             <font>
-              <pointsize>12</pointsize>
-             </font>
-            </property>
-            <property name="text">
-             <string>Импульс</string>
-            </property>
-           </widget>
-          </item>
-          <item>
-           <layout class="QHBoxLayout" name="horizontalLayout_2" stretch="1,1,2">
-            <item>
-             <widget class="QLabel" name="label_8">
-              <property name="text">
-               <string>Период</string>
-              </property>
-             </widget>
-            </item>
-            <item>
-             <widget class="QSpinBox" name="box_pulse_period">
-              <property name="minimum">
-               <number>1</number>
-              </property>
-             </widget>
-            </item>
-            <item>
-             <widget class="QSlider" name="slider_pulse_period">
-              <property name="orientation">
-               <enum>Qt::Orientation::Horizontal</enum>
-              </property>
-             </widget>
-            </item>
-           </layout>
-          </item>
-          <item>
-           <layout class="QHBoxLayout" name="horizontalLayout_3" stretch="1,1,2">
-            <item>
-             <widget class="QLabel" name="label_9">
-              <property name="text">
-               <string>Ширина</string>
-              </property>
-             </widget>
-            </item>
-            <item>
-             <widget class="QSpinBox" name="box_pulse_width"/>
-            </item>
-            <item>
-             <widget class="QSlider" name="slider_pulse_width">
-              <property name="orientation">
-               <enum>Qt::Orientation::Horizontal</enum>
-              </property>
-             </widget>
-            </item>
-           </layout>
-          </item>
-          <item>
-           <layout class="QHBoxLayout" name="horizontalLayout_4" stretch="1,1,2">
-            <item>
-             <widget class="QLabel" name="label_10">
-              <property name="text">
-               <string>Высота</string>
-              </property>
-             </widget>
-            </item>
-            <item>
-             <widget class="QSpinBox" name="box_pulse_height"/>
-            </item>
-            <item>
-             <widget class="QSlider" name="slider_pulse_height">
-              <property name="orientation">
-               <enum>Qt::Orientation::Horizontal</enum>
-              </property>
-             </widget>
-            </item>
-           </layout>
-          </item>
-          <item>
-           <layout class="QHBoxLayout" name="horizontalLayout_5" stretch="1,1,2">
-            <item>
-             <widget class="QLabel" name="label_11">
-              <property name="text">
-               <string>Количество</string>
-              </property>
-             </widget>
-            </item>
-            <item>
-             <widget class="QSpinBox" name="box_pulse_num">
-              <property name="minimum">
-               <number>1</number>
-              </property>
-             </widget>
-            </item>
-            <item>
-             <widget class="QSlider" name="slider_pulse_num">
-              <property name="minimum">
-               <number>1</number>
-              </property>
-              <property name="orientation">
-               <enum>Qt::Orientation::Horizontal</enum>
-              </property>
-             </widget>
-            </item>
-           </layout>
-          </item>
-          <item>
-           <widget class="QPushButton" name="button_start">
-            <property name="text">
-             <string>start!</string>
-            </property>
-           </widget>
-          </item>
-          <item>
-           <layout class="QHBoxLayout" name="horizontalLayout_6" stretch="1,3">
-            <item>
-             <widget class="QLabel" name="label_13">
-              <property name="font">
-               <font>
-                <bold>true</bold>
-               </font>
-              </property>
-              <property name="text">
-               <string>Статус:</string>
-              </property>
-             </widget>
-            </item>
-            <item>
-             <widget class="QLabel" name="label_status">
-              <property name="text">
-               <string>-</string>
-              </property>
-             </widget>
-            </item>
-           </layout>
-          </item>
-          <item>
-           <widget class="QCheckBox" name="checkbox_draw_reference">
-            <property name="text">
-             <string>Отрисовка эталона</string>
-            </property>
-           </widget>
-          </item>
-          <item>
-           <spacer name="verticalSpacer_2">
-            <property name="orientation">
-             <enum>Qt::Orientation::Vertical</enum>
-            </property>
-            <property name="sizeHint" stdset="0">
-             <size>
-              <width>20</width>
-              <height>40</height>
-             </size>
-            </property>
-           </spacer>
-          </item>
-          <item>
-           <widget class="QPushButton" name="button_graph_autoscale">
-            <property name="text">
-             <string>Сброс масштаба</string>
-            </property>
-           </widget>
-          </item>
-         </layout>
-        </widget>
-       </widget>
-      </item>
-     </layout>
-    </item>
-   </layout>
-  </widget>
-  <widget class="QMenuBar" name="menubar">
-   <property name="geometry">
-    <rect>
-     <x>0</x>
-     <y>0</y>
-     <width>1023</width>
-     <height>30</height>
-    </rect>
-   </property>
-  </widget>
-  <widget class="QStatusBar" name="statusbar"/>
- </widget>
- <resources/>
- <connections/>
-</ui>