DriveHQ Start Menu
Cloud Drive Mapping
Folder Sync
True Drop Box
FTP/SFTP Hosting
Group Account
Team Anywhere
DriveHQ Start Menu
Online File Server
My Storage
|
Manage Shares
|
Publishes
|
Drop Boxes
|
Group Account
WebDAV Drive Mapping
Cloud Drive Home
|
WebDAV Guide
|
Drive Mapping Tool
|
Drive Mapping URL
Complete Data Backup
Backup Guide
|
Cloud-to-Cloud Backup
|
DVR/Camera Backup
FTP, Email & Web Service
FTP/SFTP Hosting
|
Email Hosting
|
Web Hosting
|
Webcam Hosting
Other Products & Services
Team Anywhere
|
Connect to Remote PC
|
Cloud Surveillance
|
Virtual CCTV NVR
Quick Links
Security and Privacy
Customer Support
Service Manual
Use Cases
Group Account
Online Help
Support Forum
Contact Us
About DriveHQ
Sign Up
Login
Features
Business Features
Online File Server
FTP Hosting
Cloud Drive Mapping
Cloud File Backup
Email Backup & Hosting
Cloud File Sharing
Folder Synchronization
Group Management
True Drop Box
Full-text Search
AD Integration/SSO
Mobile Access
Personal Features
Personal Cloud Drive
Backup All Devices
Mobile APPs
Personal Web Hosting
Sub-Account (for Kids)
Home/PC/Kids Monitoring
Other Features
Team Anywhere (Remote Desktop Service)
CameraFTP Cloud Surveillance
Software
DriveHQ Drive Mapping Tool
DriveHQ FileManager
DriveHQ Online Backup
DriveHQ Team Anywhere for Windows (Beta)
DriveHQ Mobile Apps
Pricing
Business Plans & Pricing
Personal Plans & Pricing
Price Comparison with Others
Feature Comparison with Others
Install Mobile App
Sign up
Creating account...
Invalid character in username! Only 0-9, a-z, A-Z, _, -, . allowed.
Username is required!
Invalid email address!
E-mail is required!
Password is required!
Password is invalid!
Password and confirmation do not match.
Confirm password is required!
I accept
Membership Agreement
Please read the Membership Agreement and check "I accept"!
Free Quick Sign-up
Sign-up Page
Log in
Signing in...
Username or e-mail address is required!
Password is required!
Keep me logged in
Quick Login
Forgot Password
Up
Upload
Download
Share
Publish
New Folder
New File
Copy
Cut
Delete
Paste
Rate
Upgrade
Rotate
Effect
Edit
Slide
History
#ifndef BOOST_THREAD_PTHREAD_SHARED_MUTEX_HPP #define BOOST_THREAD_PTHREAD_SHARED_MUTEX_HPP // (C) Copyright 2006-7 Anthony Williams // // Distributed under the Boost Software License, Version 1.0. (See // accompanying file LICENSE_1_0.txt or copy at // http://www.boost.org/LICENSE_1_0.txt) #include
#include
#include
#include
#include
namespace boost { class shared_mutex { private: struct state_data { unsigned shared_count; bool exclusive; bool upgrade; bool exclusive_waiting_blocked; }; state_data state; boost::mutex state_change; boost::condition_variable shared_cond; boost::condition_variable exclusive_cond; boost::condition_variable upgrade_cond; void release_waiters() { exclusive_cond.notify_one(); shared_cond.notify_all(); } public: shared_mutex() { state_data state_={0}; state=state_; } ~shared_mutex() { } void lock_shared() { boost::this_thread::disable_interruption do_not_disturb; boost::mutex::scoped_lock lock(state_change); #ifdef BOOST_MSVC #pragma warning(push) #pragma warning(disable:4127) #endif while(true) #ifdef BOOST_MSVC #pragma warning(pop) #endif { if(!state.exclusive && !state.exclusive_waiting_blocked) { ++state.shared_count; return; } shared_cond.wait(lock); } } bool try_lock_shared() { boost::mutex::scoped_lock lock(state_change); if(state.exclusive || state.exclusive_waiting_blocked) { return false; } else { ++state.shared_count; return true; } } bool timed_lock_shared(system_time const& timeout) { boost::this_thread::disable_interruption do_not_disturb; boost::mutex::scoped_lock lock(state_change); #ifdef BOOST_MSVC #pragma warning(push) #pragma warning(disable:4127) #endif while(true) #ifdef BOOST_MSVC #pragma warning(pop) #endif { if(!state.exclusive && !state.exclusive_waiting_blocked) { ++state.shared_count; return true; } if(!shared_cond.timed_wait(lock,timeout)) { return false; } } } void unlock_shared() { boost::mutex::scoped_lock lock(state_change); bool const last_reader=!--state.shared_count; if(last_reader) { if(state.upgrade) { state.upgrade=false; state.exclusive=true; upgrade_cond.notify_one(); } else { state.exclusive_waiting_blocked=false; } release_waiters(); } } void lock() { boost::this_thread::disable_interruption do_not_disturb; boost::mutex::scoped_lock lock(state_change); #ifdef BOOST_MSVC #pragma warning(push) #pragma warning(disable:4127) #endif while(true) #ifdef BOOST_MSVC #pragma warning(pop) #endif { if(state.shared_count || state.exclusive) { state.exclusive_waiting_blocked=true; } else { state.exclusive=true; return; } exclusive_cond.wait(lock); } } bool timed_lock(system_time const& timeout) { boost::this_thread::disable_interruption do_not_disturb; boost::mutex::scoped_lock lock(state_change); #ifdef BOOST_MSVC #pragma warning(push) #pragma warning(disable:4127) #endif while(true) #ifdef BOOST_MSVC #pragma warning(pop) #endif { if(state.shared_count || state.exclusive) { state.exclusive_waiting_blocked=true; } else { state.exclusive=true; return true; } if(!exclusive_cond.timed_wait(lock,timeout)) { return false; } } } bool try_lock() { boost::mutex::scoped_lock lock(state_change); if(state.shared_count || state.exclusive) { return false; } else { state.exclusive=true; return true; } } void unlock() { boost::mutex::scoped_lock lock(state_change); state.exclusive=false; state.exclusive_waiting_blocked=false; release_waiters(); } void lock_upgrade() { boost::this_thread::disable_interruption do_not_disturb; boost::mutex::scoped_lock lock(state_change); #ifdef BOOST_MSVC #pragma warning(push) #pragma warning(disable:4127) #endif while(true) #ifdef BOOST_MSVC #pragma warning(pop) #endif { if(!state.exclusive && !state.exclusive_waiting_blocked && !state.upgrade) { ++state.shared_count; state.upgrade=true; return; } shared_cond.wait(lock); } } bool timed_lock_upgrade(system_time const& timeout) { boost::this_thread::disable_interruption do_not_disturb; boost::mutex::scoped_lock lock(state_change); #ifdef BOOST_MSVC #pragma warning(push) #pragma warning(disable:4127) #endif while(true) #ifdef BOOST_MSVC #pragma warning(pop) #endif { if(!state.exclusive && !state.exclusive_waiting_blocked && !state.upgrade) { ++state.shared_count; state.upgrade=true; return true; } if(!shared_cond.timed_wait(lock,timeout)) { return false; } } } bool try_lock_upgrade() { boost::mutex::scoped_lock lock(state_change); if(state.exclusive || state.exclusive_waiting_blocked || state.upgrade) { return false; } else { ++state.shared_count; state.upgrade=true; return true; } } void unlock_upgrade() { boost::mutex::scoped_lock lock(state_change); state.upgrade=false; bool const last_reader=!--state.shared_count; if(last_reader) { state.exclusive_waiting_blocked=false; release_waiters(); } } void unlock_upgrade_and_lock() { boost::this_thread::disable_interruption do_not_disturb; boost::mutex::scoped_lock lock(state_change); --state.shared_count; #ifdef BOOST_MSVC #pragma warning(push) #pragma warning(disable:4127) #endif while(true) #ifdef BOOST_MSVC #pragma warning(pop) #endif { if(!state.shared_count) { state.upgrade=false; state.exclusive=true; break; } upgrade_cond.wait(lock); } } void unlock_and_lock_upgrade() { boost::mutex::scoped_lock lock(state_change); state.exclusive=false; state.upgrade=true; ++state.shared_count; state.exclusive_waiting_blocked=false; release_waiters(); } void unlock_and_lock_shared() { boost::mutex::scoped_lock lock(state_change); state.exclusive=false; ++state.shared_count; state.exclusive_waiting_blocked=false; release_waiters(); } void unlock_upgrade_and_lock_shared() { boost::mutex::scoped_lock lock(state_change); state.upgrade=false; state.exclusive_waiting_blocked=false; release_waiters(); } }; } #endif
shared_mutex.hpp
Page URL
File URL
Prev
7/11
Next
Download
( 9 KB )
Note: The DriveHQ service banners will NOT be displayed if the file owner is a paid member.
Comments
Total ratings:
0
Average rating:
Not Rated
Would you like to comment?
Join DriveHQ
for a free account, or
Logon
if you are already a member.