diff options
| author | Determinant <ted.sybil@gmail.com> | 2019-03-26 03:59:47 -0400 |
|---|---|---|
| committer | Determinant <ted.sybil@gmail.com> | 2019-03-26 03:59:47 -0400 |
| commit | ea6ae75fccad52d116559f320d6f0069c1ad552b (patch) | |
| tree | c0e73f74f5a16293cdb4387b7a246ed0b770a6b6 /include/salticidae/buffer.h | |
| parent | 1d89070e5280985ce3212c6ae1f8befb0910e32a (diff) | |
use bounded send_buffer
Diffstat (limited to 'include/salticidae/buffer.h')
| -rw-r--r-- | include/salticidae/buffer.h | 4 |
1 files changed, 3 insertions, 1 deletions
diff --git a/include/salticidae/buffer.h b/include/salticidae/buffer.h index 3f415c9..2324d8b 100644 --- a/include/salticidae/buffer.h +++ b/include/salticidae/buffer.h @@ -131,7 +131,9 @@ struct MPSCWriteBuffer { } void push(bytearray_t &&data) { - buffer.enqueue(buffer_entry_t(std::move(data))); + buffer_entry_t d(std::move(data)); + // TODO: better bounded buffer impl + while (!buffer.try_enqueue(d)) {} } bytearray_t move_pop() { |