cmpto_j2k: silence logging in video_frame_pool

the exception is caught so it doesn't need to be print twice

Author: MartinPulec

src/utils/video_frame_pool.cpp

@@ -51,7 +51,7 @@
 #include <stdexcept>
 #include <utility>
 
-#include "debug.h"             // for MSG
+#include "debug.h"             // for log_msg
 #include "video_codec.h"
 #include "video_frame.h"
 
@@ -73,6 +73,7 @@ struct video_frame_pool::impl {
         void deallocate_frame(struct video_frame *frame);
 
         std::unique_ptr<video_frame_pool_allocator> m_allocator = std::unique_ptr<video_frame_pool_allocator>(new default_data_allocator);
+        bool                                        m_quiet;
         std::queue<struct video_frame *>            m_free_frames;
         std::mutex                                  m_lock;
         std::condition_variable                     m_frame_returned;
@@ -144,7 +145,8 @@ struct video_frame_pool_allocator *default_data_allocator::clone() const {
 //  \/ | (_| (- (_) __ |  |  (_| ||| (- __ |_) (_) (_) | . . | ||| |_) |
 //                                         |                       |
 video_frame_pool::impl::impl(const video_frame_pool_params &params)
-    : m_allocator(params.alloc.clone()), m_max_used_frames(params.max_used_frames)
+    : m_allocator(params.alloc.clone()), m_quiet(params.quiet),
+      m_max_used_frames(params.max_used_frames)
 {
 }
 
@@ -188,7 +190,8 @@ std::shared_ptr<video_frame> video_frame_pool::impl::get_frame() {
                                 ret->tiles[i].data_len = m_max_data_len;
                         }
                 } catch (std::exception &e) {
-                        MSG(ERROR, "%s\n", e.what());
+                        log_msg(m_quiet ? LOG_LEVEL_DEBUG : LOG_LEVEL_ERROR,
+                                MOD_NAME "%s\n", e.what());
                         deallocate_frame(ret);
                         throw;
                 }

src/utils/video_frame_pool.h

@@ -62,6 +62,9 @@ struct default_data_allocator : public video_frame_pool_allocator {
 struct video_frame_pool_params {
         unsigned int max_used_frames = 0;
         video_frame_pool_allocator const &alloc = default_data_allocator();
+        bool                              quiet =
+            false; ///< if exception thrown, do not print e.what() - the caller
+                   ///< is catching the error and will handle the message
 };
 
 struct video_frame_pool {

src/video_compress/cmpto_j2k.cpp

@@ -368,7 +368,9 @@ static struct {
 static void
 set_cpu_pool(struct state_video_compress_j2k *s, bool /*have_cuda_preprocess*/)
 {
-        s->pool = video_frame_pool(s->max_in_frames, default_data_allocator());
+        s->pool = video_frame_pool({ .max_used_frames = s->max_in_frames,
+                                     .alloc = default_data_allocator(),
+                                     .quiet = true });
 }
 #define CPU_CONV_PARAM "j2k-enc-cpu-conv"
 ADD_TO_PARAM(
@@ -385,19 +387,23 @@ set_cuda_pool(struct state_video_compress_j2k *s, bool have_cuda_preprocess)
                              "conversion...\n");
         } else if (s->precompress_codec == VC_NONE || have_cuda_preprocess) {
                 s->pool_in_cuda_memory = true;
-                s->pool                  = video_frame_pool(
-                    s->max_in_frames,
-                    cmpto_j2k_enc_cuda_buffer_data_allocator<
-                                         cuda_wrapper_malloc, cuda_wrapper_free>());
+                s->pool                = video_frame_pool(
+                    { .max_used_frames = s->max_in_frames,
+                                     .alloc = cmpto_j2k_enc_cuda_buffer_data_allocator<
+                                         cuda_wrapper_malloc, cuda_wrapper_free>(),
+                                     .quiet = true });
                 return;
         }
         s->pool = video_frame_pool(
-            s->max_in_frames,
-            cmpto_j2k_enc_cuda_buffer_data_allocator<cuda_wrapper_malloc_host,
-                                                     cuda_wrapper_free_host>());
+            { .max_used_frames = s->max_in_frames,
+              .alloc           = cmpto_j2k_enc_cuda_buffer_data_allocator<
+                            cuda_wrapper_malloc_host, cuda_wrapper_free_host>(),
+              .quiet = true });
 #else
         assert(!have_cuda_preprocess); // if CUDA not found, we shouldn't have
-        s->pool = video_frame_pool(s->max_in_frames, default_data_allocator());
+        s->pool = video_frame_pool({ .max_used_frames = s->max_in_frames,
+                                     .alloc = default_data_allocator(),
+                                     .quiet = true });
 #endif
 }