#include <boost/weak_ptr.hpp>
+#include <map>
+#include <string>
+
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
namespace isc {
namespace util {
+namespace { // unnamed namespace
+
+typedef std::map<std::string, boost::weak_ptr<Mutex> > SyncMap;
+
+Mutex sync_map_mutex;
+SyncMap sync_map;
+
+} // end of unnamed namespace
+
InterprocessSyncFile::InterprocessSyncFile(const std::string& task_name) :
InterprocessSync(task_name),
fd_(-1)
{
- Mutex::Locker locker(getSyncMapMutex());
+ Mutex::Locker locker(sync_map_mutex);
- SyncMap& sync_map = getSyncMap();
SyncMap::iterator it = sync_map.find(task_name);
if (it != sync_map.end()) {
mutex_ = it->second.lock();
// it.
}
- Mutex::Locker locker(getSyncMapMutex());
+ Mutex::Locker locker(sync_map_mutex);
// Unref the shared mutex.
locker_.reset();
mutex_.reset();
// Remove name from the map if it is unused anymore.
- SyncMap& sync_map = getSyncMap();
SyncMap::iterator it = sync_map.find(task_name_);
assert(it != sync_map.end());
// destruction when basic block is exited.
}
-InterprocessSyncFile::SyncMap&
-InterprocessSyncFile::getSyncMap() {
- // avoid static destruction fiasco when the SyncMap is destroyed
- // before clients which use it such as logger objects. This leaks,
- // but isn't a growing leak.
- static SyncMap* sync_map = new SyncMap;
-
- return (*sync_map);
-}
-
-Mutex&
-InterprocessSyncFile::getSyncMapMutex() {
- // avoid static destruction fiasco when the Mutex is destroyed
- // before clients which use it such as logger objects. This leaks,
- // but isn't a growing leak.
- static Mutex* sync_map_mutex = new Mutex;
-
- return (*sync_map_mutex);
-}
-
bool
InterprocessSyncFile::do_lock(int cmd, short l_type) {
// Open lock file only when necessary (i.e., here). This is so that
#include <boost/shared_ptr.hpp>
-#include <map>
-#include <string>
-
namespace isc {
namespace util {
bool unlock();
private:
- typedef boost::shared_ptr<isc::util::thread::Mutex> MutexPtr;
- typedef boost::shared_ptr<isc::util::thread::Mutex::Locker> LockerPtr;
- typedef std::map<std::string, boost::weak_ptr<isc::util::thread::Mutex> >
- SyncMap;
-
- SyncMap& getSyncMap();
- isc::util::thread::Mutex& getSyncMapMutex();
bool do_lock(int cmd, short l_type);
int fd_; ///< The descriptor for the open file
+
+ typedef boost::shared_ptr<isc::util::thread::Mutex> MutexPtr;
+ typedef boost::shared_ptr<isc::util::thread::Mutex::Locker> LockerPtr;
MutexPtr mutex_; ///< A mutex for mutual exclusion among threads
LockerPtr locker_; ///< A locker on mutex_
};