From b9de1e1d90526d26b4162a5f2ccd9f7639292072 Mon Sep 17 00:00:00 2001 From: Thulinma Date: Thu, 27 Jun 2024 13:21:45 +0200 Subject: [PATCH] Optimize MistInBuffer to only check STREAM_BUFFER trigger when it could possibly fire --- src/input/input_buffer.cpp | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/src/input/input_buffer.cpp b/src/input/input_buffer.cpp index 5da63707..bad6b34e 100644 --- a/src/input/input_buffer.cpp +++ b/src/input/input_buffer.cpp @@ -228,14 +228,14 @@ namespace Mist{ } } } - if (fragCount >= FRAG_BOOT && fragCount != 0xFFFFull && Triggers::shouldTrigger("STREAM_BUFFER", streamName)){ + if (fragCount >= FRAG_BOOT && fragCount != 0xFFFFull){ JSON::Value stream_details; M.getHealthJSON(stream_details); - if (lastFragCount == 0xFFFFull){ - std::string payload = streamName + "\nFULL\n" + stream_details.toString(); - Triggers::doTrigger("STREAM_BUFFER", payload, streamName); - }else{ - if (stream_details.isMember("issues") != wentDry){ + if ((lastFragCount == 0xFFFFull || stream_details.isMember("issues") != wentDry) && Triggers::shouldTrigger("STREAM_BUFFER", streamName)){ + if (lastFragCount == 0xFFFFull){ + std::string payload = streamName + "\nFULL\n" + stream_details.toString(); + Triggers::doTrigger("STREAM_BUFFER", payload, streamName); + }else{ if (stream_details.isMember("issues")){ std::string payload = streamName + "\nDRY\n" + stream_details.toString(); Triggers::doTrigger("STREAM_BUFFER", payload, streamName);