diff --git a/include/ipc.h b/include/ipc.h index af0dfae..8cf0418 100644 --- a/include/ipc.h +++ b/include/ipc.h @@ -21,9 +21,6 @@ struct IPC_EXPORT channel_detail { static std::size_t recv_count(handle_t h); static bool wait_for_recv(handle_t h, std::size_t r_count); - static void clear_recv(handle_t h); - static void clear_recv(char const * name); - static bool send(handle_t h, void const * data, std::size_t size); static buff_t recv(handle_t h); }; @@ -101,14 +98,6 @@ public: return channel_impl(name).wait_for_recv(r_count); } - void clear_recv() { - Detail::clear_recv(h_); - } - - static void clear_recv(char const * name) { - Detail::clear_recv(name); - } - bool send(void const * data, std::size_t size) { return Detail::send(h_, data, size); } diff --git a/src/ipc.cpp b/src/ipc.cpp index 44b6773..e04ef9b 100644 --- a/src/ipc.cpp +++ b/src/ipc.cpp @@ -118,20 +118,6 @@ static bool wait_for_recv(ipc::handle_t h, std::size_t r_count) { return que->wait_for_connect(r_count); } -static void clear_recv(ipc::handle_t h) { - auto* head = head_of(queue_of(h)); - if (head == nullptr) { - return; - } - std::memset(head, 0, sizeof(typename queue_t::elems_t)); -} - -static void clear_recv(char const * name) { - auto h = connect(name); - clear_recv(h); - disconnect(h); -} - static bool send(ipc::handle_t h, void const * data, std::size_t size) { if (data == nullptr) { return false; @@ -237,16 +223,6 @@ bool channel_detail::wait_for_recv(ipc::handle_t h, std::size_t r_count) { return detail_impl>::wait_for_recv(h, r_count); } -template -void channel_detail::clear_recv(ipc::handle_t h) { - detail_impl>::clear_recv(h); -} - -template -void channel_detail::clear_recv(char const * name) { - detail_impl>::clear_recv(name); -} - template bool channel_detail::send(ipc::handle_t h, void const * data, std::size_t size) { return detail_impl>::send(h, data, size); diff --git a/test/test_ipc.cpp b/test/test_ipc.cpp index 43c3426..70f6953 100644 --- a/test/test_ipc.cpp +++ b/test/test_ipc.cpp @@ -68,7 +68,6 @@ struct test_cq { test_cq(void*) : conn_name_("test-ipc-route") { - cn_t::clear_recv(conn_name_.c_str()); } cn_t connect() { @@ -324,8 +323,6 @@ void test_prod_cons() { } void Unit::test_route() { - ipc::route::clear_recv("my-ipc-route"); - std::vector const datas = { "hello!", "foo",