Skip to content

Commit 17dcde9

Browse files
committed
Added clear_storage for quieue
1 parent ab90437 commit 17dcde9

File tree

2 files changed

+6
-2
lines changed

2 files changed

+6
-2
lines changed

src/libipc/queue.h

Lines changed: 4 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -59,6 +59,10 @@ class queue_conn {
5959
elems_h_.clear();
6060
}
6161

62+
static void clear_storage(char const *name) noexcept {
63+
shm::handle::clear_storage(name);
64+
}
65+
6266
bool connected() const noexcept {
6367
return connected_ != 0;
6468
}

src/libipc/waiter.h

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -57,8 +57,8 @@ class waiter {
5757
}
5858

5959
static void clear_storage(char const *name) noexcept {
60-
ipc::sync::condition::clear_storage(name);
61-
ipc::sync::mutex::clear_storage(name);
60+
ipc::sync::condition::clear_storage((std::string{name} + "_WAITER_COND_").c_str());
61+
ipc::sync::mutex::clear_storage((std::string{name} + "_WAITER_LOCK_").c_str());
6262
}
6363

6464
template <typename F>

0 commit comments

Comments
 (0)