Thread portable class Gate portable class Timer class Pool class Terimber 2.0 About C++

Downloads Products & Services Support Clients Open Source About Home / Open source / Terimber 2.0 keymaker.hpp Go to the documentation of this file. /* * The Software License * ================================================================================= * Copyright (c) 2003-.The Terimber Corporation. All rights reserved. * ================================================================================= * Redistributions of source code must retain the above copyright notice, * this list of conditions and the following disclaimer. * Redistributions in binary form must reproduce the above copyright notice, * this list of conditions and the following disclaimer in the documentation * and/or other materials provided with the distribution. * The end-user documentation included with the redistribution, if any, * must include the following acknowledgment: * "This product includes software developed by the Terimber Corporation." * ================================================================================= * THIS SOFTWARE IS PROVIDED "AS IS" AND ANY EXPRESSED OR IMPLIED WARRANTIES, * INCLUDING, BUT NOT LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY * AND FITNESS FOR A PARTICULAR PURPOSE ARE DISCLAIMED. * IN NO EVENT SHALL THE TERIMBER CORPORATION OR ITS CONTRIBUTORS BE LIABLE FOR * ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES * (INCLUDING, BUT NOT LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; * LOSS OF USE, DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON * ANY THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. * ================================================================================ */ #ifndef _terimber_keymaker_hpp_ #define _terimber_keymaker_hpp_ #include "base/keymaker.h" #include "base/date.h" BEGIN_TERIMBER_NAMESPACE #pragma pack(4) inline keylocker::keylocker(size_t capacity) : _capacity(capacity), _opened(true), _clients(0), _ev_open(true, true), _ev_close(true, false), _ev_client(false, false), _ev_server(false, false) { } // client calls inline bool keylocker::enter(size_t timeout) const { size_t waittime = 0; // locks mutex mutex_keeper guard(_access_mtx); // access to resources while (waittime < timeout) // loops until we get client resource or run out of time { if (!_opened) // locker closed { // unlocks mutex guard.unlock(); // gets the current date date now; if (WAIT_OBJECT_0 != _ev_open.wait(timeout - waittime)) // wait for unlock return false; // locks mutex guard.lock(); // adjusts timeout waittime += (size_t)date::get_difference(now); } else if (_clients >= _capacity) // locker open but no rooms are available { // unlocks mutex guard.unlock(); // gets the current date date now; if (WAIT_OBJECT_0 != _ev_client.wait(timeout - waittime)) // wait for unlock return false; // locks mutex guard.lock(); // adjusts waittime waittime += (size_t)date::get_difference(now); } else { ++_clients; // increment client counter return true; } } return false; } inline void keylocker::leave() const { mutex_keeper guard(_access_mtx); // access to resources assert(_clients > 0); --_clients; // decrements clients if (_opened) // has client rooms and key is open { guard.unlock(); _ev_client.signal(); } else if (!_clients) // last client left { guard.unlock(); _ev_close.signal(); } } // server calls inline bool keylocker::lock(size_t timeout) const { size_t waittime = 0; // locks mutex mutex_keeper guard(_access_mtx); // access to resources while (waittime < timeout) // loops until we get client resource or run out of time { if (_opened) // already locked { _server_mtx.lock(); // lock other server calls _ev_open.nonsignal(); // resets event if (!_clients) { _opened = false; // locks the door // resets signal _ev_close.nonsignal(); return true; } } if (!_opened) { // unlocks mutex guard.unlock(); // gets the current date date now; if (WAIT_OBJECT_0 != _ev_server.wait(timeout - waittime)) // wait for unlock return false; // locks mutex guard.lock(); // adjusts timeout waittime += (size_t)date::get_difference(now); } else if (_clients) // clients are still here { _opened = false; // locks the door // unlocks mutex guard.unlock(); if (WAIT_OBJECT_0 != _ev_close.wait(timeout - waittime)) // wait for clients left { // locks mutex guard.lock(); _opened = true; // unlocks the door // unlocks mutex guard.unlock(); _ev_open.signal(); // sets the event, lets clients enter first before... // lets other server calls go through _server_mtx.unlock(); _ev_server.signal(); return false; } // resets signal _ev_close.nonsignal(); return true; } } return false; } inline void keylocker::unlock() const { // locks mutex mutex_keeper guard(_access_mtx); // access to resources if (_opened) // should not happend { return; } _opened = true; // unlocks the door // unlocks mutex guard.unlock(); _ev_open.signal(); // notifies clients who are waiting for entry, if any // lets other server calls go through _server_mtx.unlock(); _ev_server.signal(); } inline keylocker_server::keylocker_server(const keylocker& locker, size_t timeout) : _locker(locker) { _locked = _locker.lock(timeout); } // // destructor // inline keylocker_server::~keylocker_server() { if (_locked) _locker.unlock(); } // // checks the locked state // inline keylocker_server::operator bool() const { return _locked; } inline bool keylocker_server::operator!() const { return !_locked; } inline void keylocker_server::unlock() const { if (_locked) _locker.unlock(), _locked = false; } inline void keylocker_server::lock(size_t timeout) const { if (!_locked) _locked = _locker.lock(timeout); } // class supports automatic entry/leave of gate // // constructor // inline keylocker_client::keylocker_client(const keylocker& locker, size_t timeout) : _locker(locker) { _inside = _locker.enter(timeout); } // // destructor // inline keylocker_client::~keylocker_client() { if (_inside) _locker.leave(); } // checks access flag inline keylocker_client::operator bool() const { return _inside; } inline bool keylocker_client::operator!() const { return !_inside; } inline void keylocker_client::leave() const { if (_inside) _locker.leave(), _inside = false; } inline void keylocker_client::enter(size_t timeout) const { if (!_inside) _inside = _locker.enter(timeout); } #pragma pack() END_TERIMBER_NAMESPACE #endif // _terimber_keymaker_hpp_

© Copyright Terimber 2003-.