From 4b3900797e0a484df2cb8c8a71f71a5ccaca6409 Mon Sep 17 00:00:00 2001 From: Carl Hetherington Date: Thu, 28 Nov 2024 18:49:39 +0100 Subject: Count errors in Grok threads. --- src/lib/grok_j2k_encoder_thread.cc | 2 ++ src/lib/grok_j2k_encoder_thread.h | 5 +++++ 2 files changed, 7 insertions(+) (limited to 'src/lib') diff --git a/src/lib/grok_j2k_encoder_thread.cc b/src/lib/grok_j2k_encoder_thread.cc index f8bfddf58..6975d9221 100644 --- a/src/lib/grok_j2k_encoder_thread.cc +++ b/src/lib/grok_j2k_encoder_thread.cc @@ -39,6 +39,7 @@ using std::shared_ptr; GrokJ2KEncoderThread::GrokJ2KEncoderThread(J2KEncoder& encoder, grk_plugin::GrokContext* context) : J2KEncoderThread(encoder) , _context(context) + , _errors(0) { } @@ -55,6 +56,7 @@ try dcp::ScopeGuard frame_guard([this, &frame]() { LOG_ERROR("Failed to schedule encode of %1 using grok", frame.index()); + _errors++; _encoder.retry(frame); }); diff --git a/src/lib/grok_j2k_encoder_thread.h b/src/lib/grok_j2k_encoder_thread.h index 5301e1670..b9375f23a 100644 --- a/src/lib/grok_j2k_encoder_thread.h +++ b/src/lib/grok_j2k_encoder_thread.h @@ -35,7 +35,12 @@ public: void run() override; + int errors() const { + return _errors.load(); + } + private: grk_plugin::GrokContext* _context; + std::atomic _errors; }; -- cgit v1.2.3