RobustMutex.hpp

Go to the documentation of this file.

 
#ifndef _uhal_ipc_RobustMutex_hpp_
#define _uhal_ipc_RobustMutex_hpp_
 
#include <cstdint>
 
#include "uhal/ClientInterface.hpp"
#include "uhal/log/exception.hpp"
 
namespace uhallibs {
namespace ipc {
 
namespace exception {
UHAL_DEFINE_DERIVED_EXCEPTION_CLASS(MutexError,
                                    uhal::exception::TransportLayerError,
                                    "Exception class to handle errors from pthread mutex-related functions.")
} // namespace exception
 
class RobustMutex
{
public:
  RobustMutex();
  ~RobustMutex();
 
  void lock();
 
  void unlock();
 
  uint64_t getCounter() const;
 
  bool isActive() const;
 
  void startSession();
 
  void endSession();
 
private:
  RobustMutex(const RobustMutex&);
 
  pthread_mutex_t mMutex;
  uint64_t mCount;
  bool mSessionActive;
};
 
} // namespace ipc
} // namespace uhal
 
#endif /* _uhal_ipc_RobustMutex_hpp_ */