tdlight-team/tdlight
tdlight-team/tdlight
1
1
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Unify typedef name.

Browse Source 
GitOrigin-RevId: e554eb8e1c245759ab78ff706f4240548d175206
This commit is contained in:
levlam 2018-07-23 00:08:47 +03:00
parent 7c183449a8
commit 3230dbebc5
1 changed files with 7 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
tdutils/td/utils/MpscPollableQueue.h
View File

@ -20,9 +20,11 @@
namespace td { namespace td {
// interface like in PollableQueue // interface like in PollableQueue
template <class ValueT> template <class T>
class MpscPollableQueue { class MpscPollableQueue {
public: public:
using ValueType = T;
int reader_wait_nonblock() { int reader_wait_nonblock() {
auto ready = reader_vector_.size() - reader_pos_; auto ready = reader_vector_.size() - reader_pos_;
if (ready != 0) { if (ready != 0) {
@ -41,13 +43,13 @@ class MpscPollableQueue {
return narrow_cast<int>(reader_vector_.size()); return narrow_cast<int>(reader_vector_.size());
} }
} }
ValueT reader_get_unsafe() { ValueType reader_get_unsafe() {
return std::move(reader_vector_[reader_pos_++]); return std::move(reader_vector_[reader_pos_++]);
} }
void reader_flush() { void reader_flush() {
//nop //nop
} }
void writer_put(ValueT value) { void writer_put(ValueType value) {
auto guard = lock_.lock(); auto guard = lock_.lock();
writer_vector_.push_back(std::move(value)); writer_vector_.push_back(std::move(value));
if (wait_event_fd_) { if (wait_event_fd_) {
@ -95,8 +97,8 @@ class MpscPollableQueue {
SpinLock lock_; SpinLock lock_;
bool wait_event_fd_{false}; bool wait_event_fd_{false};
EventFd event_fd_; EventFd event_fd_;
std::vector<ValueT> writer_vector_; std::vector<ValueType> writer_vector_;
std::vector<ValueT> reader_vector_; std::vector<ValueType> reader_vector_;
size_t reader_pos_{0}; size_t reader_pos_{0};
}; };