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

TQueue: delete on_pop

Browse Source 
GitOrigin-RevId: f412be72f585ba19e9cdfcc2b30151f297beb761
This commit is contained in:
Arseny Smirnov 2019-08-07 18:13:45 +03:00
parent 791d4f3172
commit 62f6318edf
1 changed files with 3 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
tddb/td/db/TQueue.cpp
View File

@ -91,12 +91,6 @@ class TQueueImpl : public TQueue {
q.events.push(std::move(raw_event)); q.events.push(std::move(raw_event));
} }
void on_pop(int64 logevent_id) {
if (callback_) {
callback_->pop(logevent_id);
}
}
EventId push(QueueId queue_id, string data, double expire_at, EventId new_id = EventId()) override { EventId push(QueueId queue_id, string data, double expire_at, EventId new_id = EventId()) override {
auto &q = queues_[queue_id]; auto &q = queues_[queue_id];
EventId event_id; EventId event_id;
@ -192,7 +186,9 @@ class TQueueImpl : public TQueue {
void confirm_read(Queue &q, EventId till_id) { void confirm_read(Queue &q, EventId till_id) {
while (!q.events.empty() && q.events.front().event_id.value() < till_id.value()) { while (!q.events.empty() && q.events.front().event_id.value() < till_id.value()) {
on_pop(q.events.front().logevent_id); if (callback_) {
callback_->pop(q.events.front().logevent_id);
}
q.events.pop(); q.events.pop();
} }
} }