tdlight-team/tdlight-telegram-bot-api
tdlight-team/tdlight-telegram-bot-api
1
1
Fork 0
mirror of https://github.com/tdlight-team/tdlight-telegram-bot-api.git synced 2025-01-03 16:45:50 +01:00
Code Issues Projects Releases Wiki Activity

Use TQueue::clear.

Browse Source
This commit is contained in:
levlam 2022-11-12 10:44:00 +03:00
parent a9cb897af4
commit 84ceee07bf
1 changed files with 5 additions and 19 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
telegram-bot-api/Client.cpp
View File

@ -5193,15 +5193,7 @@ td::int32 Client::get_file_gc_scheduler_id() {
void Client::clear_tqueue() { void Client::clear_tqueue() {
CHECK(webhook_id_.empty()); CHECK(webhook_id_.empty());
auto &tqueue = parameters_->shared_data_->tqueue_; auto &tqueue = parameters_->shared_data_->tqueue_;
auto size = tqueue->get_size(tqueue_id_); tqueue->clear(tqueue_id_, 0);
if (size > 0) {
LOG(INFO) << "Removing " << size << " tqueue events";
td::MutableSpan<td::TQueue::Event> span;
auto r_size = tqueue->get(tqueue_id_, tqueue->get_tail(tqueue_id_), true, 0, span);
CHECK(r_size.is_ok());
CHECK(r_size.ok() == 0);
CHECK(tqueue->get_size(tqueue_id_) == 0);
}
} }
bool Client::to_bool(td::MutableSlice value) { bool Client::to_bool(td::MutableSlice value) {
@ -9326,17 +9318,11 @@ void Client::do_get_updates(int32 offset, int32 limit, int32 timeout, PromisedQu
LOG(DEBUG) << "Get updates with offset = " << offset << ", limit = " << limit << " and timeout = " << timeout; LOG(DEBUG) << "Get updates with offset = " << offset << ", limit = " << limit << " and timeout = " << timeout;
LOG(DEBUG) << "Queue head = " << tqueue->get_head(tqueue_id_) << ", queue tail = " << tqueue->get_tail(tqueue_id_); LOG(DEBUG) << "Queue head = " << tqueue->get_head(tqueue_id_) << ", queue tail = " << tqueue->get_tail(tqueue_id_);
if (offset < 0) {
tqueue->clear(tqueue_id_, -offset);
}
if (offset <= 0) { if (offset <= 0) {
auto head = tqueue->get_head(tqueue_id_); offset = tqueue->get_head(tqueue_id_).value();
if (!head.empty() && offset < 0) {
// negative offset is counted from the end
auto tail = tqueue->get_tail(tqueue_id_);
CHECK(!tail.empty());
offset += tail.value();
}
if (offset < head.value()) {
offset = head.value();
}
} }
td::MutableSpan<td::TQueue::Event> updates(parameters_->shared_data_->event_buffer_, td::MutableSpan<td::TQueue::Event> updates(parameters_->shared_data_->event_buffer_,