mirror of
https://github.com/mutouyun/cpp-ipc.git
synced 2026-01-01 03:12:13 +08:00
2ff5c94479
- Add LIBIPC_LOG() to functions in platform files that use log.error/warning/debug - Fixed files: - POSIX platform: mutex.h, semaphore_impl.h, shm_posix.cpp - Windows platform: get_sa.h, mutex.h, semaphore.h, shm_win.cpp - Sync layer: condition.cpp, mutex.cpp, semaphore.cpp All functions using the new log interface now properly initialize the logger with LIBIPC_LOG()
87 lines
1.7 KiB
C++
87 lines
1.7 KiB
C++
|
|
#include "libipc/mutex.h"
|
|
|
|
#include "libipc/utility/pimpl.h"
|
|
#include "libipc/imp/log.h"
|
|
#include "libipc/mem/resource.h"
|
|
#include "libipc/platform/detail.h"
|
|
#if defined(LIBIPC_OS_WIN)
|
|
#include "libipc/platform/win/mutex.h"
|
|
#elif defined(LIBIPC_OS_LINUX)
|
|
#include "libipc/platform/linux/mutex.h"
|
|
#elif defined(LIBIPC_OS_QNX) || defined(LIBIPC_OS_FREEBSD)
|
|
#include "libipc/platform/posix/mutex.h"
|
|
#else/*IPC_OS*/
|
|
# error "Unsupported platform."
|
|
#endif
|
|
|
|
namespace ipc {
|
|
namespace sync {
|
|
|
|
class mutex::mutex_ : public ipc::pimpl<mutex_> {
|
|
public:
|
|
ipc::detail::sync::mutex lock_;
|
|
};
|
|
|
|
mutex::mutex()
|
|
: p_(p_->make()) {
|
|
}
|
|
|
|
mutex::mutex(char const * name)
|
|
: mutex() {
|
|
open(name);
|
|
}
|
|
|
|
mutex::~mutex() {
|
|
close();
|
|
p_->clear();
|
|
}
|
|
|
|
void const *mutex::native() const noexcept {
|
|
return impl(p_)->lock_.native();
|
|
}
|
|
|
|
void *mutex::native() noexcept {
|
|
return impl(p_)->lock_.native();
|
|
}
|
|
|
|
bool mutex::valid() const noexcept {
|
|
return impl(p_)->lock_.valid();
|
|
}
|
|
|
|
bool mutex::open(char const *name) noexcept {
|
|
LIBIPC_LOG();
|
|
if (!is_valid_string(name)) {
|
|
log.error("fail mutex open: name is empty");
|
|
return false;
|
|
}
|
|
return impl(p_)->lock_.open(name);
|
|
}
|
|
|
|
void mutex::close() noexcept {
|
|
impl(p_)->lock_.close();
|
|
}
|
|
|
|
void mutex::clear() noexcept {
|
|
impl(p_)->lock_.clear();
|
|
}
|
|
|
|
void mutex::clear_storage(char const * name) noexcept {
|
|
ipc::detail::sync::mutex::clear_storage(name);
|
|
}
|
|
|
|
bool mutex::lock(std::uint64_t tm) noexcept {
|
|
return impl(p_)->lock_.lock(tm);
|
|
}
|
|
|
|
bool mutex::try_lock() noexcept(false) {
|
|
return impl(p_)->lock_.try_lock();
|
|
}
|
|
|
|
bool mutex::unlock() noexcept {
|
|
return impl(p_)->lock_.unlock();
|
|
}
|
|
|
|
} // namespace sync
|
|
} // namespace ipc
|