Update to use OneTBB

Mostly converting tbb::mutex -> std::mutex and tbb::atomic to std::atomic
Some changes also present around task manager.

squash:
* Include atomic/mutex/thread where required
* Use TBB_VERSION_MAJOR to detect if the legacy API should be used
This commit is contained in:
Stephen Hurd 2021-12-16 13:48:31 -05:00 committed by supermerill
parent cef7c355a1
commit ca1a475e2a
18 changed files with 96 additions and 81 deletions

View File

@ -37,7 +37,7 @@ template class PrintState<PrintObjectStep, posCount>;
void Print::clear() void Print::clear()
{ {
tbb::mutex::scoped_lock lock(this->state_mutex()); std::scoped_lock lock(this->state_mutex());
// The following call should stop background processing if it is running. // The following call should stop background processing if it is running.
this->invalidate_all_steps(); this->invalidate_all_steps();
for (PrintObject *object : m_objects) for (PrintObject *object : m_objects)
@ -353,7 +353,7 @@ bool Print::is_step_done(PrintObjectStep step) const
{ {
if (m_objects.empty()) if (m_objects.empty())
return false; return false;
tbb::mutex::scoped_lock lock(this->state_mutex()); std::scoped_lock lock(this->state_mutex());
for (const PrintObject *object : m_objects) for (const PrintObject *object : m_objects)
if (! object->is_step_done_unguarded(step)) if (! object->is_step_done_unguarded(step))
return false; return false;
@ -706,7 +706,7 @@ Print::ApplyStatus Print::apply(const Model &model, DynamicPrintConfig new_full_
update_apply_status(false); update_apply_status(false);
// Grab the lock for the Print / PrintObject milestones. // Grab the lock for the Print / PrintObject milestones.
tbb::mutex::scoped_lock lock(this->state_mutex()); std::scoped_lock lock(this->state_mutex());
// The following call may stop the background processing. // The following call may stop the background processing.
if (! print_diff.empty()) if (! print_diff.empty())

View File

@ -141,7 +141,7 @@ void PrintBase::status_update_warnings(ObjectID object_id, int step, PrintStateB
printf("%s warning: %s\n", (object_id == this->id()) ? "print" : "print object", message.c_str()); printf("%s warning: %s\n", (object_id == this->id()) ? "print" : "print object", message.c_str());
} }
tbb::mutex& PrintObjectBase::state_mutex(PrintBase *print) std::mutex& PrintObjectBase::state_mutex(PrintBase *print)
{ {
return print->state_mutex(); return print->state_mutex();
} }

View File

@ -6,12 +6,8 @@
#include <vector> #include <vector>
#include <string> #include <string>
#include <functional> #include <functional>
#include <atomic>
// tbb/mutex.h includes Windows, which in turn defines min/max macros. Convince Windows.h to not define these min/max macros. #include <mutex>
#ifndef NOMINMAX
#define NOMINMAX
#endif
#include "tbb/mutex.h"
#include "ObjectID.hpp" #include "ObjectID.hpp"
#include "Model.hpp" #include "Model.hpp"
@ -84,23 +80,23 @@ class PrintState : public PrintStateBase
public: public:
PrintState() {} PrintState() {}
StateWithTimeStamp state_with_timestamp(StepType step, tbb::mutex &mtx) const { StateWithTimeStamp state_with_timestamp(StepType step, std::mutex &mtx) const {
tbb::mutex::scoped_lock lock(mtx); std::scoped_lock lock(mtx);
StateWithTimeStamp state = m_state[step]; StateWithTimeStamp state = m_state[step];
return state; return state;
} }
StateWithWarnings state_with_warnings(StepType step, tbb::mutex &mtx) const { StateWithWarnings state_with_warnings(StepType step, std::mutex &mtx) const {
tbb::mutex::scoped_lock lock(mtx); std::scoped_lock lock(mtx);
StateWithWarnings state = m_state[step]; StateWithWarnings state = m_state[step];
return state; return state;
} }
bool is_started(StepType step, tbb::mutex &mtx) const { bool is_started(StepType step, std::mutex &mtx) const {
return this->state_with_timestamp(step, mtx).state == STARTED; return this->state_with_timestamp(step, mtx).state == STARTED;
} }
bool is_done(StepType step, tbb::mutex &mtx) const { bool is_done(StepType step, std::mutex &mtx) const {
return this->state_with_timestamp(step, mtx).state == DONE; return this->state_with_timestamp(step, mtx).state == DONE;
} }
@ -121,8 +117,8 @@ public:
// This is necessary to block until the Print::apply() updates its state, which may // This is necessary to block until the Print::apply() updates its state, which may
// influence the processing step being entered. // influence the processing step being entered.
template<typename ThrowIfCanceled> template<typename ThrowIfCanceled>
bool set_started(StepType step, tbb::mutex &mtx, ThrowIfCanceled throw_if_canceled) { bool set_started(StepType step, std::mutex &mtx, ThrowIfCanceled throw_if_canceled) {
tbb::mutex::scoped_lock lock(mtx); std::scoped_lock lock(mtx);
// If canceled, throw before changing the step state. // If canceled, throw before changing the step state.
throw_if_canceled(); throw_if_canceled();
#ifndef NDEBUG #ifndef NDEBUG
@ -154,8 +150,8 @@ public:
// Timestamp when this stepentered the DONE state. // Timestamp when this stepentered the DONE state.
// bool indicates whether the UI has to update the slicing warnings of this step or not. // bool indicates whether the UI has to update the slicing warnings of this step or not.
template<typename ThrowIfCanceled> template<typename ThrowIfCanceled>
std::pair<TimeStamp, bool> set_done(StepType step, tbb::mutex &mtx, ThrowIfCanceled throw_if_canceled) { std::pair<TimeStamp, bool> set_done(StepType step, std::mutex &mtx, ThrowIfCanceled throw_if_canceled) {
tbb::mutex::scoped_lock lock(mtx); std::scoped_lock lock(mtx);
// If canceled, throw before changing the step state. // If canceled, throw before changing the step state.
throw_if_canceled(); throw_if_canceled();
assert(m_state[step].state == STARTED); assert(m_state[step].state == STARTED);
@ -266,9 +262,9 @@ public:
// Return value: // Return value:
// Current milestone (StepType). // Current milestone (StepType).
// bool indicates whether the UI has to be updated or not. // bool indicates whether the UI has to be updated or not.
std::pair<StepType, bool> active_step_add_warning(PrintStateBase::WarningLevel warning_level, const std::string &message, int message_id, tbb::mutex &mtx) std::pair<StepType, bool> active_step_add_warning(PrintStateBase::WarningLevel warning_level, const std::string &message, int message_id, std::mutex &mtx)
{ {
tbb::mutex::scoped_lock lock(mtx); std::scoped_lock lock(mtx);
assert(m_step_active != -1); assert(m_step_active != -1);
StateWithWarnings &state = m_state[m_step_active]; StateWithWarnings &state = m_state[m_step_active];
assert(state.state == STARTED); assert(state.state == STARTED);
@ -314,7 +310,7 @@ protected:
PrintObjectBase(ModelObject *model_object) : m_model_object(model_object) {} PrintObjectBase(ModelObject *model_object) : m_model_object(model_object) {}
virtual ~PrintObjectBase() {} virtual ~PrintObjectBase() {}
// Declared here to allow access from PrintBase through friendship. // Declared here to allow access from PrintBase through friendship.
static tbb::mutex& state_mutex(PrintBase *print); static std::mutex& state_mutex(PrintBase *print);
static std::function<void()> cancel_callback(PrintBase *print); static std::function<void()> cancel_callback(PrintBase *print);
// Notify UI about a new warning of a milestone "step" on this PrintObjectBase. // Notify UI about a new warning of a milestone "step" on this PrintObjectBase.
// The UI will be notified by calling a status callback registered on print. // The UI will be notified by calling a status callback registered on print.
@ -473,7 +469,7 @@ protected:
friend class PrintObjectBase; friend class PrintObjectBase;
friend class BackgroundSlicingProcess; friend class BackgroundSlicingProcess;
tbb::mutex& state_mutex() const { return m_state_mutex; } std::mutex& state_mutex() const { return m_state_mutex; }
std::function<void()> cancel_callback() { return m_cancel_callback; } std::function<void()> cancel_callback() { return m_cancel_callback; }
void call_cancel_callback() { m_cancel_callback(); } void call_cancel_callback() { m_cancel_callback(); }
// Notify UI about a new warning of a milestone "step" on this PrintBase. // Notify UI about a new warning of a milestone "step" on this PrintBase.
@ -498,7 +494,7 @@ protected:
status_callback_type m_status_callback; status_callback_type m_status_callback;
private: private:
tbb::atomic<CancelStatus> m_cancel_status; std::atomic<CancelStatus> m_cancel_status;
// Callback to be evoked to stop the background processing before a state is updated. // Callback to be evoked to stop the background processing before a state is updated.
cancel_callback_type m_cancel_callback = [](){}; cancel_callback_type m_cancel_callback = [](){};
@ -506,7 +502,7 @@ private:
// Mutex used for synchronization of the worker thread with the UI thread: // Mutex used for synchronization of the worker thread with the UI thread:
// The mutex will be used to guard the worker thread against entering a stage // The mutex will be used to guard the worker thread against entering a stage
// while the data influencing the stage is modified. // while the data influencing the stage is modified.
mutable tbb::mutex m_state_mutex; mutable std::mutex m_state_mutex;
}; };
template<typename PrintStepEnum, const size_t COUNT> template<typename PrintStepEnum, const size_t COUNT>

View File

@ -1,8 +1,8 @@
#ifndef SLA_CONCURRENCY_H #ifndef SLA_CONCURRENCY_H
#define SLA_CONCURRENCY_H #define SLA_CONCURRENCY_H
#include <mutex>
#include <tbb/spin_mutex.h> #include <tbb/spin_mutex.h>
#include <tbb/mutex.h>
#include <tbb/parallel_for.h> #include <tbb/parallel_for.h>
#include <tbb/parallel_reduce.h> #include <tbb/parallel_reduce.h>
@ -23,7 +23,7 @@ template<bool> struct _ccr {};
template<> struct _ccr<true> template<> struct _ccr<true>
{ {
using SpinningMutex = tbb::spin_mutex; using SpinningMutex = tbb::spin_mutex;
using BlockingMutex = tbb::mutex; using BlockingMutex = std::mutex;
template<class Fn, class It> template<class Fn, class It>
static IteratorOnly<It, void> loop_(const tbb::blocked_range<It> &range, Fn &&fn) static IteratorOnly<It, void> loop_(const tbb::blocked_range<It> &range, Fn &&fn)

View File

@ -3,6 +3,7 @@
* *
*/ */
#include <mutex>
#include <numeric> #include <numeric>
#include <libslic3r/SLA/SupportTree.hpp> #include <libslic3r/SLA/SupportTree.hpp>
#include <libslic3r/SLA/SpatIndex.hpp> #include <libslic3r/SLA/SpatIndex.hpp>
@ -17,7 +18,6 @@
#include <libnest2d/optimizers/nlopt/subplex.hpp> #include <libnest2d/optimizers/nlopt/subplex.hpp>
#include <boost/log/trivial.hpp> #include <boost/log/trivial.hpp>
#include <tbb/parallel_for.h> #include <tbb/parallel_for.h>
#include <tbb/mutex.h>
#include <tbb/spin_mutex.h> #include <tbb/spin_mutex.h>
#include <libslic3r/I18N.hpp> #include <libslic3r/I18N.hpp>

View File

@ -118,7 +118,7 @@ bool validate_pad(const TriangleMesh &pad, const sla::PadConfig &pcfg)
void SLAPrint::clear() void SLAPrint::clear()
{ {
tbb::mutex::scoped_lock lock(this->state_mutex()); std::scoped_lock lock(this->state_mutex());
// The following call should stop background processing if it is running. // The following call should stop background processing if it is running.
this->invalidate_all_steps(); this->invalidate_all_steps();
for (SLAPrintObject *object : m_objects) for (SLAPrintObject *object : m_objects)
@ -212,7 +212,7 @@ SLAPrint::ApplyStatus SLAPrint::apply(const Model &model, DynamicPrintConfig con
update_apply_status(false); update_apply_status(false);
// Grab the lock for the Print / PrintObject milestones. // Grab the lock for the Print / PrintObject milestones.
tbb::mutex::scoped_lock lock(this->state_mutex()); std::scoped_lock lock(this->state_mutex());
// The following call may stop the background processing. // The following call may stop the background processing.
bool invalidate_all_model_objects = false; bool invalidate_all_model_objects = false;
@ -514,7 +514,7 @@ SLAPrint::ApplyStatus SLAPrint::apply(const Model &model, DynamicPrintConfig con
void SLAPrint::set_task(const TaskParams &params) void SLAPrint::set_task(const TaskParams &params)
{ {
// Grab the lock for the Print / PrintObject milestones. // Grab the lock for the Print / PrintObject milestones.
tbb::mutex::scoped_lock lock(this->state_mutex()); std::scoped_lock lock(this->state_mutex());
int n_object_steps = int(params.to_object_step) + 1; int n_object_steps = int(params.to_object_step) + 1;
if (n_object_steps == 0) if (n_object_steps == 0)
@ -897,7 +897,7 @@ bool SLAPrint::is_step_done(SLAPrintObjectStep step) const
{ {
if (m_objects.empty()) if (m_objects.empty())
return false; return false;
tbb::mutex::scoped_lock lock(this->state_mutex()); std::scoped_lock lock(this->state_mutex());
for (const SLAPrintObject *object : m_objects) for (const SLAPrintObject *object : m_objects)
if (! object->is_step_done_unguarded(step)) if (! object->is_step_done_unguarded(step))
return false; return false;

View File

@ -10,10 +10,11 @@
#include <cmath> #include <cmath>
#include <memory> #include <memory>
#include <atomic>
#include <thread>
#include <boost/log/trivial.hpp> #include <boost/log/trivial.hpp>
#include <tbb/parallel_for.h> #include <tbb/parallel_for.h>
#include <tbb/atomic.h>
#include <tbb/spin_mutex.h> #include <tbb/spin_mutex.h>
#include <tbb/task_group.h> #include <tbb/task_group.h>

View File

@ -10,9 +10,12 @@
#include <condition_variable> #include <condition_variable>
#include <mutex> #include <mutex>
#include <tbb/parallel_for.h> #include <tbb/parallel_for.h>
#include <tbb/tbb_thread.h>
#include <tbb/task_arena.h> #include <tbb/task_arena.h>
#if (TBB_VERSION_MAJOR >= 2020)
#include <tbb/global_control.h>
#else
#include <tbb/task_scheduler_init.h> #include <tbb/task_scheduler_init.h>
#endif
#include "Thread.hpp" #include "Thread.hpp"
@ -207,12 +210,16 @@ void name_tbb_thread_pool_threads()
#endif #endif
if (nthreads != nthreads_hw) if (nthreads != nthreads_hw)
#if (TBB_VERSION_MAJOR >= 2020)
new tbb::global_control(tbb::global_control::parameter::max_allowed_parallelism, nthreads);
#else
new tbb::task_scheduler_init(int(nthreads)); new tbb::task_scheduler_init(int(nthreads));
#endif
std::atomic<size_t> nthreads_running(0); std::atomic<size_t> nthreads_running(0);
std::condition_variable cv; std::condition_variable cv;
std::mutex cv_m; std::mutex cv_m;
auto master_thread_id = tbb::this_tbb_thread::get_id(); auto master_thread_id = std::this_thread::get_id();
auto now = std::chrono::system_clock::now(); auto now = std::chrono::system_clock::now();
tbb::parallel_for( tbb::parallel_for(
tbb::blocked_range<size_t>(0, nthreads, 1), tbb::blocked_range<size_t>(0, nthreads, 1),
@ -228,7 +235,7 @@ void name_tbb_thread_pool_threads()
// here can be deadlock with the main that creates me. // here can be deadlock with the main that creates me.
cv.wait_until(lk, now + std::chrono::milliseconds(50), [&nthreads_running, nthreads]{return nthreads_running == nthreads;}); cv.wait_until(lk, now + std::chrono::milliseconds(50), [&nthreads_running, nthreads]{return nthreads_running == nthreads;});
} }
auto thread_id = tbb::this_tbb_thread::get_id(); auto thread_id = std::this_thread::get_id();
if (thread_id == master_thread_id) { if (thread_id == master_thread_id) {
// The calling thread runs the 0'th task. // The calling thread runs the 0'th task.
//assert(range.begin() == 0); //assert(range.begin() == 0);

View File

@ -35,6 +35,7 @@
#include <locale> #include <locale>
#include <map> #include <map>
#include <memory> #include <memory>
#include <mutex>
#include <numeric> #include <numeric>
#include <ostream> #include <ostream>
#include <queue> #include <queue>
@ -93,12 +94,13 @@
#include <boost/thread.hpp> #include <boost/thread.hpp>
#include <boost/version.hpp> #include <boost/version.hpp>
#include <tbb/atomic.h>
#include <tbb/parallel_for.h> #include <tbb/parallel_for.h>
#include <tbb/spin_mutex.h> #include <tbb/spin_mutex.h>
#include <tbb/mutex.h> #if (TBB_VERSION_MAJOR >= 2020)
#include <tbb/task_group.h> #include <tbb/task_group.h>
#else
#include <tbb/task_scheduler_init.h> #include <tbb/task_scheduler_init.h>
#endif
#include <Eigen/Dense> #include <Eigen/Dense>
#include <Eigen/Geometry> #include <Eigen/Geometry>

View File

@ -43,7 +43,11 @@
#include <boost/nowide/convert.hpp> #include <boost/nowide/convert.hpp>
#include <boost/nowide/cstdio.hpp> #include <boost/nowide/cstdio.hpp>
#if (TBB_VERSION_MAJOR > 2020)
#include <tbb/global_control.h>
#else
#include <tbb/task_scheduler_init.h> #include <tbb/task_scheduler_init.h>
#endif
#if defined(__linux__) || defined(__GNUC__ ) #if defined(__linux__) || defined(__GNUC__ )
#include <strings.h> #include <strings.h>
@ -118,9 +122,15 @@ void trace(unsigned int level, const char *message)
void disable_multi_threading() void disable_multi_threading()
{ {
// Disable parallelization so the Shiny profiler works // Disable parallelization so the Shiny profiler works
#if (TBB_VERSION_MAJOR > 2020)
static tbb::global_control *tbb_init = nullptr;
if (tbb_init == nullptr)
tbb_init = new tbb::global_control(tbb::global_control::parameter::max_allowed_parallelism, 1);
#else
static tbb::task_scheduler_init *tbb_init = nullptr; static tbb::task_scheduler_init *tbb_init = nullptr;
if (tbb_init == nullptr) if (tbb_init == nullptr)
tbb_init = new tbb::task_scheduler_init(1); tbb_init = new tbb::task_scheduler_init(1);
#endif
} }
static std::string g_var_dir; static std::string g_var_dir;

View File

@ -519,7 +519,7 @@ void BackgroundSlicingProcess::schedule_export(const std::string &path, bool exp
return; return;
// Guard against entering the export step before changing the export path. // Guard against entering the export step before changing the export path.
tbb::mutex::scoped_lock lock(m_print->state_mutex()); std::scoped_lock lock(m_print->state_mutex());
this->invalidate_step(bspsGCodeFinalize); this->invalidate_step(bspsGCodeFinalize);
m_export_path = path; m_export_path = path;
m_export_path_on_removable_media = export_path_on_removable_media; m_export_path_on_removable_media = export_path_on_removable_media;
@ -532,7 +532,7 @@ void BackgroundSlicingProcess::schedule_upload(Slic3r::PrintHostJob upload_job)
return; return;
// Guard against entering the export step before changing the export path. // Guard against entering the export step before changing the export path.
tbb::mutex::scoped_lock lock(m_print->state_mutex()); std::scoped_lock lock(m_print->state_mutex());
this->invalidate_step(bspsGCodeFinalize); this->invalidate_step(bspsGCodeFinalize);
m_export_path.clear(); m_export_path.clear();
m_upload_job = std::move(upload_job); m_upload_job = std::move(upload_job);
@ -552,7 +552,7 @@ void BackgroundSlicingProcess::reset_export()
m_export_path.clear(); m_export_path.clear();
m_export_path_on_removable_media = false; m_export_path_on_removable_media = false;
// invalidate_step expects the mutex to be locked. // invalidate_step expects the mutex to be locked.
tbb::mutex::scoped_lock lock(m_print->state_mutex()); std::scoped_lock lock(m_print->state_mutex());
this->invalidate_step(bspsGCodeFinalize); this->invalidate_step(bspsGCodeFinalize);
} }
} }

View File

@ -230,7 +230,7 @@ private:
std::shared_ptr<UITask> m_ui_task; std::shared_ptr<UITask> m_ui_task;
PrintState<BackgroundSlicingProcessStep, bspsCount> m_step_state; PrintState<BackgroundSlicingProcessStep, bspsCount> m_step_state;
mutable tbb::mutex m_step_state_mutex; mutable std::mutex m_step_state_mutex;
bool set_step_started(BackgroundSlicingProcessStep step); bool set_step_started(BackgroundSlicingProcessStep step);
void set_step_done(BackgroundSlicingProcessStep step); void set_step_done(BackgroundSlicingProcessStep step);
bool is_step_done(BackgroundSlicingProcessStep step) const; bool is_step_done(BackgroundSlicingProcessStep step) const;

View File

@ -24,6 +24,7 @@
#endif //WIN32 #endif //WIN32
#if __linux__ #if __linux__
#include <mutex>
#include <dbus/dbus.h> /* Pull in all of D-Bus headers. */ #include <dbus/dbus.h> /* Pull in all of D-Bus headers. */
#endif //__linux__ #endif //__linux__

View File

@ -13,7 +13,6 @@
#if __linux__ #if __linux__
#include <boost/thread.hpp> #include <boost/thread.hpp>
#include <tbb/mutex.h>
#include <condition_variable> #include <condition_variable>
#endif // __linux__ #endif // __linux__

View File

@ -66,7 +66,7 @@ void update_maximum(std::atomic<T>& maximum_value, T const& value) noexcept
void Mouse3DController::State::append_translation(const Vec3d& translation, size_t input_queue_max_size) void Mouse3DController::State::append_translation(const Vec3d& translation, size_t input_queue_max_size)
{ {
tbb::mutex::scoped_lock lock(m_input_queue_mutex); std::scoped_lock lock(m_input_queue_mutex);
while (m_input_queue.size() >= input_queue_max_size) while (m_input_queue.size() >= input_queue_max_size)
m_input_queue.pop_front(); m_input_queue.pop_front();
m_input_queue.emplace_back(QueueItem::translation(translation)); m_input_queue.emplace_back(QueueItem::translation(translation));
@ -77,7 +77,7 @@ void Mouse3DController::State::append_translation(const Vec3d& translation, size
void Mouse3DController::State::append_rotation(const Vec3f& rotation, size_t input_queue_max_size) void Mouse3DController::State::append_rotation(const Vec3f& rotation, size_t input_queue_max_size)
{ {
tbb::mutex::scoped_lock lock(m_input_queue_mutex); std::scoped_lock lock(m_input_queue_mutex);
while (m_input_queue.size() >= input_queue_max_size) while (m_input_queue.size() >= input_queue_max_size)
m_input_queue.pop_front(); m_input_queue.pop_front();
m_input_queue.emplace_back(QueueItem::rotation(rotation.cast<double>())); m_input_queue.emplace_back(QueueItem::rotation(rotation.cast<double>()));
@ -92,7 +92,7 @@ void Mouse3DController::State::append_rotation(const Vec3f& rotation, size_t inp
void Mouse3DController::State::append_button(unsigned int id, size_t /* input_queue_max_size */) void Mouse3DController::State::append_button(unsigned int id, size_t /* input_queue_max_size */)
{ {
tbb::mutex::scoped_lock lock(m_input_queue_mutex); std::scoped_lock lock(m_input_queue_mutex);
m_input_queue.emplace_back(QueueItem::buttons(id)); m_input_queue.emplace_back(QueueItem::buttons(id));
#if ENABLE_3DCONNEXION_DEVICES_DEBUG_OUTPUT #if ENABLE_3DCONNEXION_DEVICES_DEBUG_OUTPUT
update_maximum(input_queue_max_size_achieved, m_input_queue.size()); update_maximum(input_queue_max_size_achieved, m_input_queue.size());
@ -277,7 +277,7 @@ void Mouse3DController::device_attached(const std::string &device)
#if ENABLE_CTRL_M_ON_WINDOWS #if ENABLE_CTRL_M_ON_WINDOWS
m_device_str = format_device_string(vid, pid); m_device_str = format_device_string(vid, pid);
if (auto it_params = m_params_by_device.find(m_device_str); it_params != m_params_by_device.end()) { if (auto it_params = m_params_by_device.find(m_device_str); it_params != m_params_by_device.end()) {
tbb::mutex::scoped_lock lock(m_params_ui_mutex); std::scoped_lock lock(m_params_ui_mutex);
m_params = m_params_ui = it_params->second; m_params = m_params_ui = it_params->second;
} }
else else
@ -295,7 +295,7 @@ void Mouse3DController::device_detached(const std::string& device)
int pid = 0; int pid = 0;
if (sscanf(device.c_str(), "\\\\?\\HID#VID_%x&PID_%x&", &vid, &pid) == 2) { if (sscanf(device.c_str(), "\\\\?\\HID#VID_%x&PID_%x&", &vid, &pid) == 2) {
if (std::find(_3DCONNEXION_VENDORS.begin(), _3DCONNEXION_VENDORS.end(), vid) != _3DCONNEXION_VENDORS.end()) { if (std::find(_3DCONNEXION_VENDORS.begin(), _3DCONNEXION_VENDORS.end(), vid) != _3DCONNEXION_VENDORS.end()) {
tbb::mutex::scoped_lock lock(m_params_ui_mutex); std::scoped_lock lock(m_params_ui_mutex);
m_params_by_device[format_device_string(vid, pid)] = m_params_ui; m_params_by_device[format_device_string(vid, pid)] = m_params_ui;
} }
} }
@ -307,7 +307,7 @@ void Mouse3DController::device_detached(const std::string& device)
// Filter out mouse scroll events produced by the 3DConnexion driver. // Filter out mouse scroll events produced by the 3DConnexion driver.
bool Mouse3DController::State::process_mouse_wheel() bool Mouse3DController::State::process_mouse_wheel()
{ {
tbb::mutex::scoped_lock lock(m_input_queue_mutex); std::scoped_lock lock(m_input_queue_mutex);
if (m_mouse_wheel_counter == 0) if (m_mouse_wheel_counter == 0)
// No 3DConnexion rotation has been captured since the last mouse scroll event. // No 3DConnexion rotation has been captured since the last mouse scroll event.
return false; return false;
@ -329,7 +329,7 @@ bool Mouse3DController::State::apply(const Mouse3DController::Params &params, Ca
std::deque<QueueItem> input_queue; std::deque<QueueItem> input_queue;
{ {
// Atomically move m_input_queue to input_queue. // Atomically move m_input_queue to input_queue.
tbb::mutex::scoped_lock lock(m_input_queue_mutex); std::scoped_lock lock(m_input_queue_mutex);
input_queue = std::move(m_input_queue); input_queue = std::move(m_input_queue);
m_input_queue.clear(); m_input_queue.clear();
} }
@ -418,7 +418,7 @@ bool Mouse3DController::apply(Camera& camera)
#if ENABLE_CTRL_M_ON_WINDOWS #if ENABLE_CTRL_M_ON_WINDOWS
#ifdef _WIN32 #ifdef _WIN32
{ {
tbb::mutex::scoped_lock lock(m_params_ui_mutex); std::scoped_lock lock(m_params_ui_mutex);
if (m_params_ui_changed) { if (m_params_ui_changed) {
m_params = m_params_ui; m_params = m_params_ui;
m_params_ui_changed = false; m_params_ui_changed = false;
@ -447,7 +447,7 @@ void Mouse3DController::render_settings_dialog(GLCanvas3D& canvas) const
Params params_copy; Params params_copy;
bool params_changed = false; bool params_changed = false;
{ {
tbb::mutex::scoped_lock lock(m_params_ui_mutex); std::scoped_lock lock(m_params_ui_mutex);
params_copy = m_params_ui; params_copy = m_params_ui;
} }
@ -565,7 +565,7 @@ void Mouse3DController::render_settings_dialog(GLCanvas3D& canvas) const
if (params_changed) { if (params_changed) {
// Synchronize front end parameters to back end. // Synchronize front end parameters to back end.
tbb::mutex::scoped_lock lock(m_params_ui_mutex); std::scoped_lock lock(m_params_ui_mutex);
auto pthis = const_cast<Mouse3DController*>(this); auto pthis = const_cast<Mouse3DController*>(this);
#if ENABLE_3DCONNEXION_DEVICES_DEBUG_OUTPUT #if ENABLE_3DCONNEXION_DEVICES_DEBUG_OUTPUT
if (params_copy.input_queue_max_size != params_copy.input_queue_max_size) if (params_copy.input_queue_max_size != params_copy.input_queue_max_size)
@ -586,7 +586,7 @@ void Mouse3DController::connected(std::string device_name)
m_device_str = device_name; m_device_str = device_name;
// Copy the parameters for m_device_str into the current parameters. // Copy the parameters for m_device_str into the current parameters.
if (auto it_params = m_params_by_device.find(m_device_str); it_params != m_params_by_device.end()) { if (auto it_params = m_params_by_device.find(m_device_str); it_params != m_params_by_device.end()) {
tbb::mutex::scoped_lock lock(m_params_ui_mutex); std::scoped_lock lock(m_params_ui_mutex);
m_params = m_params_ui = it_params->second; m_params = m_params_ui = it_params->second;
} }
m_connected = true; m_connected = true;
@ -597,7 +597,7 @@ void Mouse3DController::disconnected()
// Copy the current parameters for m_device_str into the parameter database. // Copy the current parameters for m_device_str into the parameter database.
assert(m_connected == ! m_device_str.empty()); assert(m_connected == ! m_device_str.empty());
if (m_connected) { if (m_connected) {
tbb::mutex::scoped_lock lock(m_params_ui_mutex); std::scoped_lock lock(m_params_ui_mutex);
m_params_by_device[m_device_str] = m_params_ui; m_params_by_device[m_device_str] = m_params_ui;
m_device_str.clear(); m_device_str.clear();
m_connected = false; m_connected = false;
@ -621,7 +621,7 @@ bool Mouse3DController::handle_input(const DataPacketAxis& packet)
{ {
// Synchronize parameters between the UI thread and the background thread. // Synchronize parameters between the UI thread and the background thread.
//FIXME is this necessary on OSX? Are these notifications triggered from the main thread or from a worker thread? //FIXME is this necessary on OSX? Are these notifications triggered from the main thread or from a worker thread?
tbb::mutex::scoped_lock lock(m_params_ui_mutex); std::scoped_lock lock(m_params_ui_mutex);
if (m_params_ui_changed) { if (m_params_ui_changed) {
m_params = m_params_ui; m_params = m_params_ui;
m_params_ui_changed = false; m_params_ui_changed = false;
@ -733,7 +733,7 @@ void Mouse3DController::run()
for (;;) { for (;;) {
{ {
tbb::mutex::scoped_lock lock(m_params_ui_mutex); std::scoped_lock lock(m_params_ui_mutex);
if (m_stop) if (m_stop)
break; break;
if (m_params_ui_changed) { if (m_params_ui_changed) {
@ -998,7 +998,7 @@ bool Mouse3DController::connect_device()
#endif // ENABLE_3DCONNEXION_DEVICES_DEBUG_OUTPUT #endif // ENABLE_3DCONNEXION_DEVICES_DEBUG_OUTPUT
// Copy the parameters for m_device_str into the current parameters. // Copy the parameters for m_device_str into the current parameters.
if (auto it_params = m_params_by_device.find(m_device_str); it_params != m_params_by_device.end()) { if (auto it_params = m_params_by_device.find(m_device_str); it_params != m_params_by_device.end()) {
tbb::mutex::scoped_lock lock(m_params_ui_mutex); std::scoped_lock lock(m_params_ui_mutex);
m_params = m_params_ui = it_params->second; m_params = m_params_ui = it_params->second;
} }
} }
@ -1023,7 +1023,7 @@ void Mouse3DController::disconnect_device()
BOOST_LOG_TRIVIAL(info) << "Disconnected device: " << m_device_str; BOOST_LOG_TRIVIAL(info) << "Disconnected device: " << m_device_str;
// Copy the current parameters for m_device_str into the parameter database. // Copy the current parameters for m_device_str into the parameter database.
{ {
tbb::mutex::scoped_lock lock(m_params_ui_mutex); std::scoped_lock lock(m_params_ui_mutex);
m_params_by_device[m_device_str] = m_params_ui; m_params_by_device[m_device_str] = m_params_ui;
} }
m_device_str.clear(); m_device_str.clear();

View File

@ -14,8 +14,7 @@
#include <vector> #include <vector>
#include <chrono> #include <chrono>
#include <condition_variable> #include <condition_variable>
#include <mutex>
#include <tbb/mutex.h>
namespace Slic3r { namespace Slic3r {
@ -85,7 +84,7 @@ class Mouse3DController
// m_input_queue is accessed by the background thread and by the UI thread. Access to m_input_queue // m_input_queue is accessed by the background thread and by the UI thread. Access to m_input_queue
// is guarded with m_input_queue_mutex. // is guarded with m_input_queue_mutex.
std::deque<QueueItem> m_input_queue; std::deque<QueueItem> m_input_queue;
mutable tbb::mutex m_input_queue_mutex; mutable std::mutex m_input_queue_mutex;
#ifdef WIN32 #ifdef WIN32
// When the 3Dconnexion driver is running the system gets, by default, mouse wheel events when rotations around the X axis are detected. // When the 3Dconnexion driver is running the system gets, by default, mouse wheel events when rotations around the X axis are detected.
@ -112,12 +111,12 @@ class Mouse3DController
#if ENABLE_3DCONNEXION_DEVICES_DEBUG_OUTPUT #if ENABLE_3DCONNEXION_DEVICES_DEBUG_OUTPUT
Vec3d get_first_vector_of_type(unsigned int type) const { Vec3d get_first_vector_of_type(unsigned int type) const {
tbb::mutex::scoped_lock lock(m_input_queue_mutex); std::scoped_lock lock(m_input_queue_mutex);
auto it = std::find_if(m_input_queue.begin(), m_input_queue.end(), [type](const QueueItem& item) { return item.type_or_buttons == type; }); auto it = std::find_if(m_input_queue.begin(), m_input_queue.end(), [type](const QueueItem& item) { return item.type_or_buttons == type; });
return (it == m_input_queue.end()) ? Vec3d::Zero() : it->vector; return (it == m_input_queue.end()) ? Vec3d::Zero() : it->vector;
} }
size_t input_queue_size_current() const { size_t input_queue_size_current() const {
tbb::mutex::scoped_lock lock(m_input_queue_mutex); std::scoped_lock lock(m_input_queue_mutex);
return m_input_queue.size(); return m_input_queue.size();
} }
std::atomic<size_t> input_queue_max_size_achieved; std::atomic<size_t> input_queue_max_size_achieved;
@ -133,7 +132,7 @@ class Mouse3DController
// UI thread will read / write this copy. // UI thread will read / write this copy.
Params m_params_ui; Params m_params_ui;
bool m_params_ui_changed { false }; bool m_params_ui_changed { false };
mutable tbb::mutex m_params_ui_mutex; mutable std::mutex m_params_ui_mutex;
// This is a database of parametes of all 3DConnexion devices ever connected. // This is a database of parametes of all 3DConnexion devices ever connected.
// This database is loaded from AppConfig on application start and it is stored to AppConfig on application exit. // This database is loaded from AppConfig on application start and it is stored to AppConfig on application exit.

View File

@ -84,7 +84,7 @@ void RemovableDriveManager::eject_drive()
this->update(); this->update();
#endif // REMOVABLE_DRIVE_MANAGER_OS_CALLBACKS #endif // REMOVABLE_DRIVE_MANAGER_OS_CALLBACKS
BOOST_LOG_TRIVIAL(info) << "Ejecting started"; BOOST_LOG_TRIVIAL(info) << "Ejecting started";
tbb::mutex::scoped_lock lock(m_drives_mutex); std::scoped_lock lock(m_drives_mutex);
auto it_drive_data = this->find_last_save_path_drive_data(); auto it_drive_data = this->find_last_save_path_drive_data();
if (it_drive_data != m_current_drives.end()) { if (it_drive_data != m_current_drives.end()) {
// get handle to device // get handle to device
@ -130,7 +130,7 @@ std::string RemovableDriveManager::get_removable_drive_path(const std::string &p
this->update(); this->update();
#endif // REMOVABLE_DRIVE_MANAGER_OS_CALLBACKS #endif // REMOVABLE_DRIVE_MANAGER_OS_CALLBACKS
tbb::mutex::scoped_lock lock(m_drives_mutex); std::scoped_lock lock(m_drives_mutex);
if (m_current_drives.empty()) if (m_current_drives.empty())
return std::string(); return std::string();
std::size_t found = path.find_last_of("\\"); std::size_t found = path.find_last_of("\\");
@ -146,7 +146,7 @@ std::string RemovableDriveManager::get_removable_drive_path(const std::string &p
std::string RemovableDriveManager::get_removable_drive_from_path(const std::string& path) std::string RemovableDriveManager::get_removable_drive_from_path(const std::string& path)
{ {
tbb::mutex::scoped_lock lock(m_drives_mutex); std::scoped_lock lock(m_drives_mutex);
std::size_t found = path.find_last_of("\\"); std::size_t found = path.find_last_of("\\");
std::string new_path = path.substr(0, found); std::string new_path = path.substr(0, found);
int letter = PathGetDriveNumberW(boost::nowide::widen(new_path).c_str()); int letter = PathGetDriveNumberW(boost::nowide::widen(new_path).c_str());
@ -285,7 +285,7 @@ void RemovableDriveManager::eject_drive()
DriveData drive_data; DriveData drive_data;
{ {
tbb::mutex::scoped_lock lock(m_drives_mutex); std::scoped_lock lock(m_drives_mutex);
auto it_drive_data = this->find_last_save_path_drive_data(); auto it_drive_data = this->find_last_save_path_drive_data();
if (it_drive_data == m_current_drives.end()) if (it_drive_data == m_current_drives.end())
return; return;
@ -341,7 +341,7 @@ void RemovableDriveManager::eject_drive()
if (success) { if (success) {
// Remove the drive_data from m_current drives, searching by value, not by pointer, as m_current_drives may get modified during // Remove the drive_data from m_current drives, searching by value, not by pointer, as m_current_drives may get modified during
// asynchronous execution on m_eject_thread. // asynchronous execution on m_eject_thread.
tbb::mutex::scoped_lock lock(m_drives_mutex); std::scoped_lock lock(m_drives_mutex);
auto it = std::find(m_current_drives.begin(), m_current_drives.end(), drive_data); auto it = std::find(m_current_drives.begin(), m_current_drives.end(), drive_data);
if (it != m_current_drives.end()) if (it != m_current_drives.end())
m_current_drives.erase(it); m_current_drives.erase(it);
@ -361,7 +361,7 @@ std::string RemovableDriveManager::get_removable_drive_path(const std::string &p
std::size_t found = path.find_last_of("/"); std::size_t found = path.find_last_of("/");
std::string new_path = found == path.size() - 1 ? path.substr(0, found) : path; std::string new_path = found == path.size() - 1 ? path.substr(0, found) : path;
tbb::mutex::scoped_lock lock(m_drives_mutex); std::scoped_lock lock(m_drives_mutex);
for (const DriveData &data : m_current_drives) for (const DriveData &data : m_current_drives)
if (search_for_drives_internal::compare_filesystem_id(new_path, data.path)) if (search_for_drives_internal::compare_filesystem_id(new_path, data.path))
return path; return path;
@ -377,7 +377,7 @@ std::string RemovableDriveManager::get_removable_drive_from_path(const std::stri
new_path = new_path.substr(0, found); new_path = new_path.substr(0, found);
// check if same filesystem // check if same filesystem
tbb::mutex::scoped_lock lock(m_drives_mutex); std::scoped_lock lock(m_drives_mutex);
for (const DriveData &drive_data : m_current_drives) for (const DriveData &drive_data : m_current_drives)
if (search_for_drives_internal::compare_filesystem_id(new_path, drive_data.path)) if (search_for_drives_internal::compare_filesystem_id(new_path, drive_data.path))
return drive_data.path; return drive_data.path;
@ -452,7 +452,7 @@ RemovableDriveManager::RemovableDrivesStatus RemovableDriveManager::status()
RemovableDriveManager::RemovableDrivesStatus out; RemovableDriveManager::RemovableDrivesStatus out;
{ {
tbb::mutex::scoped_lock lock(m_drives_mutex); std::scoped_lock lock(m_drives_mutex);
out.has_eject = out.has_eject =
// Cannot control eject on Chromium. // Cannot control eject on Chromium.
platform_flavor() != PlatformFlavor::LinuxOnChromium && platform_flavor() != PlatformFlavor::LinuxOnChromium &&
@ -468,17 +468,16 @@ RemovableDriveManager::RemovableDrivesStatus RemovableDriveManager::status()
// Update is called from thread_proc() and from most of the public methods on demand. // Update is called from thread_proc() and from most of the public methods on demand.
void RemovableDriveManager::update() void RemovableDriveManager::update()
{ {
tbb::mutex::scoped_lock inside_update_lock;
#ifdef _WIN32 #ifdef _WIN32
// All wake up calls up to now are now consumed when the drive enumeration starts. // All wake up calls up to now are now consumed when the drive enumeration starts.
m_wakeup = false; m_wakeup = false;
#endif // _WIN32 #endif // _WIN32
if (inside_update_lock.try_acquire(m_inside_update_mutex)) { if (m_inside_update_mutex.try_lock()) {
// Got the lock without waiting. That means, the update was not running. // Got the lock without waiting. That means, the update was not running.
// Run the update. // Run the update.
std::vector<DriveData> current_drives = this->search_for_removable_drives(); std::vector<DriveData> current_drives = this->search_for_removable_drives();
// Post update events. // Post update events.
tbb::mutex::scoped_lock lock(m_drives_mutex); std::scoped_lock lock(m_drives_mutex);
std::sort(current_drives.begin(), current_drives.end()); std::sort(current_drives.begin(), current_drives.end());
if (current_drives != m_current_drives) { if (current_drives != m_current_drives) {
assert(m_callback_evt_handler); assert(m_callback_evt_handler);
@ -489,8 +488,9 @@ void RemovableDriveManager::update()
} else { } else {
// Acquiring the m_iniside_update lock failed, therefore another update is running. // Acquiring the m_iniside_update lock failed, therefore another update is running.
// Just block until the other instance of update() finishes. // Just block until the other instance of update() finishes.
inside_update_lock.acquire(m_inside_update_mutex); m_inside_update_mutex.lock();
} }
m_inside_update_mutex.unlock();
} }
#ifndef REMOVABLE_DRIVE_MANAGER_OS_CALLBACKS #ifndef REMOVABLE_DRIVE_MANAGER_OS_CALLBACKS

View File

@ -3,9 +3,9 @@
#include <vector> #include <vector>
#include <string> #include <string>
#include <mutex>
#include <boost/thread.hpp> #include <boost/thread.hpp>
#include <tbb/mutex.h>
#include <condition_variable> #include <condition_variable>
// Custom wxWidget events // Custom wxWidget events
@ -111,9 +111,9 @@ private:
// m_current_drives is guarded by m_drives_mutex // m_current_drives is guarded by m_drives_mutex
// sorted ascending by path // sorted ascending by path
std::vector<DriveData> m_current_drives; std::vector<DriveData> m_current_drives;
mutable tbb::mutex m_drives_mutex; mutable std::mutex m_drives_mutex;
// Locking the update() function to avoid that the function is executed multiple times. // Locking the update() function to avoid that the function is executed multiple times.
mutable tbb::mutex m_inside_update_mutex; mutable std::mutex m_inside_update_mutex;
// Returns drive path (same as path in DriveData) if exists otherwise empty string. // Returns drive path (same as path in DriveData) if exists otherwise empty string.
std::string get_removable_drive_from_path(const std::string& path); std::string get_removable_drive_from_path(const std::string& path);