hotfix(analyzer): sync IR Fox RX terminal behavior

Анализатор IR_Fox: классификатор пакетов, настройки/результаты, тесты + перечень изменений протокола

.gitignore

@@ -11,3 +11,5 @@ Analyzer/raw/dll/*.dylib
 /Analyzer/raw/IR_Fox/.github
 **/.build
 graphify-out/*
+**/.build-*/
+/tests/*.exe

Analyzer/raw/IR_Fox/CMakeLists.txt

@@ -15,6 +15,7 @@ set(SOURCES
 	src/IrFoxAnalyzer.h
 	src/IrFoxDecoder.cpp
 	src/IrFoxDecoder.h
+	src/IrFoxPacketClassifier.h
 	src/IrFoxAnalyzerResults.cpp
 	src/IrFoxAnalyzerResults.h
 	src/IrFoxAnalyzerSettings.cpp
@@ -24,3 +25,23 @@ set(SOURCES
 )
 
 add_analyzer_plugin(${PROJECT_NAME} SOURCES ${SOURCES})
+
+if(MSVC)
+	target_compile_options(${PROJECT_NAME} PRIVATE /utf-8)
+endif()
+
+include(CTest)
+if(BUILD_TESTING)
+	add_executable(IrFoxPacketClassifierTests tests/IrFoxPacketClassifierTests.cpp)
+	target_include_directories(IrFoxPacketClassifierTests PRIVATE src)
+	add_test(NAME IrFoxPacketClassifierTests COMMAND IrFoxPacketClassifierTests)
+
+	add_executable(IrFoxDecoderTests tests/IrFoxDecoderTests.cpp src/IrFoxDecoder.cpp)
+	target_include_directories(IrFoxDecoderTests PRIVATE src)
+	target_link_libraries(IrFoxDecoderTests PRIVATE Saleae::AnalyzerSDK)
+	add_custom_command(TARGET IrFoxDecoderTests POST_BUILD
+		COMMAND ${CMAKE_COMMAND} -E copy_if_different
+			$<TARGET_FILE:Saleae::AnalyzerSDK>
+			$<TARGET_FILE_DIR:IrFoxDecoderTests>)
+	add_test(NAME IrFoxDecoderTests COMMAND IrFoxDecoderTests)
+endif()

Analyzer/raw/IR_Fox/src/IrFoxAnalyzer.cpp

@@ -1,6 +1,7 @@
 #include "IrFoxAnalyzer.h"
 #include "IrFoxAnalyzerSettings.h"
 #include "IrFoxDecoder.h"
+#include "IrFoxPacketClassifier.h"
 #include <AnalyzerChannelData.h>
 #include <AnalyzerResults.h>
 #include <algorithm>
@@ -25,7 +26,6 @@ IrFoxAnalyzer::~IrFoxAnalyzer()
 
 void IrFoxAnalyzer::SetupResults()
 {
-	m_packet_hex_by_frame.clear();
 	mResults.reset(new IrFoxAnalyzerResults(this, &mSettings));
 	SetAnalyzerResults(mResults.get());
 	mResults->AddChannelBubblesWillAppearOn(mSettings.mInputChannel);
@@ -46,35 +46,91 @@ static void append_hex(std::string& s, const uint8_t* p, size_t n, size_t max_by
 		s += "...";
 }
 
-const char* IrFoxAnalyzer::PacketHexForFrame(U64 frame_id)
+static const char* packet_status_icon(IrFoxPacketOutcome outcome)
 {
-	auto it = m_packet_hex_by_frame.find(frame_id);
+	switch (outcome)
-	if (it == m_packet_hex_by_frame.end())
+	{
-		return "";
+	case IrFoxPacketOutcome::Accepted:
-	m_hex_scratch = it->second;
+		return "✅";
-	return m_hex_scratch.c_str();
+	case IrFoxPacketOutcome::IgnoredAddress:
+		return "📭";
+	case IrFoxPacketOutcome::RejectedCrc:
+	case IrFoxPacketOutcome::RejectedLength:
+		return "❌";
+	case IrFoxPacketOutcome::RawOnlyUnknownType:
+	case IrFoxPacketOutcome::RawOnlyTypedLength:
+		return "⚠️";
+	}
+	return "⚠️";
 }
 
-const char* IrFoxAnalyzer::BubbleTextForFrame(U64 frame_id) const
+static const char* message_type_icon(uint8_t message_type)
 {
-	auto it = m_bubble_text_by_frame.find(frame_id);
+	switch (message_type)
-	if (it == m_bubble_text_by_frame.end())
+	{
+	case irfox::kMsgBack:
+		return "🔙";
+	case irfox::kMsgAccept:
+		return "🤝";
+	case irfox::kMsgRequest:
+		return "📣";
+	case irfox::kMsgBackTo:
+		return "🎯";
+	case irfox::kMsgDataNoAccept:
+		return "📦";
+	case irfox::kMsgDataAccept:
+		return "📨";
+	default:
+		return "⚠️";
+	}
+}
+
+static const char* terminal_abort_cause_text(IrFoxAbortCause cause)
+{
+	switch (cause)
+	{
+	case IrFoxAbortCause::BadSync:
+		return "SYNC";
+	case IrFoxAbortCause::BadLength:
+		return "LEN";
+	case IrFoxAbortCause::Overflow:
+		return "OVF";
+	case IrFoxAbortCause::None:
+	default:
 		return "";
-	m_bubble_scratch = it->second;
+	}
-	return m_bubble_scratch.c_str();
+}
+
+static std::string packet_icon(const IrFoxPacketDecision& decision, IrFoxPacketIconMode mode)
+{
+	const char* status = packet_status_icon(decision.outcome);
+	// Icon-mode selection describes successfully accepted packets. Diagnostic
+	// outcomes must remain visible even when the user selected type-only mode.
+	if (decision.outcome != IrFoxPacketOutcome::Accepted)
+		return status;
+	const char* type = message_type_icon(decision.message_type);
+	switch (mode)
+	{
+	case IrFoxPacketIconMode::Status:
+		return status;
+	case IrFoxPacketIconMode::MessageType:
+		return type;
+	case IrFoxPacketIconMode::StatusAndType:
+	default:
+		return std::string(status) + type;
+	}
 }
 
 void IrFoxAnalyzer::WorkerThread()
 {
 	mIr = GetAnalyzerChannelData(mSettings.mInputChannel);
-	m_packet_hex_by_frame.clear();
+	mResults->ClearCachedFrameText();
-	m_bubble_text_by_frame.clear();
 
 	const U32 fs = GetSampleRate();
 	IrFoxDecoder decoder;
 	decoder.reset();
 
-	/** Потоковый фильтр: убирает импульсы короче kMinFilteredPulseUs (иголки/дребезг в сэмплах). */
+	/** Mirrors the firmware input filter. kMinFilteredPulseUs=0 means direct edge delivery. */
 	const U64 min_seg_samples =
 		std::max<U64>(1ULL, static_cast<U64>((static_cast<double>(irfox::kMinFilteredPulseUs) * 1e-6) * static_cast<double>(fs) + 0.5));
 	struct RawEdge
@@ -115,8 +171,19 @@ void IrFoxAnalyzer::WorkerThread()
 
 	U32 frames_since_commit = 0;
 	const U32 kCommitBatch = 256;
+	const bool detailed_presentation = mSettings.mPresentation == IrFoxPresentation::Detailed;
+	std::vector<IrFoxEmitBit> pending_byte_frames;
+	pending_byte_frames.reserve(irfox::kDataByteSizeMax);
 
