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

Client: check if Client::receive is called in a thread safe manner

Browse Source 
GitOrigin-RevId: 6f2af0811b43d3e2d14177963e48dfd99853c6d2
This commit is contained in:
Arseny Smirnov 2018-07-22 23:59:18 +03:00
parent 9b6382d5d0
commit 8bd8f4a136
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
td/telegram/Client.cpp
View File

@ -212,6 +212,11 @@ class Client::Impl final {
}
Response receive(double timeout) {
auto is_locked = receive_lock_.exchange(true);
CHECK(!is_locked);
SCOPE_EXIT {
receive_lock_.exchange(false);
};
if (output_queue_ready_cnt_ == 0) {
output_queue_ready_cnt_ = output_queue_->reader_wait_nonblock();
}
@ -242,6 +247,7 @@ class Client::Impl final {
std::shared_ptr<ConcurrentScheduler> scheduler_;
int output_queue_ready_cnt_{0};
thread scheduler_thread_;
std::atomic<bool> receive_lock_{false};
void init() {
input_queue_ = std::make_shared<InputQueue>();