Pagina Principale   Moduli   Lista dei namespaces   Gerarchia delle classi   Lista in ordine alfabetico   Lista dei composti   Lista dei files   Membri dei namespaces   Membri dei composti   Membri dei files   Esempi  

/home/fbassi/devel/projects/reti/utils/ShareLock.cc

Vai alla documentazione di questo file.
00001 /*
00002  *    FBFS Distributed Object Repository
00003  *    Copyright (C) 2001 Francesco V. Bassi
00004  *
00005  *    This program is free software; you can redistribute it and/or modify
00006  *    it under the terms of the GNU General Public License as published by
00007  *    the Free Software Foundation; either version 2 of the License, or
00008  *    (at your option) any later version.
00009  *
00010  *    This program is distributed in the hope that it will be useful,
00011  *    but WITHOUT ANY WARRANTY; without even the implied warranty of
00012  *    MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
00013  *    GNU General Public License for more details.
00014  *
00015  *    You should have received a copy of the GNU General Public License
00016  *    along with this program; if not, write to the Free Software
00017  *    Foundation, Inc., 59 Temple Place, Suite 330, Boston, MA  02111-1307  USA
00018  */
00019 
00025 #include "ShareLock.h"
00026 
00027 utils::ShareLock::ShareLock() {
00028     pthread_mutex_init(&mut, NULL);
00029     pthread_cond_init(&cond, NULL);
00030 };
00031 
00032 utils::ShareLock::~ShareLock() {
00033     pthread_mutex_destroy(&mut);
00034     pthread_cond_destroy(&cond);
00035 };
00036 
00037 inline void utils::ShareLock::alloc(const string &res, bool ex) {
00038     if(ex)
00039         excl.insert(res);
00040     else
00041         shared.insert(res);
00042 };
00043 
00044 inline void utils::ShareLock::free(const string &res) {
00045     if(shared.count(res)==0)
00046         excl.erase(res);
00047     else
00048         shared.erase(res);
00049 };
00050 
00051 inline bool utils::ShareLock::isbusy(const string &res, bool ex) {
00052     return excl.count(res)!=0 || (ex && (shared.count(res)!=0) );
00053 };
00054 
00055 void utils::ShareLock::lock(const string &resource, bool ex=false) {
00056     pthread_mutex_lock(&mut);
00057     while(isbusy(resource, ex))
00058         pthread_cond_wait(&cond, &mut);
00059     alloc(resource, ex);
00060     pthread_mutex_unlock(&mut);
00061 };
00062 
00063 void utils::ShareLock::unlock(const string &resource) {
00064     pthread_mutex_lock(&mut);
00065     free(resource);
00066     pthread_cond_broadcast(&cond);
00067     pthread_mutex_unlock(&mut);
00068 };
00069 

Generato il Thu Feb 15 13:24:57 2001 per A Simple Distributed Object Repository with CORBA & C++. da doxygen1.2.3 scritto da Dimitri van Heesch, © 1997-2000