-	IrFoxOnBit on_bit = [&](const IrFoxEmitBit& e) {
+	auto note_legacy_frame = [&]() {
+		if (++frames_since_commit >= kCommitBatch)
+		{
+			mResults->CommitResults();
+			frames_since_commit = 0;
+		}
+	};
+
+	auto add_event_frame = [&](const IrFoxEmitBit& e) {
 		Frame frame;
 		frame.mStartingSampleInclusive = static_cast<S64>(e.start_sample);
 		frame.mEndingSampleInclusive = static_cast<S64>(e.end_sample);
@@ -124,45 +191,255 @@ void IrFoxAnalyzer::WorkerThread()
 		frame.mData1 = e.bit_value;
 		frame.mData2 = e.bit_index | (U64(e.err_low) << 16) | (U64(e.err_high) << 24) | (U64(e.err_other) << 32);
 		frame.mFlags = e.mflags;
-		// В SDK только ERROR/WARNING меняют цвет бабла; sync выделяем янтарным (как warning), данные — обычные.
+		mResults->AddFrame(frame);
-		if (e.frame_type == IRF_FT_SYNC_BIT)
+		note_legacy_frame();
-			frame.mFlags |= DISPLAY_AS_WARNING_FLAG;
+	};
 
-		const U64 fid = mResults->AddFrame(frame);
+	auto flush_pending_bytes = [&]() {
-		if (e.bubble_text[0] != '\0')
+		for (const IrFoxEmitBit& byte_event : pending_byte_frames)
-			m_bubble_text_by_frame[fid] = e.bubble_text;
+			add_event_frame(byte_event);
-		if (++frames_since_commit >= kCommitBatch)
+		pending_byte_frames.clear();
+	};
+
+	IrFoxOnBit on_bit = [&](const IrFoxEmitBit& e) {
+		// Per-bit markers dominate Logic's render cost.  They belong to Detailed
+		// only; Overview keeps a fast packet-level timeline.
+		if (e.frame_type == IRF_FT_DATA_BIT)
 		{
-			mResults->CommitResults();
+			if (detailed_presentation)
-			frames_since_commit = 0;
+			{
+				// Markers, like legacy frames, must be published in time order.
+				// Publish the payload boundary when the first bit arrives rather
+				// than inserting it retroactively after packet completion.
+				if (e.bit_index == 0)
+					mResults->AddMarker(static_cast<U64>(e.start_sample), AnalyzerResults::Start,
+						mSettings.mInputChannel);
+				const U64 marker_sample = static_cast<U64>((e.start_sample + e.end_sample) / 2);
+				mResults->AddMarker(marker_sample, e.bit_value ? AnalyzerResults::One : AnalyzerResults::Zero,
+					mSettings.mInputChannel);
+			}
+			return;
 		}
+		// Sync cells have no independent user-facing value at overview scale. A
+		// fatal sync mismatch is still emitted as IRF_FT_ABORT below.
+		if (e.frame_type == IRF_FT_SYNC_BIT)
+			return;
+		if (e.frame_type == IRF_FT_DATA_BYTE)
+		{
+			if (detailed_presentation)
+				pending_byte_frames.push_back(e);
+			return;
+		}
+		if (!detailed_presentation)
+			return;
+		if (e.frame_type == IRF_FT_PREAMBLE)
+		{
+			// A timeout can leave a few complete bytes without a packet event.
+			// Flush them before the next PRE so legacy frames remain monotonic.
+			flush_pending_bytes();
+			add_event_frame(e);
+			return;
+		}
+		if (e.frame_type == IRF_FT_OVERFLOW || e.frame_type == IRF_FT_ABORT)
+			flush_pending_bytes();
+		add_event_frame(e);
+	};
+
+	// Terminal events are independent of per-bit rendering.  Overview passes an
+	// empty on_bit callback for speed, but must still show an interrupted frame.
+	IrFoxOnTerminal on_terminal = [&](const IrFoxEmitTerminal& terminal) {
+		Frame frame;
+		if (detailed_presentation && !pending_byte_frames.empty())
+		{
+			// Preserve every completed byte except the final one.  The terminal
+			// frame replaces that last byte so legacy frames never overlap.
+			for (size_t i = 0; i + 1 < pending_byte_frames.size(); ++i)
+				add_event_frame(pending_byte_frames[i]);
+			frame.mStartingSampleInclusive = static_cast<S64>(pending_byte_frames.back().start_sample);
+		}
+		else
+		{
+			frame.mStartingSampleInclusive = static_cast<S64>(detailed_presentation ?
+				terminal.detail_start_sample : terminal.start_sample);
+		}
+		frame.mEndingSampleInclusive = static_cast<S64>(terminal.end_sample);
+		if (frame.mStartingSampleInclusive > frame.mEndingSampleInclusive)
+			frame.mStartingSampleInclusive = frame.mEndingSampleInclusive;
+		frame.mType = terminal.reason == IrFoxTerminalReason::Timeout ? IRF_FT_TIMEOUT :
+			(terminal.cause == IrFoxAbortCause::Overflow ? IRF_FT_OVERFLOW : IRF_FT_ABORT);
+		frame.mData1 = terminal.declared_size;
+		frame.mData2 = U64(terminal.received_bits) |
+			(U64(terminal.err_low) << 16) | (U64(terminal.err_high) << 24) | (U64(terminal.err_other) << 32) |
+			(U64(terminal.message_type) << 40) | (U64(terminal.cause) << 48) | (U64(terminal.reason) << 56);
+		frame.mFlags = DISPLAY_AS_ERROR_FLAG;
+		const U64 fid = mResults->AddFrame(frame);
+		pending_byte_frames.clear();
+
+		std::string short_text;
+		if (terminal.reason == IrFoxTerminalReason::Timeout)
+			short_text = "❌ TIMEOUT";
+		else
+		{
+			short_text = "❌ ABORT";
+			const char* cause = terminal_abort_cause_text(terminal.cause);
+			if (*cause != '\0')
+				short_text += std::string(" ") + cause;
+		}
+
+		std::string detail = short_text + " · got=" + std::to_string(terminal.received_bits) + "b";
+		if (terminal.message_type != 0xFFU)
+		{
+			detail += " · ";
+			detail += irfox::messageTypeText(terminal.message_type);
+			detail += " len=" + std::to_string(terminal.declared_size) + "B";
+		}
+		if (terminal.err_low != 0U || terminal.err_high != 0U || terminal.err_other != 0U)
+		{
+			detail += " · err=" + std::to_string(terminal.err_low) + "/" +
+				std::to_string(terminal.err_high) + "/" + std::to_string(terminal.err_other);
+		}
+
+		auto cached_text = std::make_shared<IrFoxCachedFrameText>();
+		cached_text->bubble_texts[0] = "❌";
+		cached_text->bubble_texts[1] = short_text;
+		cached_text->bubble_texts[2] = detail;
+		cached_text->bubble_text_count = 3;
+		mResults->CacheFrameText(fid, cached_text);
+
+		if (detailed_presentation)
+			mResults->AddMarker(static_cast<U64>(terminal.end_sample), AnalyzerResults::ErrorX,
+				mSettings.mInputChannel);
+		note_legacy_frame();
 	};
 
 	IrFoxOnPacket on_pkt = [&](const IrFoxEmitPacket& p) {
+		const IrFoxPacketDecision decision =
+			irfox::classifyPacket(p.data_bytes, p.pack_size, p.crc_ok, mSettings.mReceiverAddress);
 		Frame frame;
-		frame.mStartingSampleInclusive = static_cast<S64>(p.start_sample);
+		if (detailed_presentation)
+		{
+			// A Saleae legacy frame cannot overlap another legacy frame. Emit all
+			// completed bytes except the last one, then use the last byte's span
+			// for the packet outcome bubble.
+			for (size_t i = 0; i + 1 < pending_byte_frames.size(); ++i)
+				add_event_frame(pending_byte_frames[i]);
+			frame.mStartingSampleInclusive = static_cast<S64>(pending_byte_frames.empty() ?
+				p.data_start_sample : pending_byte_frames.back().start_sample);
+		}
+		else
+		{
+			frame.mStartingSampleInclusive = static_cast<S64>(p.start_sample);
+		}
 		frame.mEndingSampleInclusive = static_cast<S64>(p.end_sample);
-		frame.mType = p.crc_ok ? IRF_FT_PACKET_OK : IRF_FT_PACKET_CRC_FAIL;
+		frame.mFlags = 0;
+		switch (decision.outcome)
+		{
+		case IrFoxPacketOutcome::Accepted:
+			frame.mType = IRF_FT_PACKET_ACCEPTED;
+			break;
+		case IrFoxPacketOutcome::RejectedCrc:
+			frame.mType = IRF_FT_PACKET_CRC_FAIL;
+			frame.mFlags |= DISPLAY_AS_ERROR_FLAG;
+			break;
+		case IrFoxPacketOutcome::RejectedLength:
+			frame.mType = IRF_FT_PACKET_BAD_LENGTH;
+			frame.mFlags |= DISPLAY_AS_ERROR_FLAG;
+			break;
+		case IrFoxPacketOutcome::IgnoredAddress:
+			frame.mType = IRF_FT_PACKET_IGNORED_ADDRESS;
+			break;
+		case IrFoxPacketOutcome::RawOnlyUnknownType:
+		case IrFoxPacketOutcome::RawOnlyTypedLength:
+			frame.mType = IRF_FT_PACKET_RAW_ONLY;
+			frame.mFlags |= DISPLAY_AS_WARNING_FLAG;
+			break;
+		}
 		frame.mData1 = p.pack_size;
 		frame.mData2 = (U64(p.err_low) << 0) | (U64(p.err_high) << 8) | (U64(p.err_other) << 16);
-		if (!p.crc_ok)
-			frame.mFlags |= DISPLAY_AS_ERROR_FLAG;
 
 		const U64 fid = mResults->AddFrame(frame);
+		pending_byte_frames.clear();
+
+		const std::string icon = packet_icon(decision, mSettings.mPacketIconMode);
 
 		std::string hx;
 		append_hex(hx, p.data_bytes, p.pack_size);
-		m_packet_hex_by_frame[fid] = std::move(hx);
+		std::string status = irfox::packetOutcomeText(decision.outcome);
+		if (p.pack_size >= irfox::kMsgBytes)
+		{
+			status += " ";
+			status += irfox::messageTypeText(decision.message_type);
+		}
+		if (decision.has_destination)
+			status += " to=" + std::to_string(decision.destination);
 
-		FrameV2 fv2;
+		auto cached_text = std::make_shared<IrFoxCachedFrameText>();
-		fv2.AddBoolean("crc_ok", p.crc_ok);
+		cached_text->export_hex = hx;
-		fv2.AddInteger("len", static_cast<S64>(p.pack_size));
+		cached_text->bubble_texts[0] = icon;
-		fv2.AddInteger("err_low", static_cast<S64>(p.err_low));
+		if (detailed_presentation)
-		fv2.AddInteger("err_high", static_cast<S64>(p.err_high));
+		{
-		fv2.AddInteger("err_other", static_cast<S64>(p.err_other));
+			char last_byte[3] = "??";
-		fv2.AddByteArray("data", p.data_bytes, p.pack_size);
+			if (p.pack_size > 0)
-		mResults->AddFrameV2(fv2, p.crc_ok ? "packet_ok" : "packet_bad", static_cast<U64>(p.start_sample),
+				std::snprintf(last_byte, sizeof last_byte, "%02X", static_cast<unsigned>(p.data_bytes[p.pack_size - 1]));
-							  static_cast<U64>(p.end_sample));
+			cached_text->bubble_texts[1] = std::string("0x") + last_byte + " " + icon;
+			cached_text->bubble_texts[2] = cached_text->bubble_texts[1] + " " + status + " " +
+				std::to_string(p.pack_size) + "B";
+			if (!hx.empty())
+				cached_text->bubble_texts[2] += " · " + hx;
+		}
+		else
+		{
+			cached_text->bubble_texts[1] = icon + " [" + hx + "] " + icon;
+			cached_text->bubble_texts[2] = icon + " " + status + " " +
+				std::to_string(p.pack_size) + "B";
+			if (!hx.empty())
+				cached_text->bubble_texts[2] += " · [" + hx + "] " + icon;
+		}
+		cached_text->bubble_text_count = 3;
+		mResults->CacheFrameText(fid, cached_text);
+
+		if (detailed_presentation)
+		{
+			AnalyzerResults::MarkerType outcome_marker = AnalyzerResults::Square;
+			switch (decision.outcome)
+			{
+			case IrFoxPacketOutcome::Accepted:
+				outcome_marker = AnalyzerResults::Square;
+				break;
+			case IrFoxPacketOutcome::IgnoredAddress:
+			case IrFoxPacketOutcome::RawOnlyUnknownType:
+			case IrFoxPacketOutcome::RawOnlyTypedLength:
+				outcome_marker = AnalyzerResults::X;
+				break;
+			case IrFoxPacketOutcome::RejectedCrc:
+			case IrFoxPacketOutcome::RejectedLength:
+				outcome_marker = AnalyzerResults::ErrorX;
+				break;
+			}
+			mResults->AddMarker(static_cast<U64>(p.end_sample), outcome_marker, mSettings.mInputChannel);
+		}
+		if (detailed_presentation)
+		{
+			// Structured output is useful in Detailed. Overview intentionally keeps
+			// only the single legacy packet frame used by the graph bubble.
+			FrameV2 fv2;
+			fv2.AddBoolean("crc_ok", p.crc_ok);
+			fv2.AddBoolean("raw_accepted", decision.raw_accepted());
+			fv2.AddBoolean("accepted", decision.outcome == IrFoxPacketOutcome::Accepted);
+			fv2.AddInteger("outcome", static_cast<S64>(decision.outcome));
+			fv2.AddInteger("message_type", static_cast<S64>(decision.message_type));
+			fv2.AddInteger("receiver_address", static_cast<S64>(mSettings.mReceiverAddress));
+			if (decision.has_destination)
+				fv2.AddInteger("destination", static_cast<S64>(decision.destination));
+			fv2.AddInteger("len", static_cast<S64>(p.pack_size));
+			fv2.AddInteger("err_low", static_cast<S64>(p.err_low));
+			fv2.AddInteger("err_high", static_cast<S64>(p.err_high));
+			fv2.AddInteger("err_other", static_cast<S64>(p.err_other));
+			fv2.AddByteArray("data", p.data_bytes, p.pack_size);
+			const char* type = decision.outcome == IrFoxPacketOutcome::Accepted ? "packet_accepted" :
+				decision.raw_accepted() ? "packet_raw_only" : "packet_rejected";
+			mResults->AddFrameV2(fv2, type, static_cast<U64>(p.start_sample), static_cast<U64>(p.end_sample));
+		}
 
 		if (++frames_since_commit >= kCommitBatch)
 		{
@@ -170,6 +447,10 @@ void IrFoxAnalyzer::WorkerThread()
 			frames_since_commit = 0;
 		}
 	};
+	// In Overview the decoder still performs the same timing, CRC, and receiver
+	// checks, but does not allocate and dispatch hundreds of visual bit events.
+	const IrFoxOnBit no_bit_events;
+	const IrFoxOnBit& bit_events = detailed_presentation ? on_bit : no_bit_events;
 
 	auto emit_confirmed_edges = [&]() {
 		for (;;)
@@ -180,7 +461,7 @@ void IrFoxAnalyzer::WorkerThread()
 				return;
 			if (pending[1].sample - pending[0].sample < min_seg_samples)
 				continue;
-			decoder.processEdge(pending[0].sample, pending[0].rising, fs, on_bit, on_pkt);
+			decoder.processEdge(pending[0].sample, pending[0].rising, fs, bit_events, on_pkt, on_terminal);
 			last_dec_edge_sample = pending[0].sample;
 			last_dec_edge_valid = true;
 			pending.erase(pending.begin());
@@ -192,7 +473,7 @@ void IrFoxAnalyzer::WorkerThread()
 		strip_vs_last_decoder();
 		while (pending.size() >= 2 && pending[1].sample - pending[0].sample >= min_seg_samples)
 		{
-			decoder.processEdge(pending[0].sample, pending[0].rising, fs, on_bit, on_pkt);
+			decoder.processEdge(pending[0].sample, pending[0].rising, fs, bit_events, on_pkt, on_terminal);
 			last_dec_edge_sample = pending[0].sample;
 			last_dec_edge_valid = true;
 			pending.erase(pending.begin());
@@ -201,7 +482,7 @@ void IrFoxAnalyzer::WorkerThread()
 		}
 		if (pending.size() == 1)
 		{
-			decoder.processEdge(pending[0].sample, pending[0].rising, fs, on_bit, on_pkt);
+			decoder.processEdge(pending[0].sample, pending[0].rising, fs, bit_events, on_pkt, on_terminal);
 			last_dec_edge_sample = pending[0].sample;
 			last_dec_edge_valid = true;
 			pending.clear();
@@ -230,7 +511,9 @@ void IrFoxAnalyzer::WorkerThread()
 	}
 
 	flush_pending_tail();
-	decoder.flushEnd(mIr->GetSampleNumber(), fs, on_bit, on_pkt);
+	decoder.flushEnd(mIr->GetSampleNumber(), fs, bit_events, on_pkt, on_terminal);
+	if (detailed_presentation)
+		flush_pending_bytes();
 
 	if (frames_since_commit != 0)
 		mResults->CommitResults();

Analyzer/raw/IR_Fox/src/IrFoxAnalyzer.h

@@ -6,8 +6,6 @@
 #include "IrFoxAnalyzerResults.h"
 #include "IrFoxSimulationDataGenerator.h"
 #include <memory>
-#include <string>
-#include <unordered_map>
 
 class ANALYZER_EXPORT IrFoxAnalyzer : public Analyzer2
 {
@@ -25,9 +23,6 @@ public:
 	virtual const char* GetAnalyzerName() const;
 	virtual bool NeedsRerun();
 
-	const char* PacketHexForFrame(U64 frame_id);
-	const char* BubbleTextForFrame(U64 frame_id) const;
-
 protected:
 	IrFoxAnalyzerSettings mSettings;
 	std::unique_ptr<IrFoxAnalyzerResults> mResults;
@@ -36,10 +31,6 @@ protected:
 	IrFoxSimulationDataGenerator mSimulationDataGenerator;
 	bool mSimulationInitilized;
 
-	std::unordered_map<U64, std::string> m_packet_hex_by_frame;
-	std::unordered_map<U64, std::string> m_bubble_text_by_frame;
-	mutable std::string m_hex_scratch;
-	mutable std::string m_bubble_scratch;
 };
 
 extern "C" ANALYZER_EXPORT const char* __cdecl GetAnalyzerName();

Analyzer/raw/IR_Fox/src/IrFoxAnalyzerResults.cpp

@@ -6,6 +6,7 @@
 #include "IrFoxDecoder.h"
 #include <cstdio>
 #include <fstream>
+#include <string>
 
 IrFoxAnalyzerResults::IrFoxAnalyzerResults(IrFoxAnalyzer* analyzer, IrFoxAnalyzerSettings* settings)
 	: AnalyzerResults(),
@@ -18,51 +19,89 @@ IrFoxAnalyzerResults::~IrFoxAnalyzerResults()
 {
 }
 
+void IrFoxAnalyzerResults::ClearCachedFrameText()
+{
+	std::lock_guard<std::mutex> lock(m_frame_text_mutex);
+	m_frame_text_by_frame.clear();
+	m_frame_text_by_frame.reserve(1024);
+}
+
+void IrFoxAnalyzerResults::CacheFrameText(U64 frame_id, std::shared_ptr<const IrFoxCachedFrameText> text)
+{
+	std::lock_guard<std::mutex> lock(m_frame_text_mutex);
+	m_frame_text_by_frame[frame_id] = std::move(text);
+}
+
+std::shared_ptr<const IrFoxCachedFrameText> IrFoxAnalyzerResults::CachedFrameTextForFrame(U64 frame_id) const
+{
+	std::lock_guard<std::mutex> lock(m_frame_text_mutex);
+	const auto it = m_frame_text_by_frame.find(frame_id);
+	return it == m_frame_text_by_frame.end() ? nullptr : it->second;
+}
+
 void IrFoxAnalyzerResults::GenerateBubbleText(U64 frame_index, Channel& channel, DisplayBase display_base)
 {
 	(void)display_base;
 	(void)channel;
 	ClearResultStrings();
+	auto add_cached_text = [&]() {
+		const std::shared_ptr<const IrFoxCachedFrameText> cached = CachedFrameTextForFrame(frame_index);
+		if (!cached)
+			return false;
+		for (size_t i = 0; i < cached->bubble_text_count; ++i)
+			AddResultString(cached->bubble_texts[i].c_str());
+		return true;
+	};
+
+	// Every Overview frame is a packet with immutable, precomputed text. Avoid
+	// even GetFrame() and formatting on Logic's redraw callback in that mode.
+	if (mSettings->mPresentation == IrFoxPresentation::Overview && add_cached_text())
+		return;
+
 	Frame frame = GetFrame(frame_index);
 
 	char line[256];
 
 	switch (frame.mType)
 	{
-	case IRF_FT_DATA_BIT:
+	case IRF_FT_DATA_BYTE:
-	case IRF_FT_SYNC_BIT:
-	case IRF_FT_PREAMBLE:
-	case IRF_FT_OVERFLOW:
-	case IRF_FT_ABORT:
 	{
-		const char* bt = mAnalyzer->BubbleTextForFrame(frame_index);
+		char byte_text[3];
-		if (bt && bt[0])
+		std::snprintf(byte_text, sizeof byte_text, "%02X", static_cast<unsigned>(frame.mData1 & 0xFFu));
-			AddResultString(bt);
+		AddResultString(byte_text);
-		else if (frame.mType == IRF_FT_DATA_BIT)
+		AddResultString("0x", byte_text);
-			AddResultString(frame.mData1 ? "1" : "0");
-		else if (frame.mType == IRF_FT_SYNC_BIT)
-		{
-			snprintf(line, sizeof line, "sync: %s", frame.mData1 ? "1" : "0");
-			AddResultString(line);
-		}
-		else if (frame.mType == IRF_FT_OVERFLOW)
-			AddResultString("OVF");
-		else if (frame.mType == IRF_FT_ABORT)
-			AddResultString("SYNC!");
-		else
-			AddResultString("PRE");
 		break;
 	}
 
-	case IRF_FT_PACKET_OK:
+	case IRF_FT_PREAMBLE:
-	case IRF_FT_PACKET_CRC_FAIL:
 	{
-		snprintf(line, sizeof line, "%s %lluB", frame.mType == IRF_FT_PACKET_OK ? "OK" : "CRC",
+		AddResultString("📡");
-				 (unsigned long long)frame.mData1);
+		AddResultString("📡 PRE");
-		AddResultString(line);
+		break;
-		const char* hx = mAnalyzer->PacketHexForFrame(frame_index);
+	}
-		if (hx && hx[0])
+
-			AddResultString(hx);
+	case IRF_FT_OVERFLOW:
+	case IRF_FT_ABORT:
+	case IRF_FT_TIMEOUT:
+	{
+		if (add_cached_text())
+			break;
+		AddResultString("❌");
+		AddResultString(frame.mType == IRF_FT_TIMEOUT ? "❌ TIMEOUT" :
+			(frame.mType == IRF_FT_OVERFLOW ? "❌ ABORT OVF" : "❌ ABORT"));
+		break;
+	}
+
+	case IRF_FT_PACKET_ACCEPTED:
+	case IRF_FT_PACKET_CRC_FAIL:
+	case IRF_FT_PACKET_BAD_LENGTH:
+	case IRF_FT_PACKET_RAW_ONLY:
+	case IRF_FT_PACKET_IGNORED_ADDRESS:
+	{
+		if (!add_cached_text())
+			AddResultString(frame.mType == IRF_FT_PACKET_ACCEPTED ? "✅" :
+				(frame.mType == IRF_FT_PACKET_CRC_FAIL || frame.mType == IRF_FT_PACKET_BAD_LENGTH) ? "❌" :
+				frame.mType == IRF_FT_PACKET_IGNORED_ADDRESS ? "📭" : "⚠️");
 		break;
 	}
 
@@ -95,23 +134,44 @@ void IrFoxAnalyzerResults::GenerateExportFile(const char* file, DisplayBase disp
 		const char* typ = "?";
 		switch (frame.mType)
 		{
-		case IRF_FT_DATA_BIT:
+		case IRF_FT_PACKET_ACCEPTED:
-			typ = "D";
+			typ = "ACCEPT";
-			break;
-		case IRF_FT_SYNC_BIT:
-			typ = "S";
-			break;
-		case IRF_FT_PACKET_OK:
-			typ = "OK";
 			break;
 		case IRF_FT_PACKET_CRC_FAIL:
-			typ = "CRC";
+			typ = "REJECT_CRC";
+			break;
+		case IRF_FT_PACKET_BAD_LENGTH:
+			typ = "REJECT_LEN";
+			break;
+		case IRF_FT_PACKET_RAW_ONLY:
+			typ = "RAW_ONLY";
+			break;
+		case IRF_FT_PACKET_IGNORED_ADDRESS:
+			typ = "IGNORE_ADDR";
 			break;
 		case IRF_FT_OVERFLOW:
-			typ = "OVF";
+			typ = "ABORT_OVF";
 			break;
 		case IRF_FT_ABORT:
-			typ = "ABORT";
+			switch (static_cast<IrFoxAbortCause>((frame.mData2 >> 48) & 0xFFull))
+			{
+			case IrFoxAbortCause::BadSync:
+				typ = "ABORT_SYNC";
+				break;
+			case IrFoxAbortCause::BadLength:
+				typ = "ABORT_LEN";
+				break;
+			case IrFoxAbortCause::Overflow:
+				typ = "ABORT_OVF";
+				break;
+			case IrFoxAbortCause::None:
+			default:
+				typ = "ABORT";
+				break;
+			}
+			break;
+		case IRF_FT_TIMEOUT:
+			typ = "TIMEOUT";
 			break;
 		case IRF_FT_PREAMBLE:
 			typ = "PRE";
@@ -120,14 +180,12 @@ void IrFoxAnalyzerResults::GenerateExportFile(const char* file, DisplayBase disp
 			break;
 		}
 
-		const char* hx = mAnalyzer->PacketHexForFrame(i);
+		const std::shared_ptr<const IrFoxCachedFrameText> cached = CachedFrameTextForFrame(i);
-		if (!hx)
+		const char* hx = cached ? cached->export_hex.c_str() : "";
-			hx = "";
 
 		U64 bit_idx = 0;
 		U32 err_l = 0, err_h = 0, err_o = 0;
-		if (frame.mType == IRF_FT_DATA_BIT || frame.mType == IRF_FT_SYNC_BIT ||
+		if (frame.mType == IRF_FT_OVERFLOW || frame.mType == IRF_FT_ABORT || frame.mType == IRF_FT_TIMEOUT)
-			frame.mType == IRF_FT_OVERFLOW || frame.mType == IRF_FT_ABORT)
 		{
 			bit_idx = frame.mData2 & 0xFFFFull;
 			err_l = static_cast<U32>((frame.mData2 >> 16) & 0xFFull);

Analyzer/raw/IR_Fox/src/IrFoxAnalyzerResults.h

@@ -2,10 +2,22 @@
 #define IRFOX_ANALYZER_RESULTS
 
 #include <AnalyzerResults.h>
+#include <array>
+#include <memory>
+#include <mutex>
+#include <string>
+#include <unordered_map>
 
 class IrFoxAnalyzer;
 class IrFoxAnalyzerSettings;
 
+struct IrFoxCachedFrameText
+{
+	std::array<std::string, 3> bubble_texts{};
+	size_t bubble_text_count = 0;
+	std::string export_hex;
+};
+
 class IrFoxAnalyzerResults : public AnalyzerResults
 {
 public:
@@ -19,9 +31,15 @@ public:
 	virtual void GeneratePacketTabularText(U64 packet_id, DisplayBase display_base);
 	virtual void GenerateTransactionTabularText(U64 transaction_id, DisplayBase display_base);
 
+	void ClearCachedFrameText();
+	void CacheFrameText(U64 frame_id, std::shared_ptr<const IrFoxCachedFrameText> text);
+	std::shared_ptr<const IrFoxCachedFrameText> CachedFrameTextForFrame(U64 frame_id) const;
+
 protected:
 	IrFoxAnalyzerSettings* mSettings;
 	IrFoxAnalyzer* mAnalyzer;
+	mutable std::mutex m_frame_text_mutex;
+	std::unordered_map<U64, std::shared_ptr<const IrFoxCachedFrameText>> m_frame_text_by_frame;
 };
 
 #endif

Analyzer/raw/IR_Fox/src/IrFoxAnalyzerSettings.cpp

@@ -3,14 +3,42 @@
 
 IrFoxAnalyzerSettings::IrFoxAnalyzerSettings()
 	: mInputChannel(UNDEFINED_CHANNEL),
-	  mInputChannelInterface()
+	  mReceiverAddress(0),
+	  mPresentation(IrFoxPresentation::Overview),
+	  mPacketIconMode(IrFoxPacketIconMode::StatusAndType),
+	  mInputChannelInterface(),
+	  mReceiverAddressInterface(),
+	  mPresentationInterface(),
+	  mPacketIconModeInterface()
 {
 	mInputChannelInterface.SetTitleAndTooltip(
 		"IR",
 		"Demodulated IR receiver output (e.g. TSOP: idle HIGH, active LOW)");
 	mInputChannelInterface.SetChannel(mInputChannel);
+	mReceiverAddressInterface.SetTitleAndTooltip(
+		"Receiver address",
+		"IR receiver ID for ACCEPT/IGNORE ADDR. 0 mirrors a receiver configured to accept every address; 65000..65535 are broadcast destinations.");
+	mReceiverAddressInterface.SetMin(0);
+	mReceiverAddressInterface.SetMax(65535);
+	mReceiverAddressInterface.SetInteger(mReceiverAddress);
+	mPresentationInterface.SetTitleAndTooltip(
+		"Presentation",
+		"Overview shows one packet bubble over the full frame. Detailed separates PRE, packet, and hexadecimal bytes. Logic 2 does not expose zoom to analyzers, so this is selected explicitly.");
+	mPresentationInterface.AddNumber(static_cast<double>(IrFoxPresentation::Overview), "Overview", "One outcome bubble across the full frame; no PRE badge.");
+	mPresentationInterface.AddNumber(static_cast<double>(IrFoxPresentation::Detailed), "Detailed", "Separate PRE and packet bubbles, plus one hexadecimal bubble per byte.");
+	mPresentationInterface.SetNumber(static_cast<double>(mPresentation));
+	mPacketIconModeInterface.SetTitleAndTooltip(
+		"Packet icon",
+		"Choose whether packet bubbles show reception status, decoded message type, or both.");
+	mPacketIconModeInterface.AddNumber(static_cast<double>(IrFoxPacketIconMode::Status), "Status  ✅", "One status symbol: accepted, other address, invalid, or unknown.");
+	mPacketIconModeInterface.AddNumber(static_cast<double>(IrFoxPacketIconMode::MessageType), "Message type  📦", "One symbol for the decoded firmware message type.");
+	mPacketIconModeInterface.AddNumber(static_cast<double>(IrFoxPacketIconMode::StatusAndType), "Status + type  ✅📦", "Reception status followed by the decoded firmware message type.");
+	mPacketIconModeInterface.SetNumber(static_cast<double>(mPacketIconMode));
 
 	AddInterface(&mInputChannelInterface);
+	AddInterface(&mReceiverAddressInterface);
+	AddInterface(&mPresentationInterface);
+	AddInterface(&mPacketIconModeInterface);
 
 	AddExportOption(0, "Export as text/csv file");
 	AddExportExtension(0, "text", "txt");
@@ -27,6 +55,23 @@ IrFoxAnalyzerSettings::~IrFoxAnalyzerSettings()
 bool IrFoxAnalyzerSettings::SetSettingsFromInterfaces()
 {
 	mInputChannel = mInputChannelInterface.GetChannel();
+	mReceiverAddress = static_cast<uint16_t>(mReceiverAddressInterface.GetInteger());
+	const int presentation = static_cast<int>(mPresentationInterface.GetNumber());
+	mPresentation = presentation == static_cast<int>(IrFoxPresentation::Detailed) ?
+		IrFoxPresentation::Detailed : IrFoxPresentation::Overview;
+	const int packet_icon_mode = static_cast<int>(mPacketIconModeInterface.GetNumber());
+	switch (packet_icon_mode)
+	{
+	case static_cast<int>(IrFoxPacketIconMode::Status):
+		mPacketIconMode = IrFoxPacketIconMode::Status;
+		break;
+	case static_cast<int>(IrFoxPacketIconMode::MessageType):
+		mPacketIconMode = IrFoxPacketIconMode::MessageType;
+		break;
+	default:
+		mPacketIconMode = IrFoxPacketIconMode::StatusAndType;
+		break;
+	}
 
 	ClearChannels();
 	AddChannel(mInputChannel, "IR Fox", true);
@@ -37,6 +82,9 @@ bool IrFoxAnalyzerSettings::SetSettingsFromInterfaces()
 void IrFoxAnalyzerSettings::UpdateInterfacesFromSettings()
 {
 	mInputChannelInterface.SetChannel(mInputChannel);
+	mReceiverAddressInterface.SetInteger(mReceiverAddress);
+	mPresentationInterface.SetNumber(static_cast<double>(mPresentation));
+	mPacketIconModeInterface.SetNumber(static_cast<double>(mPacketIconMode));
 }
 
 void IrFoxAnalyzerSettings::LoadSettings(const char* settings)
@@ -45,6 +93,50 @@ void IrFoxAnalyzerSettings::LoadSettings(const char* settings)
 	text_archive.SetString(settings);
 
 	text_archive >> mInputChannel;
+	S32 receiver_address = 0;
+	if (text_archive >> receiver_address)
+	{
+		if (receiver_address < 0)
+			receiver_address = 0;
+		if (receiver_address > 65535)
+			receiver_address = 65535;
+		mReceiverAddress = static_cast<uint16_t>(receiver_address);
+	}
+	else
+	{
+		// Version 0 settings stored only the channel.
+		mReceiverAddress = 0;
+	}
+	// Settings before the presentation switch contain the former "show bit cells"
+	// value in this position.  Bits are now deliberately always shown.
+	S32 legacy_show_bit_cells = 0;
+	(void)(text_archive >> legacy_show_bit_cells);
+	S32 presentation = static_cast<S32>(IrFoxPresentation::Overview);
+	if (text_archive >> presentation && presentation == static_cast<S32>(IrFoxPresentation::Detailed))
+		mPresentation = IrFoxPresentation::Detailed;
+	else
+		mPresentation = IrFoxPresentation::Overview;
+	S32 packet_icon_mode = static_cast<S32>(IrFoxPacketIconMode::StatusAndType);
+	if (text_archive >> packet_icon_mode)
+	{
+		switch (packet_icon_mode)
+		{
+		case static_cast<S32>(IrFoxPacketIconMode::Status):
+			mPacketIconMode = IrFoxPacketIconMode::Status;
+			break;
+		case static_cast<S32>(IrFoxPacketIconMode::MessageType):
+			mPacketIconMode = IrFoxPacketIconMode::MessageType;
+			break;
+		default:
+			mPacketIconMode = IrFoxPacketIconMode::StatusAndType;
+			break;
+		}
+	}
+	else
+	{
+		// Existing analyzer instances gain the most informative mode by default.
+		mPacketIconMode = IrFoxPacketIconMode::StatusAndType;
+	}
 
 	ClearChannels();
 	AddChannel(mInputChannel, "IR Fox", true);
@@ -57,6 +149,11 @@ const char* IrFoxAnalyzerSettings::SaveSettings()
 	SimpleArchive text_archive;
 
 	text_archive << mInputChannel;
+	text_archive << static_cast<S32>(mReceiverAddress);
+	// Retain the old third field so already-saved configurations remain readable.
+	text_archive << static_cast<S32>(1);
+	text_archive << static_cast<S32>(mPresentation);
+	text_archive << static_cast<S32>(mPacketIconMode);
 
 	return SetReturnString(text_archive.GetString());
 }

Analyzer/raw/IR_Fox/src/IrFoxAnalyzerSettings.h

@@ -3,6 +3,22 @@
 
 #include <AnalyzerSettings.h>
 #include <AnalyzerTypes.h>
+#include <cstdint>
+
+/** Logic 2 does not pass the current zoom level to an analyzer, so the user selects the annotation density. */
+enum class IrFoxPresentation : uint8_t
+{
+	Overview = 0,
+	Detailed = 1,
+};
+
+/** Which compact symbol is used at the shortest packet-bubble zoom level. */
+enum class IrFoxPacketIconMode : uint8_t
+{
+	Status = 0,
+	MessageType = 1,
+	StatusAndType = 2,
+};
 
 class IrFoxAnalyzerSettings : public AnalyzerSettings
 {
@@ -16,9 +32,16 @@ public:
 	virtual const char* SaveSettings();
 
 	Channel mInputChannel;
+	/** Receiver ID used by the same address rule as IR_FOX::checkAddressRuleApply. 0 means catch all. */
+	uint16_t mReceiverAddress;
+	IrFoxPresentation mPresentation;
+	IrFoxPacketIconMode mPacketIconMode;
 
 protected:
 	AnalyzerSettingInterfaceChannel mInputChannelInterface;
+	AnalyzerSettingInterfaceInteger mReceiverAddressInterface;
+	AnalyzerSettingInterfaceNumberList mPresentationInterface;
+	AnalyzerSettingInterfaceNumberList mPacketIconModeInterface;
 };
 
 #endif

Analyzer/raw/IR_Fox/src/IrFoxDecoder.cpp

@@ -52,6 +52,20 @@ bool IrFoxDecoder::crc_check(uint8_t len, uint16_t& crc_out)
 	return ok;
 }
 
+void IrFoxDecoder::preamble_reset_to_idle()
+{
+	preamble_state_ = PreambleState::Idle;
+	preamble_good_periods_ = 0;
+	preamble_mean_period_us_ = 0;
+	preamble_candidate_last_edge_us_ = 0;
+	preamble_candidate_first_rise_us_ = 0;
+	preamble_candidate_first_rise_valid_ = false;
+	preamble_bubble_start_valid_ = false;
+	is_preamb = false;
+	is_wrong_pack = false;
+	is_buffer_overflow = false;
+}
+
 void IrFoxDecoder::first_rx()
 {
 	err_low_signal = err_high_signal = err_other = 0;
@@ -65,7 +79,7 @@ void IrFoxDecoder::first_rx()
 	i_sync_bit = 0;
 	err_sync_bit = 0;
 	is_wrong_pack = false;
-	is_preamb = true;
+	is_preamb = false;
 	is_recive = false;
 	is_recive_raw = false;
 	msg_type_receive = 0;
@@ -73,6 +87,66 @@ void IrFoxDecoder::first_rx()
 	std::memset(data_buffer, 0, sizeof data_buffer);
 	preamble_bubble_start_valid_ = false;
 	trim_first_data_bit_cell_ = false;
+	packet_start_sample_ = 0;
+	packet_start_valid_ = false;
+	packet_data_start_sample_ = 0;
+	packet_data_start_valid_ = false;
+	byte_start_sample_ = 0;
+	preamble_reset_to_idle();
+}
+
+void IrFoxDecoder::release_preamble_guard(double t_us)
+{
+	const uint32_t long_silence_us = irfox::irTimeoutUs(rise_sync_time_us) * 2U;
+	// Mirror IR_DecoderRaw::releasePreambleGuard. A negative value is the
+	// floating-point equivalent of the firmware's wrap-safe unsigned offset.
+	prev_rise_us = t_us - static_cast<double>(long_silence_us) - 1.0;
+}
+
+void IrFoxDecoder::emit_terminal(IrFoxTerminalReason reason, IrFoxAbortCause cause, uint64_t end_sample,
+								const IrFoxOnTerminal& on_terminal) const
+{
+	if (!on_terminal)
+		return;
+
+	IrFoxEmitTerminal terminal{};
+	const uint64_t start_sample = packet_start_valid_ ? packet_start_sample_ :
+		(packet_data_start_valid_ ? packet_data_start_sample_ : last_edge_sample);
+	terminal.start_sample = static_cast<int64_t>(start_sample);
+	terminal.detail_start_sample = static_cast<int64_t>(
+		packet_data_start_valid_ ? packet_data_start_sample_ : last_edge_sample);
+	terminal.end_sample = static_cast<int64_t>(end_sample);
+	terminal.reason = reason;
+	terminal.cause = cause;
+	terminal.message_type = i_data_buffer >= irfox::kBitPerByte ?
+		static_cast<uint8_t>((data_buffer[0] >> 5U) & 0x07U) : 0xFFU;
+	terminal.declared_size = static_cast<uint8_t>(pack_size);
+	terminal.received_bits = i_data_buffer;
+	terminal.err_low = err_low_signal;
+	terminal.err_high = err_high_signal;
+	terminal.err_other = err_other;
+	on_terminal(terminal);
+}
+
+void IrFoxDecoder::abort_frame(double t_us, uint64_t end_sample, IrFoxAbortCause cause,
+							   const IrFoxOnTerminal& on_terminal)
+{
+	emit_terminal(IrFoxTerminalReason::Abort, cause, end_sample, on_terminal);
+	is_recive = false;
+	is_recive_raw = false;
+	msg_type_receive = 0;
+	first_rx();
+	release_preamble_guard(t_us);
+}
+
+void IrFoxDecoder::expire_preamble_candidate(double t_us)
+{
+	if (preamble_state_ != PreambleState::Candidate)
+		return;
+	const uint32_t timeout_us =
+		irfox::irTimeoutUs(rise_sync_time_us) * irfox::kPreambleCandidateTimeoutMult;
+	if ((t_us - preamble_candidate_last_edge_us_) > static_cast<double>(timeout_us))
+		preamble_reset_to_idle();
 }
 
 void IrFoxDecoder::listen_start(double t_us)
@@ -86,13 +160,20 @@ void IrFoxDecoder::listen_start(double t_us)
 	}
 }
 
-void IrFoxDecoder::check_timeout(double t_us)
+void IrFoxDecoder::check_timeout(double t_us, uint32_t fs, const IrFoxOnTerminal& on_terminal)
 {
 	if (!is_recive)
 		return;
 	const uint32_t irmax = irfox::irTimeoutUs(rise_sync_time_us);
 	if (t_us - last_edge_time_us > irmax * 2.0)
 	{
+		const uint64_t timeout_us = static_cast<uint64_t>(irmax) * 2U;
+		// The callback fires only after the strict > 2T boundary, but the terminal
+		// frame owns samples only through 2T.  This leaves a following edge free to
+		// seed the next preamble without overlapping inclusive Saleae frames.
+		const uint64_t timeout_samples = (timeout_us * static_cast<uint64_t>(fs)) / 1000000ULL;
+		emit_terminal(IrFoxTerminalReason::Timeout, IrFoxAbortCause::None,
+			last_edge_sample + timeout_samples, on_terminal);
 		// Как IR_DecoderRaw::checkTimeout после фикса: полный сброс, иначе залипание FSM.
 		is_recive = false;
 		msg_type_receive = 0;
@@ -103,29 +184,23 @@ void IrFoxDecoder::check_timeout(double t_us)
 }
 
 void IrFoxDecoder::write_to_buffer(bool bit, bool pack_trace_invert_fix, uint64_t cell_start_s, uint64_t cell_end_s,
-								   const IrFoxOnBit& on_bit, const IrFoxOnPacket& on_pkt, IrFoxEmitBitMode emit_mode)
+								   const IrFoxOnBit& on_bit, const IrFoxOnPacket& on_pkt,
+								   const IrFoxOnTerminal& on_terminal, IrFoxEmitBitMode emit_mode)
 {
-	if (i_data_buffer > irfox::kDataByteSizeMax * 8u)
+	if (i_data_buffer >= irfox::kDataByteSizeMax * 8u)
 	{
-		if (!is_buffer_overflow && on_bit)
-		{
-			IrFoxEmitBit e{};
-			e.start_sample = static_cast<int64_t>(cell_start_s);
-			e.end_sample = static_cast<int64_t>(cell_end_s);
-			e.frame_type = IRF_FT_OVERFLOW;
-			e.mflags = DISPLAY_AS_ERROR_FLAG;
-			fill_err_snapshot(e);
-			std::strncpy(e.bubble_text, "OVF", sizeof e.bubble_text);
-			e.bubble_text[sizeof e.bubble_text - 1] = '\0';
-			on_bit(e);
-		}
 		is_buffer_overflow = true;
+		abort_frame(last_edge_time_us, cell_end_s, IrFoxAbortCause::Overflow, on_terminal);
+		return;
 	}
 
 	if (is_buffer_overflow || is_preamb || is_wrong_pack)
 	{
-		// Как IR_DecoderRaw::writeToBuffer: полный first_rx() вместо только сброса флагов приёма.
+		// Firmware treats overflow/invalid frame state as a terminal abort and
-		first_rx();
+		// immediately permits a fresh preamble candidate.
+		const IrFoxAbortCause cause = is_buffer_overflow ? IrFoxAbortCause::Overflow :
+			(is_wrong_pack ? IrFoxAbortCause::BadSync : IrFoxAbortCause::None);
+		abort_frame(last_edge_time_us, cell_end_s, cause, on_terminal);
 		return;
 	}
 
@@ -140,6 +215,19 @@ void IrFoxDecoder::write_to_buffer(bool bit, bool pack_trace_invert_fix, uint64_
 	if (is_data)
 	{
 		const bool was_first_data_bit = (i_data_buffer == 0);
+		const bool was_first_bit_of_byte = (i_data_buffer % irfox::kBitPerByte) == 0U;
+		if (was_first_data_bit && !packet_start_valid_)
+		{
+			packet_start_sample_ = cell_start_s;
+			packet_start_valid_ = true;
+		}
+		if (was_first_data_bit)
+		{
+			packet_data_start_sample_ = cell_start_s;
+			packet_data_start_valid_ = true;
+		}
+		if (was_first_bit_of_byte)
+			byte_start_sample_ = cell_start_s;
 		data_buffer[i_data_buffer / 8] |= static_cast<uint8_t>(bit ? 1 : 0) << (7 - (i_data_buffer % 8));
 		i_data_buffer++;
 		buf_bit_pos++;
@@ -156,6 +244,16 @@ void IrFoxDecoder::write_to_buffer(bool bit, bool pack_trace_invert_fix, uint64_
 			e.bubble_text[1] = '\0';
 			on_bit(e);
 		}
+		if (on_bit && emit_mode == IrFoxEmitBitMode::WithBubble &&
+			(i_data_buffer % irfox::kBitPerByte) == 0U)
+		{
+			const uint64_t byte_index = (i_data_buffer / irfox::kBitPerByte) - 1U;
+			IrFoxEmitBit e{static_cast<int64_t>(byte_start_sample_), static_cast<int64_t>(cell_end_s), IRF_FT_DATA_BYTE,
+				data_buffer[byte_index], byte_index, fl, pack_trace_invert_fix, 0, 0, 0};
+			fill_err_snapshot(e);
+			std::snprintf(e.bubble_text, sizeof e.bubble_text, "%02X", static_cast<unsigned>(data_buffer[byte_index]));
+			on_bit(e);
+		}
 		if (was_first_data_bit && trim_first_data_bit_cell_)
 			trim_first_data_bit_cell_ = false;
 	}
@@ -186,14 +284,10 @@ void IrFoxDecoder::write_to_buffer(bool bit, bool pack_trace_invert_fix, uint64_
 				const bool fatal_sync = (err_sync_bit >= irfox::kSyncBits);
 				if (fatal_sync)
 					is_wrong_pack = true;
-				if (on_bit && fatal_sync)
+				if (fatal_sync)
 				{
-					IrFoxEmitBit e{static_cast<int64_t>(cell_start_s), static_cast<int64_t>(cell_end_s), IRF_FT_ABORT,
+					abort_frame(last_edge_time_us, cell_end_s, IrFoxAbortCause::BadSync, on_terminal);
-								   0, 0, DISPLAY_AS_ERROR_FLAG, false, 0, 0, 0};
+					return;
-					fill_err_snapshot(e);
-					std::strncpy(e.bubble_text, "SYNC!", sizeof e.bubble_text);
-					e.bubble_text[sizeof e.bubble_text - 1] = '\0';
-					on_bit(e);
 				}
 			}
 		}
@@ -216,12 +310,23 @@ void IrFoxDecoder::write_to_buffer(bool bit, bool pack_trace_invert_fix, uint64_
 	if (!is_available && is_data && !is_wrong_pack)
 	{
 		if (i_data_buffer == 8 * irfox::kMsgBytes)
+		{
 			pack_size = static_cast<uint16_t>(data_buffer[0] & 0x1Fu);
+			// The receiver rejects a length that cannot contain its two CRC bytes.
+			// Emit a terminal abort so the capture explains why no packet follows.
+			if (pack_size < irfox::kMsgBytes + irfox::kCrcBytes)
+			{
+				is_wrong_pack = true;
+				abort_frame(last_edge_time_us, cell_end_s, IrFoxAbortCause::BadLength, on_terminal);
+				return;
+			}
+		}
 
 		if (pack_size && (i_data_buffer == 8))
 			msg_type_receive = static_cast<uint8_t>((data_buffer[0] >> 5) | 0xF8u);
 
-		if (pack_size && (i_data_buffer == pack_size * irfox::kBitPerByte))
+		if (pack_size >= irfox::kMsgBytes + irfox::kCrcBytes &&
+			(i_data_buffer == pack_size * irfox::kBitPerByte))
 		{
 			uint16_t crc_computed = 0;
 			const bool crc_ok = crc_check(static_cast<uint8_t>(pack_size - irfox::kCrcBytes), crc_computed);
@@ -232,7 +337,8 @@ void IrFoxDecoder::write_to_buffer(bool bit, bool pack_trace_invert_fix, uint64_
 			is_available = crc_ok;
 
 			IrFoxEmitPacket pkt{};
-			pkt.start_sample = static_cast<int64_t>(cell_start_s);
+			pkt.start_sample = static_cast<int64_t>(packet_start_valid_ ? packet_start_sample_ : cell_start_s);
+			pkt.data_start_sample = static_cast<int64_t>(packet_data_start_valid_ ? packet_data_start_sample_ : cell_start_s);
 			pkt.end_sample = static_cast<int64_t>(cell_end_s);
 			pkt.crc_ok = crc_ok;
 			pkt.pack_size = static_cast<uint8_t>(pack_size);
@@ -248,37 +354,198 @@ void IrFoxDecoder::write_to_buffer(bool bit, bool pack_trace_invert_fix, uint64_
 }
 
 void IrFoxDecoder::processEdge(uint64_t sample, bool rising, uint32_t fs, const IrFoxOnBit& on_bit,
-							   const IrFoxOnPacket& on_pkt)
+							   const IrFoxOnPacket& on_pkt, const IrFoxOnTerminal& on_terminal)
 {
 	const double t_us = sample_to_us(sample, fs);
+
+	// Firmware advances terminal timers in this order while no queued edge is
+	// pending. For an offline capture, do the equivalent immediately before the
+	// next timestamped edge is consumed.
+	check_timeout(t_us, fs, on_terminal);
+	listen_start(t_us);
+	expire_preamble_candidate(t_us);
+
+	// A timeout/abort may have restored the nominal adaptive bit period.
 	const uint32_t irmax = irfox::irTimeoutUs(rise_sync_time_us);
 	uint32_t rise_min_us = rise_sync_time_us > irfox::kToleranceUs ? rise_sync_time_us - irfox::kToleranceUs : 0U;
-
-	listen_start(t_us);
-
-	// Как IR_DecoderRaw: пауза между фронтами по lastEdgeTime при активном приёме кадра.
-	if (last_edge_time_us > 0.0 && (t_us - last_edge_time_us) > irmax * 2.0 && is_recive)
-		check_timeout(t_us);
-
-	last_edge_time_us = t_us;
-	last_edge_sample = sample;
-
 	const uint32_t rise_max_us = rise_sync_time_us + irfox::kToleranceUs;
 
-	/** Визуализация: начало PRE с ближайшего спада в пределах ~3 битовых периодов (ИК-метка). */
+	/** Firmware starts a preamble candidate only on its first rising edge after silence. */
 	auto new_bubble_preamble_start = [&](uint64_t edge_s, bool is_rising) -> uint64_t {
-		if (!is_rising)
+		(void)is_rising;
-			return edge_s;
-		if (edge_s > prev_fall_sample)
-		{
-			const double span_us = double(edge_s - prev_fall_sample) * 1e6 / double(fs);
-			const double max_us = double(rise_max_us) * 3.0;
-			if (span_us <= max_us)
-				return prev_fall_sample;
-		}
 		return edge_s;
 	};
 
+	// Mirror IR_DecoderRaw::preambleProcessEdge.  A frame may start only after
+	// a long silence and two mutually consistent rise-to-rise periods.
+	auto start_preamble_candidate = [&]() {
+		preamble_state_ = PreambleState::Candidate;
+		preamble_good_periods_ = 0;
+		preamble_mean_period_us_ = 0;
+		preamble_candidate_last_edge_us_ = t_us;
+		preamble_candidate_first_rise_us_ = t_us;
+		preamble_candidate_first_rise_valid_ = rising;
+		is_preamb = true;
+		is_recive = false;
+		is_recive_raw = false;
+		is_wrong_pack = false;
+		preamble_bubble_start_sample_ = new_bubble_preamble_start(sample, rising);
+		preamble_bubble_start_valid_ = true;
+	};
+
+	const uint32_t long_silence_us = irmax * 2U;
+	if (preamble_state_ == PreambleState::Locked && !is_recive_raw)
+	{
+		preamble_state_ = PreambleState::Idle;
+		preamble_good_periods_ = 0;
+		preamble_mean_period_us_ = 0;
+	}
+	if (preamble_state_ == PreambleState::Idle)
+	{
+		const bool enough_silence = prev_rise_us == 0.0 ? t_us > static_cast<double>(long_silence_us) :
+			(t_us - prev_rise_us) > static_cast<double>(long_silence_us);
+		if (!is_recive_raw && rising && enough_silence)
+		{
+			start_preamble_candidate();
+			// The first rising edge only opens Candidate; it must not also be
+			// compared with itself as a zero-length preamble period.
+			last_edge_time_us = t_us;
+			last_edge_sample = sample;
+			last_processed_edge_us = t_us;
+			have_last_processed = true;
+			return;
+		}
+		else
+		{
+			// IR_DecoderRaw ignores idle edges until a valid preamble candidate starts.
+			last_edge_time_us = t_us;
+			last_edge_sample = sample;
+			last_processed_edge_us = t_us;
+			have_last_processed = true;
+			return;
+		}
+	}
+
+	if (preamble_state_ == PreambleState::Candidate)
+	{
+		preamble_candidate_last_edge_us_ = t_us;
+		if (!rising)
+		{
+			last_edge_time_us = t_us;
+			last_edge_sample = sample;
+			last_processed_edge_us = t_us;
+			have_last_processed = true;
+			return;
+		}
+
+		if (!preamble_candidate_first_rise_valid_)
+		{
+			preamble_candidate_first_rise_valid_ = true;
+			preamble_candidate_first_rise_us_ = t_us;
+			last_edge_time_us = t_us;
+			last_edge_sample = sample;
+			last_processed_edge_us = t_us;
+			have_last_processed = true;
+			return;
+		}
+
+		const uint32_t period_us = static_cast<uint32_t>(t_us - preamble_candidate_first_rise_us_);
+		preamble_candidate_first_rise_us_ = t_us;
+		if (!irfox::preambleRisePeriodCoarseOk(period_us))
+		{
+			preamble_good_periods_ = 0;
+			preamble_mean_period_us_ = 0;
+			last_edge_time_us = t_us;
+			last_edge_sample = sample;
+			last_processed_edge_us = t_us;
+			have_last_processed = true;
+			return;
+		}
+
+		if (preamble_good_periods_ == 0)
+		{
+			preamble_good_periods_ = 1;
+			preamble_mean_period_us_ = period_us;
+		}
+		else
+		{
+			const uint32_t delta = period_us > preamble_mean_period_us_ ? period_us - preamble_mean_period_us_ :
+				preamble_mean_period_us_ - period_us;
+			if (delta <= irfox::preambleJitterTolUs(preamble_mean_period_us_))
+			{
+				if (preamble_good_periods_ < 255U)
+					++preamble_good_periods_;
+				preamble_mean_period_us_ = (preamble_mean_period_us_ * 3U + period_us) / 4U;
+			}
+			else
+			{
+				preamble_good_periods_ = 1;
+				preamble_mean_period_us_ = period_us;
+			}
+		}
+
+		if (preamble_good_periods_ < irfox::kPreambleLockRisePeriods)
+		{
+			last_edge_time_us = t_us;
+			last_edge_sample = sample;
+			last_processed_edge_us = t_us;
+			have_last_processed = true;
+			return;
+		}
+
+		// The firmware clears all frame state when the candidate becomes locked.
+		err_low_signal = err_high_signal = err_other = 0;
+		pack_size = 0;
+		is_buffer_overflow = false;
+		is_available = false;
+		buf_bit_pos = 0;
+		is_data = true;
+		i_data_buffer = 0;
+		next_control_bit = irfox::kBitPerByte;
+		i_sync_bit = 0;
+		err_sync_bit = 0;
+		is_wrong_pack = false;
+		msg_type_receive = 0;
+		std::memset(data_buffer, 0, sizeof data_buffer);
+		packet_start_sample_ = preamble_bubble_start_sample_;
+		packet_start_valid_ = preamble_bubble_start_valid_;
+		packet_data_start_sample_ = 0;
+		packet_data_start_valid_ = false;
+		byte_start_sample_ = 0;
+		preamble_state_ = PreambleState::Locked;
+		is_preamb = false;
+		is_recive = true;
+		is_recive_raw = true;
+		rise_period_us = preamble_mean_period_us_;
+		prev_rise_us = t_us + static_cast<double>(preamble_mean_period_us_) / 2.0;
+		prev_rise_sample = sample + static_cast<uint64_t>(std::llround(
+			static_cast<double>(preamble_mean_period_us_) * 0.5 * static_cast<double>(fs) / 1e6));
+		trim_first_data_bit_cell_ = true;
+
+		// The analyzer chooses whether this is visible (Detailed) or folded into
+		// the full packet frame (Overview).
+		if (on_bit && preamble_bubble_start_valid_)
+		{
+			IrFoxEmitBit pe{};
+			pe.start_sample = static_cast<int64_t>(preamble_bubble_start_sample_);
+			pe.end_sample = static_cast<int64_t>(sample > 0 ? sample - 1 : sample);
+			pe.frame_type = IRF_FT_PREAMBLE;
+			fill_err_snapshot(pe);
+			on_bit(pe);
+		}
+		preamble_bubble_start_valid_ = false;
+		last_edge_time_us = t_us;
+		last_edge_sample = sample;
+		last_processed_edge_us = t_us;
+		have_last_processed = true;
+		return;
+	}
+
+	// As in processDecodedFront, the edge becomes the timing reference only
+	// after the preamble state machine has allowed it through.
+	last_edge_time_us = t_us;
+	last_edge_sample = sample;
+
 	if (rising)
 	{
 		const double delta_rp = t_us - prev_rise_us;
@@ -357,78 +624,6 @@ void IrFoxDecoder::processEdge(uint64_t sample, bool rising, uint32_t fs, const
 		}
 	}
 
-	// Как IR_DecoderRaw::tick: после длинной паузы старт сырого приёма (без отдельного firstRX — флаги ниже).
-	if (t_us > prev_rise_us && (t_us - prev_rise_us) > irmax * 2.0 && !is_recive_raw)
-	{
-		preamb_front_counter = static_cast<int8_t>(irfox::kPreambFronts - 1);
-		is_preamb = true;
-		is_recive = true;
-		is_recive_raw = true;
-		is_wrong_pack = false;
-		if (!preamble_bubble_start_valid_)
-		{
-			preamble_bubble_start_sample_ = new_bubble_preamble_start(sample, rising);
-			preamble_bubble_start_valid_ = true;
-		}
-	}
-
-	if (preamb_front_counter)
-	{
-		if (rising && rise_period_us < irmax)
-		{
-			if (rise_period_us < rise_min_us / 2U)
-			{
-				preamb_front_counter += 2;
-				err_other++;
-			}
-		}
-		preamb_front_counter--;
-	}
-	else
-	{
-		if (is_preamb)
-		{
-			is_preamb = false;
-			// IR_DecoderRaw: prevRise += risePeriod / 2 — фаза как в прошивке.
-			// Бабл PRE: до текущего фронта (sample−1), чтобы охватить все kPreambPulse периодов (3 импульса),
-			// а не только до предыдущего подъёма (~2 периода).
-			const uint64_t preamble_bubble_end_sample = sample > 0 ? sample - 1 : sample;
-			prev_rise_us += rise_period_us / 2.0;
-			{
-				const double half_us = 0.5 * static_cast<double>(rise_period_us);
-				const uint64_t half_s = static_cast<uint64_t>(std::llround(half_us * double(fs) / 1e6));
-				prev_rise_sample += half_s;
-			}
-			trim_first_data_bit_cell_ = true;
-			if (on_bit && preamble_bubble_start_valid_)
-			{
-				int64_t pe_start = static_cast<int64_t>(preamble_bubble_start_sample_);
-				int64_t pe_end = static_cast<int64_t>(preamble_bubble_end_sample);
-				if (preamble_bubble_end_sample == 0 || pe_end < pe_start)
-					pe_end = static_cast<int64_t>(sample > 0 ? sample - 1 : sample);
-				IrFoxEmitBit pe{};
-				pe.start_sample = pe_start;
-				pe.end_sample = pe_end;
-				pe.frame_type = IRF_FT_PREAMBLE;
-				fill_err_snapshot(pe);
-				std::strncpy(pe.bubble_text, "PRE", sizeof pe.bubble_text);
-				pe.bubble_text[sizeof pe.bubble_text - 1] = '\0';
-				on_bit(pe);
-			}
-			preamble_bubble_start_valid_ = false;
-			last_processed_edge_us = t_us;
-			have_last_processed = true;
-			return;
-		}
-	}
-
-	if (is_preamb)
-	{
-		last_processed_edge_us = t_us;
-		have_last_processed = true;
-		return;
-	}
-
 	if (rise_period_us > irmax || is_buffer_overflow || rise_period_us < rise_min_us || is_wrong_pack)
 	{
 		last_processed_edge_us = t_us;
@@ -455,9 +650,11 @@ void IrFoxDecoder::processEdge(uint64_t sample, bool rising, uint32_t fs, const
 		if (irfox::aroundRisePeriod(rise_period_us, rise_sync_time_us))
 		{
 			if (high_time_us > low_time_us)
-				write_to_buffer(true, false, cell_start_s, cell_end_s, on_bit, on_pkt, IrFoxEmitBitMode::WithBubble);
+				write_to_buffer(true, false, cell_start_s, cell_end_s, on_bit, on_pkt, on_terminal,
+					IrFoxEmitBitMode::WithBubble);
 			else
-				write_to_buffer(false, false, cell_start_s, cell_end_s, on_bit, on_pkt, IrFoxEmitBitMode::WithBubble);
+				write_to_buffer(false, false, cell_start_s, cell_end_s, on_bit, on_pkt, on_terminal,
+					IrFoxEmitBitMode::WithBubble);
 		}
 		else
 		{
@@ -547,13 +744,15 @@ void IrFoxDecoder::processEdge(uint64_t sample, bool rising, uint32_t fs, const
 				if (i == low_count - 1 && invert_err)
 				{
 					invert_err = false;
-					write_to_buffer(true, true, cell_start_s, cell_end_s, on_bit, on_pkt, IrFoxEmitBitMode::Quiet);
+					write_to_buffer(true, true, cell_start_s, cell_end_s, on_bit, on_pkt, on_terminal,
+						IrFoxEmitBitMode::Quiet);
 					merge_warn = true;
 					append_merge(row_is_data, true);
 				}
 				else
 				{
-					write_to_buffer(false, false, cell_start_s, cell_end_s, on_bit, on_pkt, IrFoxEmitBitMode::Quiet);
+					write_to_buffer(false, false, cell_start_s, cell_end_s, on_bit, on_pkt, on_terminal,
+						IrFoxEmitBitMode::Quiet);
 					append_merge(row_is_data, false);
 				}
 			}
@@ -564,13 +763,15 @@ void IrFoxDecoder::processEdge(uint64_t sample, bool rising, uint32_t fs, const
 				if (i == high_count - 1 && invert_err)
 				{
 					invert_err = false;
-					write_to_buffer(false, true, cell_start_s, cell_end_s, on_bit, on_pkt, IrFoxEmitBitMode::Quiet);
+					write_to_buffer(false, true, cell_start_s, cell_end_s, on_bit, on_pkt, on_terminal,
+						IrFoxEmitBitMode::Quiet);
 					merge_warn = true;
 					append_merge(row_is_data, false);
 				}
 				else
 				{
-					write_to_buffer(true, false, cell_start_s, cell_end_s, on_bit, on_pkt, IrFoxEmitBitMode::Quiet);
+					write_to_buffer(true, false, cell_start_s, cell_end_s, on_bit, on_pkt, on_terminal,
+						IrFoxEmitBitMode::Quiet);
 					append_merge(row_is_data, true);
 				}
 			}
@@ -583,11 +784,13 @@ void IrFoxDecoder::processEdge(uint64_t sample, bool rising, uint32_t fs, const
 	have_last_processed = true;
 }
 
-void IrFoxDecoder::flushEnd(uint64_t last_sample, uint32_t fs, const IrFoxOnBit& on_bit, const IrFoxOnPacket& on_pkt)
+void IrFoxDecoder::flushEnd(uint64_t last_sample, uint32_t fs, const IrFoxOnBit& on_bit, const IrFoxOnPacket& on_pkt,
+						   const IrFoxOnTerminal& on_terminal)
 {
 	const double t_us = sample_to_us(last_sample, fs);
+	check_timeout(t_us, fs, on_terminal);
 	listen_start(t_us);
-	check_timeout(t_us);
+	expire_preamble_candidate(t_us);
 	(void)on_bit;
 	(void)on_pkt;
 }

Analyzer/raw/IR_Fox/src/IrFoxDecoder.h

@@ -8,11 +8,17 @@ enum IrFoxFrameType : uint8_t
 {
 	IRF_FT_DATA_BIT = 1,
 	IRF_FT_SYNC_BIT = 2,
-	IRF_FT_PACKET_OK = 3,
+	IRF_FT_PACKET_ACCEPTED = 3,
 	IRF_FT_PACKET_CRC_FAIL = 4,
 	IRF_FT_OVERFLOW = 5,
 	IRF_FT_ABORT = 6,
 	IRF_FT_PREAMBLE = 7,
+	IRF_FT_PACKET_BAD_LENGTH = 8,
+	IRF_FT_PACKET_RAW_ONLY = 9,
+	IRF_FT_PACKET_IGNORED_ADDRESS = 10,
+	IRF_FT_DATA_BYTE = 11,
+	IRF_FT_TIMEOUT = 12,
+	IRF_FT_PACKET_OK = IRF_FT_PACKET_ACCEPTED,
 };
 
 /** WithBubble — вызвать on_bit; Quiet — только обновить состояние (для пакета битов с одного фронта). */
@@ -41,6 +47,8 @@ struct IrFoxEmitBit
 struct IrFoxEmitPacket
 {
 	int64_t start_sample;
+	/** First data-bit cell: the visible boundary between the preamble and payload. */
+	int64_t data_start_sample;
 	int64_t end_sample;
 	bool crc_ok;
 	uint8_t pack_size;
@@ -50,16 +58,47 @@ struct IrFoxEmitPacket
 	uint8_t data_bytes[irfox::kDataByteSizeMax];
 };
 
+enum class IrFoxTerminalReason : uint8_t
+{
+	Abort,
+	Timeout,
+};
+
+enum class IrFoxAbortCause : uint8_t
+{
+	None,
+	BadSync,
+	BadLength,
+	Overflow,
+};
+
+struct IrFoxEmitTerminal
+{
+	int64_t start_sample;
+	int64_t detail_start_sample;
+	int64_t end_sample;
+	IrFoxTerminalReason reason;
+	IrFoxAbortCause cause;
+	uint8_t message_type;
+	uint8_t declared_size;
+	uint16_t received_bits;
+	uint8_t err_low;
+	uint8_t err_high;
+	uint8_t err_other;
+};
+
 using IrFoxOnBit = std::function<void(const IrFoxEmitBit&)>;
 using IrFoxOnPacket = std::function<void(const IrFoxEmitPacket&)>;
+using IrFoxOnTerminal = std::function<void(const IrFoxEmitTerminal&)>;
 
 class IrFoxDecoder
 {
 public:
 	void reset();
 	void processEdge(uint64_t sample, bool rising, uint32_t sample_rate_hz, const IrFoxOnBit& on_bit,
-					  const IrFoxOnPacket& on_pkt);
+					  const IrFoxOnPacket& on_pkt, const IrFoxOnTerminal& on_terminal);
-	void flushEnd(uint64_t last_sample, uint32_t sample_rate_hz, const IrFoxOnBit& on_bit, const IrFoxOnPacket& on_pkt);
+	void flushEnd(uint64_t last_sample, uint32_t sample_rate_hz, const IrFoxOnBit& on_bit, const IrFoxOnPacket& on_pkt,
+				  const IrFoxOnTerminal& on_terminal);
 
 private:
 	static uint16_t ceil_div_u16(uint16_t val, uint16_t divider);
@@ -67,10 +106,17 @@ private:
 	bool crc_check(uint8_t len, uint16_t& crc_out);
 
 	void first_rx();
+	void preamble_reset_to_idle();
+	void release_preamble_guard(double t_us);
+	void emit_terminal(IrFoxTerminalReason reason, IrFoxAbortCause cause, uint64_t end_sample,
+					   const IrFoxOnTerminal& on_terminal) const;
+	void abort_frame(double t_us, uint64_t end_sample, IrFoxAbortCause cause,
+					 const IrFoxOnTerminal& on_terminal);
+	void expire_preamble_candidate(double t_us);
 	void listen_start(double t_us);
-	void check_timeout(double t_us);
+	void check_timeout(double t_us, uint32_t sample_rate_hz, const IrFoxOnTerminal& on_terminal);
 	void write_to_buffer(bool bit, bool pack_trace_invert_fix, uint64_t cell_start_s, uint64_t cell_end_s,
-						 const IrFoxOnBit& on_bit, const IrFoxOnPacket& on_pkt,
+						 const IrFoxOnBit& on_bit, const IrFoxOnPacket& on_pkt, const IrFoxOnTerminal& on_terminal,
 						 IrFoxEmitBitMode emit_mode = IrFoxEmitBitMode::WithBubble);
 
 	double sample_to_us(uint64_t sample, uint32_t fs) const { return double(sample) * 1e6 / double(fs); }
@@ -101,6 +147,11 @@ private:
 	uint64_t preamble_bubble_start_sample_ = 0;
 	bool preamble_bubble_start_valid_ = false;
 	bool trim_first_data_bit_cell_ = false;
+	uint64_t packet_start_sample_ = 0;
+	bool packet_start_valid_ = false;
+	uint64_t packet_data_start_sample_ = 0;
+	bool packet_data_start_valid_ = false;
+	uint64_t byte_start_sample_ = 0;
 
 	double last_edge_time_us = 0;
 	uint64_t last_edge_sample = 0;
@@ -123,7 +174,18 @@ private:
 	int8_t all_count = 0;
 
 	uint16_t wrong_counter = 0;
-	int8_t preamb_front_counter = 0;
+	enum class PreambleState : uint8_t
+	{
+		Idle,
+		Candidate,
+		Locked,
+	};
+	PreambleState preamble_state_ = PreambleState::Idle;
+	uint8_t preamble_good_periods_ = 0;
+	uint32_t preamble_mean_period_us_ = 0;
+	double preamble_candidate_last_edge_us_ = 0;
+	double preamble_candidate_first_rise_us_ = 0;
+	bool preamble_candidate_first_rise_valid_ = false;
 	int16_t buf_bit_pos = 0;
 	bool is_data = true;
 	uint16_t i_data_buffer = 0;

Analyzer/raw/IR_Fox/src/IrFoxPacketClassifier.h

@@ -0,0 +1,172 @@
+#pragma once
+
+#include "IrFoxProtocolConstants.h"
+#include <cstdint>
+
+/**
+ * The decision made after IR_DecoderRaw::availableRaw() in IR_Decoder::_tick().
+ * It intentionally models only what a capture can prove: decoding, CRC, typed
+ * layout, and the receiver address.  It does not claim that application code
+ * subsequently acted on the delivered message.
+ */
+enum class IrFoxPacketOutcome : uint8_t
+{
+	Accepted,
+	RawOnlyUnknownType,
+	RawOnlyTypedLength,
+	IgnoredAddress,
+	RejectedCrc,
+	RejectedLength,
+};
+
+struct IrFoxPacketDecision
+{
+	IrFoxPacketOutcome outcome = IrFoxPacketOutcome::RejectedLength;
+	uint8_t message_type = 0;
+	uint8_t minimum_size = 0;
+	uint16_t destination = 0;
+	bool has_destination = false;
+
+	bool raw_accepted() const
+	{
+		return outcome == IrFoxPacketOutcome::Accepted || outcome == IrFoxPacketOutcome::RawOnlyUnknownType ||
+			   outcome == IrFoxPacketOutcome::RawOnlyTypedLength || outcome == IrFoxPacketOutcome::IgnoredAddress;
+	}
+};
+
+namespace irfox {
+
+constexpr uint8_t kMsgBack = 0U;
+constexpr uint8_t kMsgAccept = 1U;
+constexpr uint8_t kMsgRequest = 2U;
+constexpr uint8_t kMsgBackTo = 4U;
+constexpr uint8_t kMsgDataNoAccept = 6U;
+constexpr uint8_t kMsgDataAccept = 7U;
+constexpr uint16_t kBroadcastAddress = 65000U;
+
+inline uint8_t messageType(uint8_t header)
+{
+	return static_cast<uint8_t>((header >> 5U) & 0x07U);
+}
+
+inline uint8_t minimumPacketSize(uint8_t message_type)
+{
+	switch (message_type)
+	{
+	case kMsgDataAccept:
+	case kMsgDataNoAccept:
+	case kMsgBackTo:
+	case kMsgRequest:
+		return static_cast<uint8_t>(kMsgBytes + kAddrBytes + kAddrBytes + kCrcBytes);
+	case kMsgBack:
+		return static_cast<uint8_t>(kMsgBytes + kAddrBytes + kCrcBytes);
+	case kMsgAccept:
+		return static_cast<uint8_t>(kMsgBytes + kAddrBytes + 1U + kCrcBytes);
+	default:
+		return 0;
+	}
+}
+
+inline bool addressAcceptedByReceiver(uint16_t destination, uint16_t receiver_address)
+{
+	return receiver_address == 0U || destination == receiver_address || destination >= kBroadcastAddress;
+}
+
+inline IrFoxPacketDecision classifyPacket(const uint8_t* data, uint8_t observed_size, bool crc_ok,
+										  uint16_t receiver_address)
+{
+	IrFoxPacketDecision result;
+	if (data == nullptr)
+	{
+		result.outcome = IrFoxPacketOutcome::RejectedLength;
+		return result;
+	}
+
+	result.message_type = messageType(data[0]);
+	if (observed_size < kMsgBytes + kCrcBytes)
+	{
+		result.outcome = IrFoxPacketOutcome::RejectedLength;
+		return result;
+	}
+	if ((data[0] & 0x1FU) != observed_size)
+	{
+		result.outcome = IrFoxPacketOutcome::RejectedLength;
+		return result;
+	}
+	if (!crc_ok)
+	{
+		result.outcome = IrFoxPacketOutcome::RejectedCrc;
+		return result;
+	}
+
+	result.minimum_size = minimumPacketSize(result.message_type);
+	if (result.minimum_size == 0U)
+	{
+		result.outcome = IrFoxPacketOutcome::RawOnlyUnknownType;
+		return result;
+	}
+	if (observed_size < result.minimum_size)
+	{
+		result.outcome = IrFoxPacketOutcome::RawOnlyTypedLength;
+		return result;
+	}
+
+	const bool addressed = result.message_type == kMsgDataAccept || result.message_type == kMsgDataNoAccept ||
+						   result.message_type == kMsgBackTo || result.message_type == kMsgRequest;
+	if (addressed)
+	{
+		result.has_destination = true;
+		result.destination = static_cast<uint16_t>((static_cast<uint16_t>(data[3]) << 8U) | data[4]);
+		if (!addressAcceptedByReceiver(result.destination, receiver_address))
+		{
+			result.outcome = IrFoxPacketOutcome::IgnoredAddress;
+			return result;
+		}
+	}
+
+	result.outcome = IrFoxPacketOutcome::Accepted;
+	return result;
+}
+
+inline const char* packetOutcomeText(IrFoxPacketOutcome outcome)
+{
+	switch (outcome)
+	{
+	case IrFoxPacketOutcome::Accepted:
+		return "ACCEPT";
+	case IrFoxPacketOutcome::RawOnlyUnknownType:
+		return "RAW TYPE";
+	case IrFoxPacketOutcome::RawOnlyTypedLength:
+		return "RAW SIZE";
+	case IrFoxPacketOutcome::IgnoredAddress:
+		return "IGNORE ADDR";
+	case IrFoxPacketOutcome::RejectedCrc:
+		return "REJECT CRC";
+	case IrFoxPacketOutcome::RejectedLength:
+		return "REJECT LEN";
+	}
+	return "REJECT";
+}
+
+inline const char* messageTypeText(uint8_t message_type)
+{
+	switch (message_type)
+	{
+	case kMsgBack:
+		return "BACK";
+	case kMsgAccept:
+		return "ACCEPT";
+	case kMsgRequest:
+		return "REQUEST";
+	case kMsgBackTo:
+		return "BACK_TO";
+	case kMsgDataNoAccept:
+		return "DATA";
+	case kMsgDataAccept:
+		return "DATA_ACK";
+	default:
+		return "UNKNOWN";
+	}
+}
+
+} // namespace irfox

Analyzer/raw/IR_Fox/src/IrFoxProtocolConstants.h

@@ -11,8 +11,12 @@ constexpr uint32_t kBitTakts = kBitActiveTakts + kBitPauseTakts;
 constexpr uint32_t kBitTimeUs = kBitTakts * kCarrierPeriodUs;
 constexpr uint32_t kToleranceUs = 300U;
 
-/** Мин. длительность плато (мкс) для потокового анти-глитча в анализаторе; согласовано с IR_INPUT_MIN_PULSE_US. */
+/**
-constexpr uint32_t kMinFilteredPulseUs = 10U;
+ * Must match IR_INPUT_MIN_PULSE_US in the firmware configuration.  The current
+ * receiver configuration keeps this filter disabled, so a capture must not
+ * silently lose short edges that the receiver would see.
+ */
+constexpr uint32_t kMinFilteredPulseUs = 0U;
 
 constexpr uint8_t kBitPerByte = 8U;
 constexpr uint8_t kMsgBytes = 1;
@@ -27,6 +31,12 @@ constexpr uint8_t kDataByteSizeMax =
 
 constexpr uint8_t kPreambPulse = 3;
 constexpr uint8_t kPreambFronts = kPreambPulse * 2U;
+constexpr uint8_t kPreambleLockRisePeriods = 2U;
+constexpr uint8_t kPreambleJitterPct = 18U;
+constexpr uint32_t kPreambleJitterUsMin = 80U;
+constexpr uint32_t kPreamblePeriodMinFactorPct = 220U;
+constexpr uint32_t kPreamblePeriodMaxFactorPct = 340U;
+constexpr uint32_t kPreambleCandidateTimeoutMult = 1U;
 
 /** Отброс ложного подъёма после микро-LOW в паузе; зеркало IR_config.h (прошивка). */
 #ifndef IRFOX_SHORT_LOW_GLITCH_REJECT
@@ -53,6 +63,19 @@ inline bool aroundRisePeriod(uint32_t periodUs, uint32_t riseSyncTimeUs)
 	return lo < periodUs && periodUs < hi;
 }
 
+inline uint32_t preambleJitterTolUs(uint32_t baselineUs)
+{
+	const uint32_t pct = (baselineUs * kPreambleJitterPct) / 100U;
+	return pct > kPreambleJitterUsMin ? pct : kPreambleJitterUsMin;
+}
+
+inline bool preambleRisePeriodCoarseOk(uint32_t periodUs)
+{
+	const uint32_t min_period = (kBitTimeUs * kPreamblePeriodMinFactorPct) / 100U;
+	const uint32_t max_period = (kBitTimeUs * kPreamblePeriodMaxFactorPct) / 100U;
+	return periodUs >= min_period && periodUs <= max_period;
+}
+
 inline void irfoxGlitchPhaseNudgeUs(double edge_us, uint32_t rise_sync_us, double& prev_rise_us)
 {
 #if IRFOX_GLITCH_REJECT_PHASE_NUDGE

Analyzer/raw/IR_Fox/tests/IrFoxDecoderTests.cpp

@@ -0,0 +1,282 @@
+#include "IrFoxDecoder.h"
+#include <cstddef>
+#include <cstdio>
+#include <cstdlib>
+#include <cstdint>
+#include <vector>
+
+#define CHECK(expression)                                                                                              \
+	do                                                                                                                   \
+	{                                                                                                                    \
+		if (!(expression))                                                                                                 \
+		{                                                                                                                  \
+			std::fprintf(stderr, "CHECK failed: %s (%s:%d)\n", #expression, __FILE__, __LINE__);                           \
+			std::exit(EXIT_FAILURE);                                                                                        \
+		}                                                                                                                  \
+	} while (false)
+
+namespace {
+
+uint8_t crc8(const uint8_t* data, uint8_t end, uint8_t poly)
+{
+	uint8_t crc = 0xFF;
+	for (uint8_t i = 0; i < end; ++i)
+	{
+		crc ^= data[i];
+		for (uint8_t bit = 0; bit < 8; ++bit)
+			crc = (crc & 0x80U) ? static_cast<uint8_t>((crc << 1U) ^ poly) : static_cast<uint8_t>(crc << 1U);
+	}
+	return crc;
+}
+
+struct DecoderHarness
+{
+	IrFoxDecoder decoder;
+	std::vector<IrFoxEmitPacket> packets;
+	std::vector<IrFoxEmitBit> events;
+	std::vector<IrFoxEmitTerminal> terminals;
+	uint64_t phase = 0;
+	bool collect_bit_events = true;
+	static constexpr uint32_t kFs = 1000000U;
+
+	explicit DecoderHarness(bool collect_bits = true) : collect_bit_events(collect_bits)
+	{
+		decoder.reset();
+	}
+
+	void edge(uint64_t sample, bool rising)
+	{
+		IrFoxOnBit on_bit;
+		if (collect_bit_events)
+			on_bit = [this](const IrFoxEmitBit& event) { events.push_back(event); };
+		decoder.processEdge(sample, rising, kFs, on_bit,
+			[this](const IrFoxEmitPacket& packet) { packets.push_back(packet); },
+			[this](const IrFoxEmitTerminal& terminal) { terminals.push_back(terminal); });
+	}
+
+	void lockPreamble()
+	{
+		lockPreambleAt(40000U);
+	}
+
+	void lockPreambleAt(uint64_t first_rise)
+	{
+		constexpr uint64_t period = irfox::kBitTimeUs * 3U;
+		edge(first_rise, true);
+		edge(first_rise + 700U, false);
+		edge(first_rise + period, true);
+		edge(first_rise + period + 700U, false);
+		edge(first_rise + period * 2U, true);
+		phase = first_rise + period * 2U + period / 2U;
+	}
+
+	void emitCell(bool bit)
+	{
+		// The decoder calls a cell a one when the inactive (HIGH) interval is
+		// longer than the active (LOW) interval. The waveform is TSOP output.
+		const uint64_t high_us = bit ? 262U : 700U;
+		edge(phase + high_us, false);
+		phase += irfox::kBitTimeUs;
+		edge(phase, true);
+	}
+
+	void emitByte(uint8_t value, bool emit_sync)
+	{
+		for (uint8_t i = 0; i < 8; ++i)
+			emitCell((value & static_cast<uint8_t>(0x80U >> i)) != 0U);
+		if (emit_sync)
+		{
+			const bool sync = (value & 1U) == 0U;
+			for (uint8_t i = 0; i < irfox::kSyncBits; ++i)
+				emitCell(sync);
+		}
+	}
+
+	void emitPacket(const std::vector<uint8_t>& packet)
+	{
+		for (size_t i = 0; i < packet.size(); ++i)
+			emitByte(packet[i], i + 1U != packet.size());
+	}
+
+	void flushAt(uint64_t sample)
+	{
+		IrFoxOnBit on_bit;
+		if (collect_bit_events)
+			on_bit = [this](const IrFoxEmitBit& event) { events.push_back(event); };
+		decoder.flushEnd(sample, kFs, on_bit,
+			[this](const IrFoxEmitPacket& packet) { packets.push_back(packet); },
+			[this](const IrFoxEmitTerminal& terminal) { terminals.push_back(terminal); });
+	}
+};
+
+std::vector<uint8_t> makeValidPacket()
+{
+	std::vector<uint8_t> packet{0xE7, 0x00, 0x01, 0x00, 0x2A, 0x00, 0x00};
+	packet[5] = crc8(packet.data(), 5, irfox::kPoly1);
+	packet[6] = crc8(packet.data(), 6, irfox::kPoly2);
+	return packet;
+}
+
+void assertBadLengthAbortsAndRecovers(uint8_t declared_size)
+{
+	DecoderHarness harness;
+	harness.lockPreamble();
+	const uint8_t header = static_cast<uint8_t>(0xE0U | declared_size);
+	harness.emitByte(header, false);
+
+	CHECK(harness.packets.empty());
+	CHECK(harness.terminals.size() == 1U);
+	CHECK(harness.terminals[0].reason == IrFoxTerminalReason::Abort);
+	CHECK(harness.terminals[0].cause == IrFoxAbortCause::BadLength);
+	CHECK(harness.terminals[0].message_type == 7U);
+	CHECK(harness.terminals[0].declared_size == declared_size);
+	CHECK(harness.terminals[0].received_bits == irfox::kBitPerByte);
+
+	// Firmware abortFrame() releases the 30.288 ms preamble guard.  A receiver
+	// that merely sets is_wrong_pack will miss this complete nearby frame.
+	const uint64_t next_preamble = harness.phase + 5000U;
+	harness.lockPreambleAt(next_preamble);
+	harness.emitPacket(makeValidPacket());
+
+	CHECK(harness.packets.size() == 1U);
+	CHECK(harness.packets[0].crc_ok);
+	CHECK(harness.packets[0].start_sample == static_cast<int64_t>(next_preamble));
+	CHECK(harness.terminals.size() == 1U);
+}
+
+} // namespace
+
+int main()
+{
+	const std::vector<uint8_t> packet = makeValidPacket();
+
+	DecoderHarness valid;
+	valid.lockPreamble();
+	valid.emitPacket(packet);
+	CHECK(valid.packets.size() == 1U);
+	CHECK(valid.packets[0].crc_ok);
+	CHECK(valid.packets[0].pack_size == packet.size());
+	CHECK(valid.packets[0].start_sample == 40000);
+	CHECK(valid.packets[0].start_sample < valid.packets[0].end_sample);
+	bool saw_preamble = false;
+	std::vector<uint8_t> decoded_bytes;
+	for (const IrFoxEmitBit& event : valid.events)
+	{
+		if (event.frame_type == IRF_FT_PREAMBLE)
+		{
+			saw_preamble = true;
+			CHECK(event.start_sample == 40000);
+		}
+		if (event.frame_type == IRF_FT_DATA_BYTE)
+			decoded_bytes.push_back(static_cast<uint8_t>(event.bit_value));
+	}
+	CHECK(saw_preamble);
+	CHECK(decoded_bytes.size() == packet.size());
+	for (size_t i = 0; i < packet.size(); ++i)
+		CHECK(decoded_bytes[i] == packet[i]);
+
+	for (uint8_t declared_size = 0; declared_size < irfox::kMsgBytes + irfox::kCrcBytes; ++declared_size)
+		assertBadLengthAbortsAndRecovers(declared_size);
+
+	// Overview supplies no per-bit callback. Terminal reporting must not depend
+	// on Detailed-mode bit/event generation.
+	DecoderHarness bad_sync(false);
+	bad_sync.lockPreamble();
+	bad_sync.emitByte(0xE7, false);
+	// Header 0xE7 ends in one, while the first sync bit must be inverted.
+	bad_sync.emitCell(true);
+	CHECK(bad_sync.terminals.empty());
+	bad_sync.emitCell(true);
+	CHECK(bad_sync.terminals.empty());
+	bad_sync.emitCell(true);
+	CHECK(bad_sync.events.empty());
+	CHECK(bad_sync.terminals.size() == 1U);
+	CHECK(bad_sync.terminals[0].reason == IrFoxTerminalReason::Abort);
+	CHECK(bad_sync.terminals[0].cause == IrFoxAbortCause::BadSync);
+	CHECK(bad_sync.terminals[0].message_type == 7U);
+	CHECK(bad_sync.terminals[0].declared_size == 7U);
+	CHECK(bad_sync.terminals[0].received_bits == irfox::kBitPerByte);
+	const uint64_t after_sync_abort = bad_sync.phase + 5000U;
+	bad_sync.lockPreambleAt(after_sync_abort);
+	bad_sync.emitPacket(packet);
+	CHECK(bad_sync.packets.size() == 1U);
+	CHECK(bad_sync.packets[0].crc_ok);
+	CHECK(bad_sync.packets[0].start_sample == static_cast<int64_t>(after_sync_abort));
+	CHECK(bad_sync.terminals.size() == 1U);
+
+	DecoderHarness stale_candidate;
+	constexpr uint64_t stale_rise = 40000U;
+	const uint64_t candidate_gap =
+		irfox::irTimeoutUs(irfox::kBitTimeUs) + 1U; // New 1x timeout, still below the old 3x timeout.
+	const uint64_t fresh_preamble = stale_rise + candidate_gap;
+	stale_candidate.edge(stale_rise, true);
+	stale_candidate.lockPreambleAt(fresh_preamble);
+	stale_candidate.emitPacket(packet);
+	CHECK(stale_candidate.packets.size() == 1U);
+	CHECK(stale_candidate.packets[0].crc_ok);
+	CHECK(stale_candidate.packets[0].start_sample == static_cast<int64_t>(fresh_preamble));
+	CHECK(stale_candidate.terminals.empty());
+
+	// If reception times out after PRE lock but before the first data bit, the
+	// Detailed terminal span must begin immediately after the separate PRE frame.
+	DecoderHarness pre_only;
+	pre_only.lockPreamble();
+	const IrFoxEmitBit* pre_event = nullptr;
+	for (const IrFoxEmitBit& event : pre_only.events)
+	{
+		if (event.frame_type == IRF_FT_PREAMBLE)
+			pre_event = &event;
+	}
+	CHECK(pre_event != nullptr);
+	constexpr uint64_t preamble_period = irfox::kBitTimeUs * 3U;
+	const uint64_t pre_lock_edge = 40000U + preamble_period * 2U;
+	const uint64_t abort_silence = 2U * irfox::irTimeoutUs(irfox::kBitTimeUs);
+	pre_only.flushAt(pre_lock_edge + abort_silence + 1U);
+	CHECK(pre_only.terminals.size() == 1U);
+	CHECK(pre_only.terminals[0].reason == IrFoxTerminalReason::Timeout);
+	CHECK(pre_only.terminals[0].received_bits == 0U);
+	CHECK(pre_only.terminals[0].detail_start_sample == pre_event->end_sample + 1);
+	CHECK(pre_only.terminals[0].end_sample == static_cast<int64_t>(pre_lock_edge + abort_silence));
+
+	DecoderHarness truncated;
+	truncated.lockPreamble();
+	truncated.emitByte(0xE7, true);
+	CHECK(truncated.packets.empty());
+	truncated.flushAt(truncated.phase + abort_silence);
+	CHECK(truncated.terminals.empty());
+	truncated.flushAt(truncated.phase + abort_silence + 1U);
+	CHECK(truncated.packets.empty());
+	CHECK(truncated.terminals.size() == 1U);
+	CHECK(truncated.terminals[0].reason == IrFoxTerminalReason::Timeout);
+	CHECK(truncated.terminals[0].cause == IrFoxAbortCause::None);
+	CHECK(truncated.terminals[0].message_type == 7U);
+	CHECK(truncated.terminals[0].declared_size == 7U);
+	CHECK(truncated.terminals[0].received_bits == irfox::kBitPerByte);
+	CHECK(truncated.terminals[0].end_sample == static_cast<int64_t>(truncated.phase + abort_silence));
+	truncated.flushAt(truncated.phase + abort_silence + 100U);
+	CHECK(truncated.terminals.size() == 1U);
+	const uint64_t after_timeout = truncated.phase + abort_silence + 5000U;
+	truncated.lockPreambleAt(after_timeout);
+	truncated.emitPacket(packet);
+	CHECK(truncated.packets.size() == 1U);
+	CHECK(truncated.packets[0].crc_ok);
+	CHECK(truncated.packets[0].start_sample == static_cast<int64_t>(after_timeout));
+	CHECK(truncated.terminals.size() == 1U);
+
+	// With no flush/tick between frames, the first rise strictly beyond 2T both
+	// closes the old frame and opens the new preamble. Inclusive spans must not
+	// share that sample.
+	DecoderHarness adjacent_timeout;
+	adjacent_timeout.lockPreamble();
+	adjacent_timeout.emitByte(0xE7, true);
+	const uint64_t adjacent_preamble = adjacent_timeout.phase + abort_silence + 1U;
+	adjacent_timeout.lockPreambleAt(adjacent_preamble);
+	adjacent_timeout.emitPacket(packet);
+	CHECK(adjacent_timeout.terminals.size() == 1U);
+	CHECK(adjacent_timeout.terminals[0].reason == IrFoxTerminalReason::Timeout);
+	CHECK(adjacent_timeout.packets.size() == 1U);
+	CHECK(adjacent_timeout.packets[0].crc_ok);
+	CHECK(adjacent_timeout.terminals[0].end_sample < adjacent_timeout.packets[0].start_sample);
+	CHECK(adjacent_timeout.packets[0].start_sample == static_cast<int64_t>(adjacent_preamble));
+	return 0;
+}

Analyzer/raw/IR_Fox/tests/IrFoxPacketClassifierTests.cpp

@@ -0,0 +1,43 @@
+#include "IrFoxPacketClassifier.h"
+#include <cassert>
+#include <cstdint>
+
+static IrFoxPacketDecision classify(const uint8_t* data, uint8_t size, bool crc_ok, uint16_t id = 0)
+{
+	return irfox::classifyPacket(data, size, crc_ok, id);
+}
+
+int main()
+{
+	const uint8_t data_to_42[] = {0xE7, 0x00, 0x01, 0x00, 0x2A, 0x00, 0x00};
+	assert(classify(data_to_42, 7, true, 42).outcome == IrFoxPacketOutcome::Accepted);
+	assert(classify(data_to_42, 7, true, 41).outcome == IrFoxPacketOutcome::IgnoredAddress);
+
+	const uint8_t broadcast_data[] = {0xC7, 0x00, 0x01, 0xFD, 0xE8, 0x00, 0x00};
+	assert(classify(broadcast_data, 7, true, 41).outcome == IrFoxPacketOutcome::Accepted);
+	const uint8_t request_to_42[] = {0x47, 0x00, 0x01, 0x00, 0x2A, 0x00, 0x00};
+	assert(classify(request_to_42, 7, true, 42).outcome == IrFoxPacketOutcome::Accepted);
+	assert(classify(request_to_42, 7, true, 41).outcome == IrFoxPacketOutcome::IgnoredAddress);
+	const uint8_t back_to_42[] = {0x87, 0x00, 0x01, 0x00, 0x2A, 0x00, 0x00};
+	assert(classify(back_to_42, 7, true, 42).outcome == IrFoxPacketOutcome::Accepted);
+	assert(classify(back_to_42, 7, true, 41).outcome == IrFoxPacketOutcome::IgnoredAddress);
+
+	const uint8_t back[] = {0x05, 0x00, 0x01, 0x00, 0x00};
+	assert(classify(back, 5, true, 41).outcome == IrFoxPacketOutcome::Accepted);
+
+	const uint8_t accept[] = {0x26, 0x00, 0x01, 0x55, 0x00, 0x00};
+	assert(classify(accept, 6, true, 41).outcome == IrFoxPacketOutcome::Accepted);
+
+	const uint8_t unknown[] = {0x63, 0x00, 0x00};
+	assert(classify(unknown, 3, true).outcome == IrFoxPacketOutcome::RawOnlyUnknownType);
+
+	const uint8_t short_data[] = {0xE5, 0x00, 0x01, 0x00, 0x2A};
+	assert(classify(short_data, 5, true).outcome == IrFoxPacketOutcome::RawOnlyTypedLength);
+	assert(classify(data_to_42, 7, false).outcome == IrFoxPacketOutcome::RejectedCrc);
+
+	const uint8_t too_short[] = {0xE2, 0x00};
+	const IrFoxPacketDecision short_decision = classify(too_short, 2, false);
+	assert(short_decision.outcome == IrFoxPacketOutcome::RejectedLength);
+	assert(short_decision.message_type == irfox::kMsgDataAccept);
+	return 0;
+}

IR_Decoder.cpp

@@ -162,7 +162,9 @@ void IR_Decoder::_tick()
             if (addrAcceptSendTo && addrAcceptSendTo < IR_Broadcast)
                 isWaitingAcceptSend = true;
         }
-        gotRaw.set(&packInfo, id);
+        // Raw keeps the decoder's common minimum-size contract. Known packet
+        // layouts are validated by their typed BasePack::set calls above.
+        gotRaw.set(&packInfo, id, false);
     }
     if (isWaitingAcceptSend && millis() - acceptSendTimer > acceptDelay)
     {

IR_DecoderRaw.cpp

@@ -403,6 +403,7 @@ inline void IR_DecoderRaw::checkTimeout()
 #endif
         const uint16_t expected = (i_dataBuffer >= 8U) ? uint16_t(dataBuffer[0] & IR_MASK_MSG_INFO) : 0U;
         rxBriefLog(RxBriefReason::Timeout, i_dataBuffer, expected, micros());
+        noteRxEnd(RxEndReason::Timeout, micros());
         isRecive = false;      // приём завершён
         msgTypeReceive = 0;
         // Как после listenStart(): без сброса isReciveRaw + firstRX() декодер остаётся
@@ -417,6 +418,62 @@ inline void IR_DecoderRaw::checkTimeout()
 }
 // ====================================================================
 
+void IR_DecoderRaw::noteRxEnd(RxEndReason reason, uint32_t tUs)
+{
+    rxEnd.seq++;
+    rxEnd.reason = reason;
+    rxEnd.msgType = (i_dataBuffer >= 8U * msgBytes) ? (uint8_t)((dataBuffer[0] >> 5) & IR_MASK_MSG_TYPE) : 0xFF;
+    rxEnd.packSize = (uint8_t)packSize;
+    rxEnd.tUs = tUs;
+    rxEnd.expectedEndUs = (packSize >= msgBytes + crcBytes)
+        ? rxLockTimeUsVal + irLockToDecodeEndUs((uint8_t)packSize) + irTicksToUs((uint32_t)syncBits * irBitTicks)
+        : 0U;
+}
+
+void IR_DecoderRaw::abortFrame(uint32_t tUs)
+{
+#if defined(IRDEBUG_SERIAL_PACK)
+    packTraceOnTimeoutOrAbort(false);
+#endif
+    noteRxEnd(RxEndReason::Abort, tUs);
+    isRecive = false;
+    isReciveRaw = false;
+    msgTypeReceive = 0;
+    firstRX();
+    releasePreambleGuard(tUs);
+}
+
+// После обрыва кадра «длинная тишина» (IR_timeout × 2 ≈ 30 мс) перед новым кандидатом преамбулы не требуется.
+// prevRise — последний ДЕКОДИРОВАННЫЙ фронт; после abort он свежий, а фронты, отброшенные гвардом, его не двигают,
+// поэтому валидный кадр, начавшийся через <30 мс после обрыва мусора, проглатывался целиком без счётчика
+// (стенд 09.09: КУ теряла пинг машинки после обрывков чужого заднего и всплеска её дальномера за 24 мс до пинга).
+// Ложных захватов это не добавляет: хвост оборванного кадра (период фронтов 962 мкс, синхробиты ~1100) не проходит
+// грубый фильтр периода преамбулы (2116…3270 мкс), а настоящая преамбула перезапускает кандидата по паузе > IR_timeout.
+// После чистого конца кадра гвард остаётся: там он отсекает хвост синхробитов.
+void IR_DecoderRaw::releasePreambleGuard(uint32_t tUs)
+{
+    prevRise = tUs - IR_timeout * 2U - 1U;   // «тишина уже была»: (front.time - prevRise) > longSilence для следующего фронта
+}
+
+void IR_DecoderRaw::expirePreambleCandidate()
+{
+    if (preambleState != PreambleState::Candidate || rxTimeoutPipelineBusy())
+        return;
+    if ((micros() - preambleCandidateLastEdgeTime) > IR_timeout * (uint32_t)IR_PREAMBLE_CANDIDATE_TIMEOUT_MULT)
+    {
+        if (preambleGoodPeriods)
+            rxBriefLog(RxBriefReason::Preamble, preambleGoodPeriods, 0, micros());
+        preambleResetToIdle();
+    }
+}
+
+uint32_t IR_DecoderRaw::rxExpectedEndUs() const
+{
+    if (!isRecive || preambleState != PreambleState::Locked || isWrongPack || packSize < msgBytes + crcBytes)
+        return 0;
+    return rxLockTimeUsVal + irLockToDecodeEndUs((uint8_t)packSize);
+}
+
 void IR_DecoderRaw::tick()
 {
 #if IR_RX_BRIEF_LOG
@@ -471,15 +528,16 @@ void IR_DecoderRaw::tick()
     if (!processedFront)
     {
         isSubBufferOverflow = false;
-        listenStart();
         checkTimeout();
+        listenStart();
+        expirePreambleCandidate();
 #if defined(IR_EDGE_TRACE)
         while (edgeTraceFlushChunk(Serial, 48) > 0) {}
 #endif
         return;
     } // Если данных нет - ничего не делаем
-    listenStart();
     checkTimeout();
+    listenStart();
 #if IR_RX_BRIEF_LOG
     rxBriefFlushDeferredIsrLogs();
 #endif
@@ -780,10 +838,7 @@ void IR_DecoderRaw::writeToBuffer(bool bit, bool packTraceInvertFix)
     {
         // Как checkTimeout/listenStart: firstRX() сбрасывает буфер битов, преамбулу и
         // pulseFilterReset() — при IR_INPUT_MIN_PULSE_US > 0 иначе остаётся «хвост» в hold/filtered.
-        isRecive = false;
+        abortFrame(micros());
-        isReciveRaw = false;
-        msgTypeReceive = 0;
-        firstRX();
         return;
     }
 
@@ -851,6 +906,8 @@ void IR_DecoderRaw::writeToBuffer(bool bit, bool packTraceInvertFix)
 #if defined(IRDEBUG_SERIAL_PACK)
                         packTraceEmitErrorFlash(F("ERROR: Wrong sync bit"));
 #endif
+                        abortFrame(micros());   // битый кадр не удерживает приёмник до таймаута
+                        return;
                     }
                 }
             }
@@ -878,8 +935,12 @@ void IR_DecoderRaw::writeToBuffer(bool bit, bool packTraceInvertFix)
             // B1: под-минимальная длина (1..2) физически не несёт CRC (min кадр = msg+crc = 3 байта) → шум/битьё.
             // Без отсева packSize==1 даёт crcCheck(1-2) → len=255 → OOB-чтение dataBuffer[0..256] (массив 38).
             // packSize>=3 (в т.ч. будущие компактные кадры) обрабатываются как обычно.
-            if (packSize != 0 && packSize < msgBytes + crcBytes)
+            if (packSize < msgBytes + crcBytes)   // 0..2: кадр физически не несёт CRC — шум/битьё
+            {
                 isWrongPack = true;
+                abortFrame(micros());
+                return;
+            }
         }
 
         // Тип приёма (для isReceive): выставляем сразу после первого байта, ДО проверки «Конец».
@@ -903,6 +964,7 @@ void IR_DecoderRaw::writeToBuffer(bool bit, bool packTraceInvertFix)
             preambleResetToIdle();
             msgTypeReceive = 0;
             isAvailable = crcCheck(packSize - crcBytes, crcValue);
+            noteRxEnd(isAvailable ? RxEndReason::Ok : RxEndReason::Crc, micros());
 
 #ifdef BRUTEFORCE_CHECK
             {
@@ -1622,7 +1684,10 @@ bool IR_DecoderRaw::preambleProcessEdge(const FrontStorage &front)
         if (!isReciveRaw && front.dir &&
             ((prevRise == 0U && front.time > longSilence) ||
              (prevRise != 0U && (uint32_t)(front.time - prevRise) > longSilence)))
+        {
             preambleStartCandidate(front);
+            return true;
+        }
     }
 
     if (preambleState == PreambleState::Candidate)
@@ -1703,6 +1768,8 @@ bool IR_DecoderRaw::preambleProcessEdge(const FrontStorage &front)
             isRecive = true;
             isReciveRaw = true;
             risePeriod = preambleMeanPeriod;
+            rxLockSeqCnt++;
+            rxLockTimeUsVal = front.time;
 #if defined(IRDEBUG_SERIAL_PACK)
             packTraceResetFrame();
             packTraceOpen = true;

IR_DecoderRaw.h

@@ -52,6 +52,40 @@ public:
     inline bool isOverflow() { return isBufferOverflow; }; // Буффер переполнился
     bool isSubOverflow();
     volatile inline bool isReciving() { return isRecive; }; // Возвращает true, если происходит приём пакета
+    // Активность линии по СОСТОЯНИЮ (не по хардкод-длительности): кадр залочен ИЛИ формируется
+    // ВАЛИДНАЯ преамбула (>=1 совпавший по периоду фронт — отличает реальный кадр от одиночного
+    // шумового фронта, который лишь заводит Candidate, но не набирает goodPeriods). Для гейта заднего:
+    // «не стрелять, пока на линии идёт/формируется кадр (напр. ответ точки)». Аддитивно, const.
+    inline bool rxLineActive() const {
+        return isRecive ||
+               (preambleState == PreambleState::Candidate && preambleGoodPeriods >= 1U);
+    }
+    // Объявленная длина ПРИНИМАЕМОГО кадра (байт) из ПЕРВОГО байта, если он уже принят и валиден;
+    // иначе 0 (ещё не знаем / битый). До CRC это НЕДОВЕРЕННОЕ значение — потребитель, получив 0
+    // или чрезмерное, обязан брать rxMaxPackSize() (безопасно держать задний до конца макс.кадра).
+    inline uint16_t rxDeclaredPackSize() const {
+        return (isRecive && packSize && !isWrongPack) ? packSize : 0;
+    }
+    // Протокольный МАКСИМУМ длины кадра (байт) — верхняя граница бюджета удержания заднего.
+    static constexpr uint16_t rxMaxPackSize() { return (uint16_t)irMaxPackSize; }
+
+    // ---- Наблюдаемость приёма по СОСТОЯНИЮ: лок / ожидаемый конец / факт завершения с причиной ----
+    enum class RxEndReason : uint8_t { None = 0, Ok, Crc, Timeout, Abort };
+    struct RxEndInfo {
+        uint16_t seq = 0;                 // номер завершения (растёт на каждом терминале)
+        RxEndReason reason = RxEndReason::None;
+        uint8_t msgType = 0xFF;           // 0xFF = первый байт не был принят
+        uint8_t packSize = 0;             // объявленная длина (0 = неизвестна)
+        uint32_t tUs = 0;                 // micros() терминала
+        uint32_t expectedEndUs = 0;       // расчётный конец кадра в эфире (0 = неизвестен)
+    };
+    uint16_t rxLockSeq() const { return rxLockSeqCnt; }          // ++ в момент лока преамбулы
+    uint32_t rxLockTimeUs() const { return rxLockTimeUsVal; }    // метка фронта лока (ISR-время)
+    /// Тип принимаемого кадра (3 бита) после первого байта; 0xFF пока неизвестен / приём не идёт.
+    uint8_t rxMsgType() const { return (isRecive && packSize) ? (uint8_t)((dataBuffer[0] >> 5) & IR_MASK_MSG_TYPE) : 0xFF; }
+    const RxEndInfo &rxLastEnd() const { return rxEnd; }
+    /// Расчётный момент последнего бита данных текущего кадра (по объявленной длине); 0 = не Locked / длина неизвестна.
+    uint32_t rxExpectedEndUs() const;
     uint32_t pulseFilterDroppedByFilteredOverflow() const { return 0; }
     uint32_t pulseFilterDroppedByHoldOverflow() const { return pulseFilterDropHoldOverflow; }
     uint32_t pulseFilterDroppedGlitchPairs() const { return pulseFilterDropGlitchPairs; }
@@ -147,6 +181,13 @@ private:
         Locked = 2
     };
     PreambleState preambleState = PreambleState::Idle;
+    uint16_t rxLockSeqCnt = 0;
+    uint32_t rxLockTimeUsVal = 0;
+    RxEndInfo rxEnd;
+    void noteRxEnd(RxEndReason reason, uint32_t tUs);   // терминал: фиксирует тип/длину/расчётный конец
+    void abortFrame(uint32_t tUs);                     // немедленный сброс битого кадра (sync/длина/overflow)
+    void releasePreambleGuard(uint32_t tUs);           // после abort: новый кандидат преамбулы без ожидания длинной тишины
+    void expirePreambleCandidate();                    // кандидат без фронтов дольше таймаута → Idle
     uint8_t preambleGoodPeriods = 0;
     uint16_t preambleMeanPeriod = 0;
     uint32_t preambleCandidateLastEdgeTime = 0;

IR_Encoder.cpp

@@ -352,6 +352,29 @@ bool IR_Encoder::txEmitTick(TxFsmState &st, const uint8_t *sendBufferLocal, bool
     return txAdvanceAfterOutput(st, sendBufferLocal);
 }
 
+// Обход кадра по границам ранов: между границами автомат выдаёт st.toggleCounter+1 тактов
+// уровня st.state (txAdvanceAfterOutput считает toggleCounter до нуля, затем txAdvanceBoundary
+// открывает следующий ран). Даёт ту же последовательность тактов, что потиковый обход, но за
+// число шагов = число ранов (пинг: ~230 вместо ~8700 тактов — на 12 МГц это ~30 мс перед стартом DMA).
+template <typename Emit>
+bool IR_Encoder::txWalkRuns(TxFsmState &st, const uint8_t *sendBufferLocal, Emit emit)
+{
+    for (;;)
+    {
+        const bool gate = st.state;
+        const uint32_t lenTicks = (uint32_t)st.toggleCounter + 1U;
+        if (!emit(gate, lenTicks))
+        {
+            return false;
+        }
+        st.toggleCounter = 0;
+        if (!txAdvanceBoundary(st, sendBufferLocal))
+        {
+            return true;
+        }
+    }
+}
+
 void IR_Encoder::loadTxFsmFromMembers(TxFsmState &st) const
 {
     st.sendLen = sendLen;
@@ -476,28 +499,27 @@ size_t IR_Encoder::buildGateRuns(const uint8_t *packet, uint8_t len, IR_TxGateRu
     st.currentBitSequence = bitHigh;
 
     size_t runCount = 0;
-    bool isActive = true;
+    const bool ok = txWalkRuns(st, sendBufferLocal, [&](bool gate, uint32_t lenTicks) -> bool {
-    while (isActive)
-    {
-        bool gate = false;
-        isActive = txEmitTick(st, sendBufferLocal, gate);
-
         if (runCount > 0 && outRuns[runCount - 1].gate == gate)
         {
-            outRuns[runCount - 1].lenTicks = (uint16_t)(outRuns[runCount - 1].lenTicks + 1U);
+            const uint32_t merged = (uint32_t)outRuns[runCount - 1].lenTicks + lenTicks;
-        }
+            if (merged > 65535U)
-        else
-        {
-            if (runCount >= maxRuns)
             {
-                return 0;
+                return false;
             }
-            outRuns[runCount].gate = gate;
+            outRuns[runCount - 1].lenTicks = (uint16_t)merged;
-            outRuns[runCount].lenTicks = 1U;
+            return true;
-            runCount++;
         }
-    }
+        if (runCount >= maxRuns || lenTicks > 65535U)
-    return runCount;
+        {
+            return false;
+        }
+        outRuns[runCount].gate = gate;
+        outRuns[runCount].lenTicks = (uint16_t)lenTicks;
+        runCount++;
+        return true;
+    });
+    return ok ? runCount : 0;
 }
 
 size_t IR_Encoder::buildPhysicalGateRuns(const uint8_t *packet, uint8_t len, IR_TxGateRun *outRuns, size_t maxRuns, uint16_t multiply)
@@ -564,40 +586,29 @@ size_t IR_Encoder::buildPhysicalGateRuns(const uint8_t *packet, uint8_t len, IR_
     bool currentGate = false;
     uint32_t currentLogicalLen = 0;
     bool havePendingRun = false;
-    bool isActive = true;
+    const bool ok = txWalkRuns(st, sendBufferLocal, [&](bool gate, uint32_t lenTicks) -> bool {
-    while (isActive)
+        if (havePendingRun && currentGate == gate)
-    {
-        bool gate = false;
-        isActive = txEmitTick(st, sendBufferLocal, gate);
-
-        if (!havePendingRun)
         {
-            currentGate = gate;
+            currentLogicalLen += lenTicks;
-            currentLogicalLen = 1U;
+            return true;
-            havePendingRun = true;
-            continue;
         }
-
+        if (havePendingRun && !appendPhysicalRun(currentGate, currentLogicalLen, runCount))
-        if (currentGate == gate)
         {
-            currentLogicalLen++;
+            return false;
-            continue;
         }
-
-        if (!appendPhysicalRun(currentGate, currentLogicalLen, runCount))
-        {
-            return 0;
-        }
-
         currentGate = gate;
-        currentLogicalLen = 1U;
+        currentLogicalLen = lenTicks;
+        havePendingRun = true;
+        return true;
+    });
+    if (!ok)
+    {
+        return 0;
     }
-
     if (havePendingRun && !appendPhysicalRun(currentGate, currentLogicalLen, runCount))
     {
         return 0;
     }
-
     return runCount;
 }
 
@@ -1183,26 +1194,8 @@ uint8_t IR_Encoder::bitLow[2] = {
 
 uint32_t IR_Encoder::calculateSendTime(uint8_t packSize) const
 {
-    // Расчет времени отправки пакета в миллисекундах
+    // Полное время кадра в эфире по формуле FSM (преамбула + байты с синхробитами), округление вверх до мс.
-    
+    return (irFrameAirtimeUs(packSize) + 999U) / 1000U;
-    // Время преамбулы: preambPulse * 2 фронта * bitTakts тактов
-    uint32_t preambTime = preambPulse * 2 * bitTakts;
-    
-    // Время данных: количество бит * bitTakts тактов
-    uint32_t dataTime = packSize * 8 * bitTakts;
-    
-    // Время синхронизации: syncBits * 2 фронта * bitTakts тактов
-    uint32_t syncTime = syncBits * 2 * bitTakts;
-    
-    // Общее время в тактах
-    uint32_t totalTakts = preambTime + dataTime + syncTime;
-    
-    // Конвертируем в миллисекунды
-    // carrierPeriod - период несущей в микросекундах
-    // totalTakts * carrierPeriod / 1000 = время в миллисекундах
-    uint32_t sendTimeMs = (totalTakts * carrierPeriod) / 1000;
-    
-    return sendTimeMs;
 }
 
 // Функции для тестирования времени отправки без фактической отправки

IR_Encoder.h

@@ -62,6 +62,10 @@ public:
     /// @param decPair Если задан, конструктор регистрирует этот один приёмник как blind-decoder
     ///        (аналог setBlindDecoders() для одного RX).
     IR_Encoder(uint8_t pin, uint16_t addr = 0, IR_DecoderRaw *decPair = nullptr, bool autoHandle = true);
+    /// Публичная оценка airtime кадра (мс) по его полной длине в байтах (packSize). Чистая функция
+    /// протокольных констант — подходит и для приёма (напр. бюджет удержания заднего по объявленному
+    /// в 1-м байте размеру принимаемого ответа). БЕЗ +30% компенсации занижения sync — добавляет потребитель.
+    uint32_t packAirtimeMs(uint8_t packSize) const { return calculateSendTime(packSize); }
     static void isr();
     static void begin(HardwareTimer* timer, uint8_t channel, IRQn_Type IRQn, uint8_t priority, void(*isrCallback)() = nullptr);
     /**
@@ -210,6 +214,8 @@ private:
     static bool txAdvanceBoundary(TxFsmState &st, const uint8_t *sendBufferLocal);
     static bool txAdvanceAfterOutput(TxFsmState &st, const uint8_t *sendBufferLocal);
     static bool txEmitTick(TxFsmState &st, const uint8_t *sendBufferLocal, bool &gateOut);
+    template <typename Emit>
+    static bool txWalkRuns(TxFsmState &st, const uint8_t *sendBufferLocal, Emit emit);
     void loadTxFsmFromMembers(TxFsmState &st) const;
     void storeTxFsmToMembers(const TxFsmState &st);
     bool shouldUseBufferedIsr() const;

IR_config.h

@@ -231,9 +231,11 @@ typedef uint16_t crc_t;
 #ifndef IR_PREAMBLE_PERIOD_MAX_FACTOR_PCT
 #define IR_PREAMBLE_PERIOD_MAX_FACTOR_PCT 340U
 #endif
-/** Таймаут окна кандидата преамбулы: IR_timeout * mult. */
+/** Таймаут окна кандидата преамбулы: IR_timeout * mult. Кандидат без фронтов дольше таймаута байта
+    преамбулой быть не может; при 3× линия считалась занятой (rxLineActive) ещё 45 мс после последнего
+    паразитного фронта (напр. засветка своим дальномером) и откладывала передачу. */
 #ifndef IR_PREAMBLE_CANDIDATE_TIMEOUT_MULT
-#define IR_PREAMBLE_CANDIDATE_TIMEOUT_MULT 3U
+#define IR_PREAMBLE_CANDIDATE_TIMEOUT_MULT 1U
 #endif
 
 #define preambPulse 3
@@ -264,6 +266,32 @@ typedef uint16_t crc_t;
 #define bitTime (bitTakts * carrierPeriod)        // Общая длительность бита
 #define tolerance 300U
 
+// ---- Длительности и размеры кадра ФОРМУЛАМИ из FSM передатчика (IR_Encoder::txAdvanceBoundary) ----
+// Логический такт TX = полпериода несущей (toggleCounter считает полупериоды). Преамбула = 6 ран по
+// (preambToggle+1) тактов; лок декодера — на 3-м RISE (конец 5-й раны); байт = (8 данных + 3 sync) бит по 74 такта.
+constexpr uint32_t irTxTickNs      = 1000000000UL / (carrierFrec * 2U);
+constexpr uint32_t irPreambleTicks = (uint32_t)preambPulse * 2U * ((uint32_t)preambToggle + 1U);
+constexpr uint32_t irLockTicks     = ((uint32_t)preambPulse * 2U - 1U) * ((uint32_t)preambToggle + 1U);
+constexpr uint32_t irBitTicks      = (uint32_t)bitTakts * 2U;
+constexpr uint32_t irByteTicks     = ((uint32_t)bitPerByte + (uint32_t)syncBits) * irBitTicks;
+constexpr uint32_t irTicksToUs(uint32_t ticks) { return (uint32_t)(((uint64_t)ticks * irTxTickNs + 500U) / 1000U); }
+/// Полное время кадра в эфире (от первой несущей до последнего sync-бита), мкс.
+constexpr uint32_t irFrameAirtimeUs(uint8_t packSize) { return irTicksToUs(irPreambleTicks + (uint32_t)packSize * irByteTicks); }
+/// От старта кадра до последнего БИТА ДАННЫХ (момент, когда декодер отдаёт кадр), мкс.
+constexpr uint32_t irFrameDecodeEndUs(uint8_t packSize) { return irTicksToUs(irPreambleTicks + (uint32_t)packSize * irByteTicks - (uint32_t)syncBits * irBitTicks); }
+/// От лока декодера (3-й RISE преамбулы) до последнего бита данных, мкс.
+constexpr uint32_t irLockToDecodeEndUs(uint8_t packSize) { return irTicksToUs(irPreambleTicks - irLockTicks + (uint32_t)packSize * irByteTicks - (uint32_t)syncBits * irBitTicks); }
+/// Латентность лока: от первой несущей чужого кадра до лока декодера, мкс.
+constexpr uint32_t irLockLatencyUs = irTicksToUs(irLockTicks);
+/// Таймаут байта декодера (как IR_timeout при номинальном bitTime) и тишина, по которой декодер обрывает приём.
+constexpr uint32_t irRxByteTimeoutUs  = ((uint32_t)bitTime + tolerance) * ((uint32_t)bitPerByte + syncBits + 1U);
+constexpr uint32_t irRxAbortSilenceUs = 2U * irRxByteTimeoutUs;
+/// Протокольный максимум длины кадра (5-битное поле длины).
+constexpr uint8_t  irMaxPackSize = IR_MASK_MSG_INFO;
+/// Размер кадра по полезной нагрузке: DATA (from+to) и BACK (только from).
+constexpr uint8_t  irDataPackSize(uint8_t payload) { return (uint8_t)(msgBytes + addrBytes * 2 + payload + crcBytes); }
+constexpr uint8_t  irBackPackSize(uint8_t payload) { return (uint8_t)(msgBytes + addrBytes + payload + crcBytes); }
+
 constexpr uint16_t test_all_Time = bitTime;
 constexpr uint16_t test_all_Takts = bitTakts * 2;
 constexpr uint16_t test_hi = ((bitPauseTakts) * 2 - 0) + ((bitActiveTakts) * 2 - 0);

IrTxBsrrWave.h

@@ -65,13 +65,63 @@ public:
         return out;
     }
 
+    // Заполнение по ранам, а не по словам: тот же поток слов, что даёт nextWord() (состояние
+    // runIndex_/ticksLeftInRun_/slotInPeriod_ переносится через границы порций), но пауза (gate=0)
+    // пишется одним циклом записи, а несущая — копией готового шаблона периода. На 12 МГц это
+    // ~1 мс на 4096 слов вместо ~16 (пословный автомат) — и в предзаполнении перед стартом DMA,
+    // и в ISR-дозаполнении половин буфера во время передачи.
     IR_TX_BSRR_WAVE_HOT void fill(uint32_t* dst, uint16_t count) {
         if (dst == nullptr || count == 0) {
             return;
         }
-        do {
+        while (count != 0) {
-            *dst++ = nextWord();
+            if (runIndex_ >= runCount) {
-        } while (--count != 0);
+                do { *dst++ = resetWord; } while (--count != 0);
+                return;
+            }
+            const bool gate = runs[runIndex_].gate;
+            uint16_t n = ticksLeftInRun_;                 // слов до конца текущего рана
+            if (n == 0) n = 1;                            // ран нулевой длины: nextWord() выдаёт одно слово и переходит дальше
+            if (n > count) n = count;
+            if (!gate) {
+                slotInPeriod_ = 0;
+                uint16_t k = n;
+                do { *dst++ = resetWord; } while (--k != 0);
+            } else {
+                uint16_t k = n;
+                // добить текущий период до слота 0 (если ран начался посреди периода на границе порции)
+                while (k != 0 && slotInPeriod_ != 0) {
+                    *dst++ = (slotInPeriod_ < powerN_) ? setWord : resetWord;
+                    if (++slotInPeriod_ >= multiply_) slotInPeriod_ = 0;
+                    k--;
+                }
+                // целые периоды: powerN_ слов setWord, остальные resetWord
+                while (k >= multiply_) {
+                    uint16_t i = 0;
+                    for (; i < powerN_; ++i) *dst++ = setWord;
+                    for (; i < multiply_; ++i) *dst++ = resetWord;
+                    k = (uint16_t)(k - multiply_);
+                }
+                // хвост неполного периода
+                while (k != 0) {
+                    *dst++ = (slotInPeriod_ < powerN_) ? setWord : resetWord;
+                    if (++slotInPeriod_ >= multiply_) slotInPeriod_ = 0;
+                    k--;
+                }
+            }
+            count = (uint16_t)(count - n);
+            if (ticksLeftInRun_ > n) {
+                ticksLeftInRun_ = (uint16_t)(ticksLeftInRun_ - n);
+            } else {
+                ticksLeftInRun_ = 0;
+            }
+            if (ticksLeftInRun_ == 0) {
+                runIndex_++;
+                if (runIndex_ < runCount) {
+                    ticksLeftInRun_ = runs[runIndex_].lenTicks;
+                }
+            }
+        }
     }
 
 private:

PacketTypes.cpp

@@ -2,12 +2,49 @@
 
 namespace PacketTypes
 {
-    bool BasePack::checkAddress() { return true; };
+    uint8_t minimumPacketSize(uint8_t msgType)
-    void BasePack::set(IR_FOX::PackInfo *packInfo, uint16_t id)
     {
+        switch (msgType)
+        {
+        case IR_MSG_DATA_ACCEPT:
+        case IR_MSG_DATA_NOACCEPT:
+        case IR_MSG_BACK_TO:
+        case IR_MSG_REQUEST:
+            return uint8_t(msgBytes + addrBytes + addrBytes + crcBytes);
+        case IR_MSG_BACK:
+            return uint8_t(msgBytes + addrBytes + crcBytes);
+        case IR_MSG_ACCEPT:
+            return uint8_t(msgBytes + addrBytes + 1U + crcBytes);
+        default:
+            return 0;
+        }
+    }
+
+    bool isTypedPacketSizeValid(uint8_t msgType, uint8_t packSize)
+    {
+        const uint8_t minimum = minimumPacketSize(msgType);
+        return minimum != 0 && packSize >= minimum;
+    }
+
+    bool BasePack::checkAddress() { return true; }
+    bool BasePack::set(IR_FOX::PackInfo *packInfo, uint16_t id, bool requireTypedSize)
+    {
+        isAvailable = false;
+        isRawAvailable = false;
         this->packInfo = packInfo;
         this->id = id;
 
+        if (packInfo == nullptr || packInfo->buffer == nullptr)
+        {
+            return false;
+        }
+
+        const uint8_t msgType = (packInfo->buffer[msgOffset] >> 5) & IR_MASK_MSG_TYPE;
+        if (requireTypedSize && !isTypedPacketSizeValid(msgType, packInfo->packSize))
+        {
+            return false;
+        }
+
         if (checkAddress())
         {
             isAvailable = true;
@@ -23,29 +60,65 @@ namespace PacketTypes
             Serial.print("  NOT-OK  ");
 #endif
         }
+        return isAvailable;
     }
 
     uint16_t BasePack::_getAddrFrom(BasePack *obj)
     {
+        if (obj == nullptr || obj->packInfo == nullptr || obj->packInfo->buffer == nullptr ||
+            obj->packInfo->packSize < crcBytes ||
+            uint16_t(obj->addressFromOffset) + 1U >= uint16_t(obj->packInfo->packSize - crcBytes))
+        {
+            return 0;
+        }
         return (obj->packInfo->buffer[obj->addressFromOffset] << 8) | obj->packInfo->buffer[obj->addressFromOffset + 1];
-    };
+    }
     uint16_t BasePack::_getAddrTo(BasePack *obj)
     {
+        if (obj == nullptr || obj->packInfo == nullptr || obj->packInfo->buffer == nullptr ||
+            obj->packInfo->packSize < crcBytes ||
+            uint16_t(obj->addressToOffset) + 1U >= uint16_t(obj->packInfo->packSize - crcBytes))
+        {
+            return 0;
+        }
         return (obj->packInfo->buffer[obj->addressToOffset] << 8) | obj->packInfo->buffer[obj->addressToOffset + 1];
-    };
+    }
 
     uint8_t BasePack::_getDataSize(BasePack *obj)
     {
-        return obj->packInfo->packSize - crcBytes - obj->DataOffset;
+        if (obj == nullptr || obj->packInfo == nullptr || obj->packInfo->buffer == nullptr)
-    };
+        {
+            return 0;
+        }
+        const uint16_t frameOverhead = uint16_t(crcBytes) + uint16_t(obj->DataOffset);
+        if (uint16_t(obj->packInfo->packSize) <= frameOverhead)
+        {
+            return 0;
+        }
+        return uint8_t(uint16_t(obj->packInfo->packSize) - frameOverhead);
+    }
     uint8_t *BasePack::_getDataPrt(BasePack *obj)
     {
+        if (obj == nullptr || obj->packInfo == nullptr || obj->packInfo->buffer == nullptr ||
+            obj->packInfo->packSize < crcBytes)
+        {
+            return nullptr;
+        }
+        const uint16_t dataEnd = uint16_t(obj->packInfo->packSize) - uint16_t(crcBytes);
+        if (uint16_t(obj->DataOffset) > dataEnd)
+        {
+            return nullptr;
+        }
         return obj->packInfo->buffer + obj->DataOffset;
-    };
+    }
     uint8_t BasePack::_getDataRawSize(BasePack *obj)
     {
+        if (obj == nullptr || obj->packInfo == nullptr)
+        {
+            return 0;
+        }
         return obj->packInfo->packSize;
-    };
+    }
 
     bool BasePack::available()
     {
@@ -59,7 +132,7 @@ namespace PacketTypes
         {
             return false;
         }
-    };
+    }
     bool BasePack::availableRaw()
     {
         if (isRawAvailable)
@@ -71,7 +144,7 @@ namespace PacketTypes
         {
             return false;
         }
-    };
+    }
 
     bool Data::checkAddress()
     {

PacketTypes.h

@@ -4,25 +4,34 @@
 class IR_Decoder;
 namespace PacketTypes
 {
+    /**
+     * Minimum complete frame size (header, addresses/data required by the type,
+     * and CRC). Unknown/reserved message types return 0.
+     */
+    uint8_t minimumPacketSize(uint8_t msgType);
+
+    /** True only for a known typed packet whose complete frame is long enough. */
+    bool isTypedPacketSizeValid(uint8_t msgType, uint8_t packSize);
+
     class BasePack
     {
         friend IR_Decoder;
 
     protected:
-        bool isAvailable;
+        bool isAvailable = false;
-        bool isRawAvailable;
+        bool isRawAvailable = false;
-        bool isNeedAccept;
+        bool isNeedAccept = false;
 
-        uint8_t msgOffset;
+        uint8_t msgOffset = 0;
-        uint8_t addressFromOffset;
+        uint8_t addressFromOffset = 0;
-        uint8_t addressToOffset;
+        uint8_t addressToOffset = 0;
-        uint8_t DataOffset;
+        uint8_t DataOffset = 0;
 
-        IR_FOX::PackInfo *packInfo;
+        IR_FOX::PackInfo *packInfo = nullptr;
-        uint16_t id;
+        uint16_t id = 0;
 
         virtual bool checkAddress();
-        void set(IR_FOX::PackInfo *packInfo, uint16_t id);
+        bool set(IR_FOX::PackInfo *packInfo, uint16_t id, bool requireTypedSize = true);
 
         static uint16_t _getAddrFrom(BasePack *obj);
         static uint16_t _getAddrTo(BasePack *obj);