- bool push(F&& prep, P&&... params) {
- if (elems_ == nullptr) return false;
- return elems_->push(this, [&](void* p) {
- if (prep(p)) ::new (p) T(std::forward(params)...);
- });
- }
-
- template
- bool force_push(F&& prep, P&&... params) {
- if (elems_ == nullptr) return false;
- return elems_->force_push(this, [&](void* p) {
- if (prep(p)) ::new (p) T(std::forward(params)...);
- });
- }
-
- template
- bool pop(T& item, F&& out) {
- if (elems_ == nullptr) {
- return false;
- }
- return elems_->pop(this, &(this->cursor_), [&item](void* p) {
- ::new (&item) T(std::move(*static_cast(p)));
- }, std::forward(out));
- }
-};
-
-} // namespace detail
-
-template
-class queue final : public detail::queue_base> {
- using base_t = detail::queue_base>;
-
-public:
- using value_t = T;
-
- using base_t::base_t;
-
- template
- bool push(P&&... params) {
- return base_t::template push(std::forward(params)...);
- }
-
- template
- bool force_push(P&&... params) {
- return base_t::template force_push(std::forward(params)...);
- }
-
- bool pop(T& item) {
- return base_t::pop(item, [](bool) {});
- }
-
- template
- bool pop(T& item, F&& out) {
- return base_t::pop(item, std::forward(out));
- }
-};
-
-} // namespace ipc
diff --git a/crazy_functions/test_project/cpp/cppipc/shm.cpp b/crazy_functions/test_project/cpp/cppipc/shm.cpp
deleted file mode 100644
index 92f96ef4..00000000
--- a/crazy_functions/test_project/cpp/cppipc/shm.cpp
+++ /dev/null
@@ -1,103 +0,0 @@
-
-#include
-#include
-
-#include "libipc/shm.h"
-
-#include "libipc/utility/pimpl.h"
-#include "libipc/memory/resource.h"
-
-namespace ipc {
-namespace shm {
-
-class handle::handle_ : public pimpl {
-public:
- shm::id_t id_ = nullptr;
- void* m_ = nullptr;
-
- ipc::string n_;
- std::size_t s_ = 0;
-};
-
-handle::handle()
- : p_(p_->make()) {
-}
-
-handle::handle(char const * name, std::size_t size, unsigned mode)
- : handle() {
- acquire(name, size, mode);
-}
-
-handle::handle(handle&& rhs)
- : handle() {
- swap(rhs);
-}
-
-handle::~handle() {
- release();
- p_->clear();
-}
-
-void handle::swap(handle& rhs) {
- std::swap(p_, rhs.p_);
-}
-
-handle& handle::operator=(handle rhs) {
- swap(rhs);
- return *this;
-}
-
-bool handle::valid() const noexcept {
- return impl(p_)->m_ != nullptr;
-}
-
-std::size_t handle::size() const noexcept {
- return impl(p_)->s_;
-}
-
-char const * handle::name() const noexcept {
- return impl(p_)->n_.c_str();
-}
-
-std::int32_t handle::ref() const noexcept {
- return shm::get_ref(impl(p_)->id_);
-}
-
-void handle::sub_ref() noexcept {
- shm::sub_ref(impl(p_)->id_);
-}
-
-bool handle::acquire(char const * name, std::size_t size, unsigned mode) {
- release();
- impl(p_)->id_ = shm::acquire((impl(p_)->n_ = name).c_str(), size, mode);
- impl(p_)->m_ = shm::get_mem(impl(p_)->id_, &(impl(p_)->s_));
- return valid();
-}
-
-std::int32_t handle::release() {
- if (impl(p_)->id_ == nullptr) return -1;
- return shm::release(detach());
-}
-
-void* handle::get() const {
- return impl(p_)->m_;
-}
-
-void handle::attach(id_t id) {
- if (id == nullptr) return;
- release();
- impl(p_)->id_ = id;
- impl(p_)->m_ = shm::get_mem(impl(p_)->id_, &(impl(p_)->s_));
-}
-
-id_t handle::detach() {
- auto old = impl(p_)->id_;
- impl(p_)->id_ = nullptr;
- impl(p_)->m_ = nullptr;
- impl(p_)->s_ = 0;
- impl(p_)->n_.clear();
- return old;
-}
-
-} // namespace shm
-} // namespace ipc
diff --git a/crazy_functions/test_project/cpp/cppipc/waiter.h b/crazy_functions/test_project/cpp/cppipc/waiter.h
deleted file mode 100644
index ee45fe35..00000000
--- a/crazy_functions/test_project/cpp/cppipc/waiter.h
+++ /dev/null
@@ -1,83 +0,0 @@
-#pragma once
-
-#include
-#include
-#include
-#include
-
-#include "libipc/def.h"
-#include "libipc/mutex.h"
-#include "libipc/condition.h"
-#include "libipc/platform/detail.h"
-
-namespace ipc {
-namespace detail {
-
-class waiter {
- ipc::sync::condition cond_;
- ipc::sync::mutex lock_;
- std::atomic quit_ {false};
-
-public:
- static void init();
-
- waiter() = default;
- waiter(char const *name) {
- open(name);
- }
-
- ~waiter() {
- close();
- }
-
- bool valid() const noexcept {
- return cond_.valid() && lock_.valid();
- }
-
- bool open(char const *name) noexcept {
- quit_.store(false, std::memory_order_relaxed);
- if (!cond_.open((std::string{"_waiter_cond_"} + name).c_str())) {
- return false;
- }
- if (!lock_.open((std::string{"_waiter_lock_"} + name).c_str())) {
- cond_.close();
- return false;
- }
- return valid();
- }
-
- void close() noexcept {
- cond_.close();
- lock_.close();
- }
-
- template
- bool wait_if(F &&pred, std::uint64_t tm = ipc::invalid_value) noexcept {
- IPC_UNUSED_ std::lock_guard guard {lock_};
- while ([this, &pred] {
- return !quit_.load(std::memory_order_relaxed)
- && std::forward
-
+