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

remove clear_recv

Browse Source
This commit is contained in:
mutouyun 2019-01-24 21:51:22 +08:00
parent 38449a598d
commit 3713d46f3e
3 changed files with 0 additions and 38 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
include/ipc.h
View File

@ -21,9 +21,6 @@ struct IPC_EXPORT channel_detail {
static std::size_t recv_count(handle_t h); static std::size_t recv_count(handle_t h);
static bool wait_for_recv(handle_t h, std::size_t r_count); 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 bool send(handle_t h, void const * data, std::size_t size);
static buff_t recv(handle_t h); static buff_t recv(handle_t h);
}; };
@ -101,14 +98,6 @@ public:
return channel_impl(name).wait_for_recv(r_count); 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) { bool send(void const * data, std::size_t size) {
return Detail::send(h_, data, size); return Detail::send(h_, data, size);
} }

24
src/ipc.cpp
View File

@ -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); 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) { static bool send(ipc::handle_t h, void const * data, std::size_t size) {
if (data == nullptr) { if (data == nullptr) {
return false; return false;
@ -237,16 +223,6 @@ bool channel_detail<Flag>::wait_for_recv(ipc::handle_t h, std::size_t r_count) {
return detail_impl<policy_t<Flag>>::wait_for_recv(h, r_count); return detail_impl<policy_t<Flag>>::wait_for_recv(h, r_count);
} }
template <typename Flag>
void channel_detail<Flag>::clear_recv(ipc::handle_t h) {
detail_impl<policy_t<Flag>>::clear_recv(h);
}
template <typename Flag>
void channel_detail<Flag>::clear_recv(char const * name) {
detail_impl<policy_t<Flag>>::clear_recv(name);
}
template <typename Flag> template <typename Flag>
bool channel_detail<Flag>::send(ipc::handle_t h, void const * data, std::size_t size) { bool channel_detail<Flag>::send(ipc::handle_t h, void const * data, std::size_t size) {
return detail_impl<policy_t<Flag>>::send(h, data, size); return detail_impl<policy_t<Flag>>::send(h, data, size);

3
test/test_ipc.cpp
View File

@ -68,7 +68,6 @@ struct test_cq<ipc::route> {
test_cq(void*) test_cq(void*)
: conn_name_("test-ipc-route") { : conn_name_("test-ipc-route") {
cn_t::clear_recv(conn_name_.c_str());
} }
cn_t connect() { cn_t connect() {
@ -324,8 +323,6 @@ void test_prod_cons() {
} }
void Unit::test_route() { void Unit::test_route() {
ipc::route::clear_recv("my-ipc-route");
std::vector<char const *> const datas = { std::vector<char const *> const datas = {
"hello!", "hello!",
"foo", "foo",