FM / posix

/usr/include/boost/interprocess/sync/posix/

/usr/include/boost/interprocess/sync/posix

Name	Size	Mode	Actions
condition.hpp	5636	0644	edit dl rm
mutex.hpp	3951	0644	edit dl rm
named_mutex.hpp	3423	0644	edit dl rm
named_semaphore.hpp	2622	0644	edit dl rm
pthread_helpers.hpp	5321	0644	edit dl rm
ptime_to_timespec.hpp	1482	0644	edit dl rm
recursive_mutex.hpp	4030	0644	edit dl rm
semaphore.hpp	1762	0644	edit dl rm
semaphore_wrapper.hpp	6807	0644	edit dl rm

Edit: /usr/include/boost/interprocess/sync/posix/named_semaphore.hpp (2622B)

#ifndef BOOST_INTERPROCESS_POSIX_NAMED_CONDITION_HPP
#define BOOST_INTERPROCESS_POSIX_NAMED_CONDITION_HPP

#ifndef BOOST_CONFIG_HPP
#  include <boost/config.hpp>
#endif
#
#if defined(BOOST_HAS_PRAGMA_ONCE)
#  pragma once
#endif

#include <boost/interprocess/detail/config_begin.hpp>
#include <boost/interprocess/detail/workaround.hpp>

#include <boost/interprocess/sync/posix/semaphore_wrapper.hpp>

namespace boost {
namespace interprocess {

#if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED)
namespace ipcdetail{ class interprocess_tester; }
#endif   //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED

namespace ipcdetail {

class posix_named_semaphore
{
   posix_named_semaphore();
   posix_named_semaphore(const posix_named_semaphore&);
   posix_named_semaphore &operator= (const posix_named_semaphore &);

public:
   posix_named_semaphore
      (create_only_t, const char *name, unsigned int initialCount, const permissions &perm = permissions())
   {  semaphore_open(mp_sem, DoCreate, name, initialCount, perm);   }

posix_named_semaphore(open_or_create_t, const char *name, unsigned int initialCount, const permissions &perm = permissions())
   {  semaphore_open(mp_sem, DoOpenOrCreate, name, initialCount, perm);   }

posix_named_semaphore(open_only_t, const char *name)
   {  semaphore_open(mp_sem, DoOpen, name);   }

~posix_named_semaphore()
   {
      if(mp_sem != BOOST_INTERPROCESS_POSIX_SEM_FAILED)
         semaphore_close(mp_sem);
   }

void post()
   {  semaphore_post(mp_sem); }

void wait()
   {  semaphore_wait(mp_sem); }

bool try_wait()
   {  return semaphore_try_wait(mp_sem); }

bool timed_wait(const boost::posix_time::ptime &abs_time)
   {  return semaphore_timed_wait(mp_sem, abs_time); }

static bool remove(const char *name)
   {  return semaphore_unlink(name);   }

private:
   friend class ipcdetail::interprocess_tester;
   void dont_close_on_destruction()
   {  mp_sem = BOOST_INTERPROCESS_POSIX_SEM_FAILED; }

sem_t      *mp_sem;
};

}  //namespace ipcdetail {
}  //namespace interprocess {
}  //namespace boost {

#include <boost/interprocess/detail/config_end.hpp>

#endif   //#ifndef BOOST_INTERPROCESS_POSIX_NAMED_CONDITION_HPP

////////////////////////////////////////////////////////////////////////////// // // (C) Copyright Ion Gaztanaga 2005-2012. 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) // // See http://www.boost.org/libs/interprocess for documentation. // ////////////////////////////////////////////////////////////////////////////// #ifndef BOOST_INTERPROCESS_POSIX_NAMED_CONDITION_HPP #define BOOST_INTERPROCESS_POSIX_NAMED_CONDITION_HPP #ifndef BOOST_CONFIG_HPP # include #endif # #if defined(BOOST_HAS_PRAGMA_ONCE) # pragma once #endif #include #include #include namespace boost { namespace interprocess { #if !defined(BOOST_INTERPROCESS_DOXYGEN_INVOKED) namespace ipcdetail{ class interprocess_tester; } #endif //#ifndef BOOST_INTERPROCESS_DOXYGEN_INVOKED namespace ipcdetail { class posix_named_semaphore { posix_named_semaphore(); posix_named_semaphore(const posix_named_semaphore&); posix_named_semaphore &operator= (const posix_named_semaphore &); public: posix_named_semaphore (create_only_t, const char *name, unsigned int initialCount, const permissions &perm = permissions()) { semaphore_open(mp_sem, DoCreate, name, initialCount, perm); } posix_named_semaphore(open_or_create_t, const char *name, unsigned int initialCount, const permissions &perm = permissions()) { semaphore_open(mp_sem, DoOpenOrCreate, name, initialCount, perm); } posix_named_semaphore(open_only_t, const char *name) { semaphore_open(mp_sem, DoOpen, name); } ~posix_named_semaphore() { if(mp_sem != BOOST_INTERPROCESS_POSIX_SEM_FAILED) semaphore_close(mp_sem); } void post() { semaphore_post(mp_sem); } void wait() { semaphore_wait(mp_sem); } bool try_wait() { return semaphore_try_wait(mp_sem); } bool timed_wait(const boost::posix_time::ptime &abs_time) { return semaphore_timed_wait(mp_sem, abs_time); } static bool remove(const char *name) { return semaphore_unlink(name); } private: friend class ipcdetail::interprocess_tester; void dont_close_on_destruction() { mp_sem = BOOST_INTERPROCESS_POSIX_SEM_FAILED; } sem_t *mp_sem; }; } //namespace ipcdetail { } //namespace interprocess { } //namespace boost { #include #endif //#ifndef BOOST_INTERPROCESS_POSIX_NAMED_CONDITION_HPP