// Copyright (C) 2012 Internet Systems Consortium, Inc. ("ISC") // // Permission to use, copy, modify, and/or distribute this software for any // purpose with or without fee is hereby granted, provided that the above // copyright notice and this permission notice appear in all copies. // // THE SOFTWARE IS PROVIDED "AS IS" AND ISC DISCLAIMS ALL WARRANTIES WITH // REGARD TO THIS SOFTWARE INCLUDING ALL IMPLIED WARRANTIES OF MERCHANTABILITY // AND FITNESS. IN NO EVENT SHALL ISC BE LIABLE FOR ANY SPECIAL, DIRECT, // INDIRECT, OR CONSEQUENTIAL DAMAGES OR ANY DAMAGES WHATSOEVER RESULTING FROM // LOSS OF USE, DATA OR PROFITS, WHETHER IN AN ACTION OF CONTRACT, NEGLIGENCE // OR OTHER TORTIOUS ACTION, ARISING OUT OF OR IN CONNECTION WITH THE USE OR // PERFORMANCE OF THIS SOFTWARE. #ifndef __INTERPROCESS_SYNC_FILE_H__ #define __INTERPROCESS_SYNC_FILE_H__ #include "util/interprocess_sync.h" #include "exceptions/exceptions.h" namespace isc { namespace util { /// \brief InterprocessSyncFileError /// /// Exception that is thrown if it's not possible to open the /// lock file. class InterprocessSyncFileError : public Exception { public: InterprocessSyncFileError(const char* file, size_t line, const char* what) : isc::Exception(file, line, what) {} }; /// \brief File-based Interprocess Sync Class /// /// This class specifies a concrete implementation for a file-based /// interprocess synchronization mechanism. Please see the /// InterprocessSync class documentation for usage. /// /// Lock files are created typically in the local state directory /// (var). They are typically named like "_lockfile". /// This implementation opens lock files lazily (only when /// necessary). It also leaves the lock files lying around as multiple /// processes may have locks on them. class InterprocessSyncFile : public InterprocessSync { public: /// \brief Constructor /// /// Creates a file-based interprocess synchronization object /// /// \param name Name of the synchronization task. This has to be /// identical among the various processes that need to be /// synchronized for the same task. InterprocessSyncFile(const std::string& task_name) : InterprocessSync(task_name), fd_(-1) {} /// \brief Destructor virtual ~InterprocessSyncFile(); protected: /// \brief Acquire the lock (blocks if something else has acquired a /// lock on the same task name) /// /// \return Returns true if the lock was acquired, false otherwise. bool lock(); /// \brief Try to acquire a lock (doesn't block) /// /// \return Returns true if the lock was acquired, false otherwise. bool tryLock(); /// \brief Release the lock /// /// \return Returns true if the lock was released, false otherwise. bool unlock(); private: bool do_lock(int cmd, short l_type); int fd_; ///< The descriptor for the open file }; } // namespace util } // namespace isc #endif // __INTERPROCESS_SYNC_FILE_H__