Mutex.h

#ifndef DASH__MUTEX_H__INCLUDED
#define DASH__MUTEX_H__INCLUDED

#include <dash/Team.h>
#include <dash/dart/if/dart_synchronization.h>

namespace dash {

class Mutex {
private:
  using self_t = Mutex;

  struct DestroyDARTLock {
    void operator()(dart_lock_t lock)
    {
      if (DART_LOCK_NULL != lock) {
        auto ret = dart_team_lock_destroy(&lock);

        if (ret != DART_OK) {
          DASH_LOG_ERROR(
              "dash::Mutex::operator()",
              "Failed to destroy DART lock! "
              "(dart_team_lock_destroy failed)");
        }
      }
    }
  };

public:
  explicit Mutex(Team& team = dash::Team::All());

  Mutex(const Mutex& other) = delete;
  Mutex(Mutex&& other)      = default;

  self_t& operator=(const self_t& other) = delete;
  self_t& operator=(self_t&& other) = default;

  ~Mutex() = default;

  bool init();

  void lock();

  bool try_lock();

  void unlock();

private:
  dash::Team const* _team{nullptr};
  std::unique_ptr<std::remove_pointer<dart_lock_t>::type, DestroyDARTLock>
      _mutex{DART_LOCK_NULL};
};  // class Mutex

}  // namespace dash

#endif  // DASH__MUTEX_H__INCLUDED