diff --git a/lib/base/workqueue.cpp b/lib/base/workqueue.cpp index 9a74557c1..c7b62caa1 100644 --- a/lib/base/workqueue.cpp +++ b/lib/base/workqueue.cpp @@ -79,6 +79,9 @@ void WorkQueue::Enqueue(const boost::function& function, WorkQueueP boost::mutex::scoped_lock lock(m_Mutex); if (!m_Spawned) { + Log(LogNotice, "WorkQueue") + << "Spawning WorkQueue threads for '" << m_Name << "'"; + for (int i = 0; i < m_ThreadCount; i++) { m_Threads.create_thread(boost::bind(&WorkQueue::WorkerThreadProc, this)); } @@ -116,6 +119,9 @@ void WorkQueue::Join(bool stop) m_Threads.join_all(); m_Spawned = false; + + Log(LogNotice, "WorkQueue") + << "Stopped WorkQueue threads for '" << m_Name << "'"; } } diff --git a/lib/cli/daemoncommand.cpp b/lib/cli/daemoncommand.cpp index 9463f11ef..f9777896c 100644 --- a/lib/cli/daemoncommand.cpp +++ b/lib/cli/daemoncommand.cpp @@ -282,6 +282,7 @@ int DaemonCommand::Run(const po::variables_map& vm, const std::vector& configs, } WorkQueue upq(25000, Application::GetConcurrency()); + upq.SetName("DaemonUtility::LoadConfigFiles"); bool result = ConfigItem::CommitItems(ascope.GetContext(), upq, newItems); if (!result) {