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

still have bugs

Browse Source
This commit is contained in:
mutouyun 2018-11-26 18:15:07 +08:00
parent 453f93a69e
commit e2cdcb24c3
1 changed files with 3 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
src/circ_elem_array.h
View File

@ -52,15 +52,14 @@ public:
static_assert(data_size % alignof(head_t) == 0, "data_size must be multiple of alignof(head_t)"); static_assert(data_size % alignof(head_t) == 0, "data_size must be multiple of alignof(head_t)");
private: private:
byte_t block_[block_size];
struct elem_t { struct elem_t {
head_t head_; head_t head_;
byte_t data_[data_size]; byte_t data_[data_size];
}; };
elem_t block_[elem_max];
elem_t* elem_start(void) { elem_t* elem_start(void) {
return reinterpret_cast<elem_t*>(block_); return block_;
} }
static elem_t* elem(void* ptr) { static elem_t* elem(void* ptr) {
@ -148,7 +147,7 @@ public:
} while(!(cas = cr_.compare_exchange_weak(curr, next, std::memory_order_acq_rel)) && no_next); } while(!(cas = cr_.compare_exchange_weak(curr, next, std::memory_order_acq_rel)) && no_next);
/* /*
* if compare_exchange failed & !no_next, * if compare_exchange failed & !no_next,
* means there is another producer thread just update this commit, * means there is another producer thread updated this commit,
* so in this case we could just return * so in this case we could just return
*/ */
if (no_next || (!cas/* && !no_next*/)) return; if (no_next || (!cas/* && !no_next*/)) return;