From 1550d3ac6ab9bb54eb5f6d2ba5a6e90af9b359f2 Mon Sep 17 00:00:00 2001 From: Peter Andreas Entschev Date: Mon, 30 Oct 2023 11:12:50 -0700 Subject: [PATCH] Downgrade worker progress thread start/stop log to debug --- cpp/src/worker.cpp | 4 ++-- cpp/src/worker_progress_thread.cpp | 2 +- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/cpp/src/worker.cpp b/cpp/src/worker.cpp index a7b04e03..fe63ed64 100644 --- a/cpp/src/worker.cpp +++ b/cpp/src/worker.cpp @@ -355,7 +355,7 @@ void Worker::setProgressThreadStartCallback(std::function callback, void Worker::startProgressThread(const bool pollingMode, const int epollTimeout) { if (_progressThread) { - ucxx_warn("Worker progress thread already running"); + ucxx_debug("Worker progress thread already running"); return; } @@ -390,7 +390,7 @@ void Worker::stopProgressThreadNoWarn() { _progressThread = nullptr; } void Worker::stopProgressThread() { if (!_progressThread) - ucxx_warn("Worker progress thread not running or already stopped"); + ucxx_debug("Worker progress thread not running or already stopped"); else stopProgressThreadNoWarn(); } diff --git a/cpp/src/worker_progress_thread.cpp b/cpp/src/worker_progress_thread.cpp index 616abd7a..859c8013 100644 --- a/cpp/src/worker_progress_thread.cpp +++ b/cpp/src/worker_progress_thread.cpp @@ -52,7 +52,7 @@ WorkerProgressThread::WorkerProgressThread( WorkerProgressThread::~WorkerProgressThread() { if (!_thread.joinable()) { - ucxx_warn("Worker progress thread not running or already stopped"); + ucxx_debug("Worker progress thread not running or already stopped"); return; }