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

fix wrong word

Browse Source
This commit is contained in:
mutouyun 2018-11-29 00:20:15 +08:00
parent 7d91b187fe
commit b3ad167970
2 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
include/circ_queue.h
View File

@ -29,7 +29,7 @@ public:
queue(void) = default; queue(void) = default;
explicit queue(array_t* arr) : queue() { explicit queue(array_t* arr) : queue() {
attch(arr); attach(arr);
} }
queue(queue&& rhs) : queue() { queue(queue&& rhs) : queue() {
@ -61,7 +61,7 @@ public:
return elems_->disconnect(); return elems_->disconnect();
} }
array_t* attch(array_t* arr) { array_t* attach(array_t* arr) {
if (arr == nullptr) return nullptr; if (arr == nullptr) return nullptr;
auto old = elems_; auto old = elems_;
elems_ = arr; elems_ = arr;
@ -89,7 +89,7 @@ public:
T pop(void) { T pop(void) {
if (elems_ == nullptr) throw std::invalid_argument { if (elems_ == nullptr) throw std::invalid_argument {
"This queue hasn't connected to any elem_array." "This queue hasn't attached any elem_array."
}; };
while (cursor_ == elems_->cursor()) { while (cursor_ == elems_->cursor()) {
std::this_thread::yield(); std::this_thread::yield();

4
test/test_circ.cpp
View File

@ -196,7 +196,7 @@ struct test_cq<ipc::circ::queue<T>> {
cn_t connect(void) { cn_t connect(void) {
cn_t queue; cn_t queue;
[&] { [&] {
queue.attch(ca_); queue.attach(ca_);
QVERIFY(queue.connect() != ipc::error_count); QVERIFY(queue.connect() != ipc::error_count);
} (); } ();
return queue; return queue;
@ -314,7 +314,7 @@ void Unit::test_queue(void) {
QVERIFY(sizeof(decltype(queue)::array_t) <= sizeof(*cq__)); QVERIFY(sizeof(decltype(queue)::array_t) <= sizeof(*cq__));
auto cq = ::new (cq__) decltype(queue)::array_t; auto cq = ::new (cq__) decltype(queue)::array_t;
queue.attch(cq); queue.attach(cq);
QVERIFY(queue.detach() != nullptr); QVERIFY(queue.detach() != nullptr);
test_prod_cons<1, 3>((ipc::circ::queue<msg_t>*)nullptr); test_prod_cons<1, 3>((ipc::circ::queue<msg_t>*)nullptr);