coffee/cpp-ipc
1
0
Fork 0
mirror of https://github.com/mutouyun/cpp-ipc.git synced 2025-12-07 01:06:45 +08:00
Code Issues Packages Projects Releases Wiki Activity

adjust naming

Browse Source
This commit is contained in:
mutouyun 2019-02-13 07:09:10 +08:00
parent ed6af29264
commit fd92e94e51
1 changed files with 19 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

36
src/platform/waiter_win.h
View File

@ -68,56 +68,58 @@ public:
}
private:
semaphore& s(handle_t& h) { return std::get<0>(h); }
semaphore& w(handle_t& h) { return std::get<1>(h); }
mutex & x(handle_t& h) { return std::get<2>(h); }
semaphore& sem(handle_t& h) { return std::get<0>(h); }
semaphore& han(handle_t& h) { return std::get<1>(h); }
mutex & mtx(handle_t& h) { return std::get<2>(h); }
public:
handle_t open(char const * name) {
if (name == nullptr || name[0] == '\0') return invalid();
std::string n = name;
return handle_t {
semaphore {}.open(ipc::detail::to_tchar(n + "__S__")),
semaphore {}.open(ipc::detail::to_tchar(n + "__W__")),
mutex {}.open(ipc::detail::to_tchar(n + "__X__"))
semaphore {}.open(ipc::detail::to_tchar(n + "__SEM__")),
semaphore {}.open(ipc::detail::to_tchar(n + "__HAN__")),
mutex {}.open(ipc::detail::to_tchar(n + "__MTX__"))
};
}
void close(handle_t& h) {
if (h == invalid()) return;
x(h).close();
w(h).close();
s(h).close();
mtx(h).close();
han(h).close();
sem(h).close();
}
template <typename F>
bool wait_if(handle_t& h, F&& pred) {
if (h == invalid()) return false;
{
IPC_UNUSED_ auto guard = ipc::detail::unique_lock(x(h));
IPC_UNUSED_ auto guard = ipc::detail::unique_lock(mtx(h));
if (!std::forward<F>(pred)()) return true;
++ counter_;
}
return s(h).wait() && w(h).post();
bool ret_s = sem(h).wait();
bool ret_h = han(h).post();
return ret_s && ret_h;
}
void notify(handle_t& h) {
if (h == invalid()) return;
IPC_UNUSED_ auto guard = ipc::detail::unique_lock(x(h));
IPC_UNUSED_ auto guard = ipc::detail::unique_lock(mtx(h));
if (counter_ > 0) {
s(h).post();
sem(h).post();
-- counter_;
w(h).wait();
han(h).wait();
}
}
void broadcast(handle_t& h) {
if (h == invalid()) return;
IPC_UNUSED_ auto guard = ipc::detail::unique_lock(x(h));
s(h).post(counter_);
IPC_UNUSED_ auto guard = ipc::detail::unique_lock(mtx(h));
sem(h).post(counter_);
while (counter_ > 0) {
-- counter_;
w(h).wait();
han(h).wait();
}
}
};