diff options
| -rw-r--r-- | avmedia/source/gstreamer/gstplayer.cxx | 13 |
1 files changed, 6 insertions, 7 deletions
diff --git a/avmedia/source/gstreamer/gstplayer.cxx b/avmedia/source/gstreamer/gstplayer.cxx index 7d7602b5b3eb..b841c576be17 100644 --- a/avmedia/source/gstreamer/gstplayer.cxx +++ b/avmedia/source/gstreamer/gstplayer.cxx @@ -25,7 +25,6 @@ #include <cstddef> #include <cstring> #include <map> -#include <mutex> #include <set> #include <vector> #include <math.h> @@ -99,7 +98,7 @@ private: DECL_STATIC_LINK(MissingPluginInstaller, launchUi, void*, void); - std::mutex mutex_; + osl::Mutex mutex_; std::set<OString> reported_; std::map<OString, std::set<rtl::Reference<Player>>> queued_; rtl::Reference<MissingPluginInstallerThread> currentThread_; @@ -111,7 +110,7 @@ private: MissingPluginInstaller::~MissingPluginInstaller() { - std::unique_lock g(mutex_); + osl::MutexGuard g(mutex_); SAL_WARN_IF(currentThread_.is(), "avmedia.gstreamer", "unjoined thread"); inCleanUp_ = true; } @@ -139,7 +138,7 @@ void MissingPluginInstaller::report( rtl::Reference<MissingPluginInstallerThread> join; rtl::Reference<MissingPluginInstallerThread> launch; { - std::unique_lock g(mutex_); + osl::MutexGuard g(mutex_); if (reported_.find(detStr) != reported_.end()) { return; } @@ -184,7 +183,7 @@ void eraseSource(std::set<rtl::Reference<Player>> & set, Player const * source) void MissingPluginInstaller::detach(Player const * source) { rtl::Reference<MissingPluginInstallerThread> join; { - std::unique_lock g(mutex_); + osl::MutexGuard g(mutex_); if (inCleanUp_) { // Guard against ~MissingPluginInstaller with erroneously un-joined // currentThread_ (thus non-empty currentSources_) calling @@ -256,7 +255,7 @@ void MissingPluginInstallerThread::execute() { for (;;) { std::vector<OString> details; { - std::unique_lock g(inst.mutex_); + osl::MutexGuard g(inst.mutex_); assert(!inst.currentDetails_.empty()); details.swap(inst.currentDetails_); } @@ -269,7 +268,7 @@ void MissingPluginInstallerThread::execute() { args.push_back(nullptr); gst_install_plugins_sync(args.data(), nullptr); { - std::unique_lock g(inst.mutex_); + osl::MutexGuard g(inst.mutex_); if (inst.queued_.empty() || inst.launchNewThread_) { inst.launchNewThread_ = true; break; |