andreacavalli/tdlib-fork
Archived
1
0
Fork 0
Code Pull Requests Releases Activity

Decrease queries delay in MessageDb, DialogDb and SQLite key-value.

Browse Source 
GitOrigin-RevId: 5859c8ed99af5ac20b1485187c35faa85eff4201
This commit is contained in:
levlam 2019-03-31 22:46:32 +03:00
parent 586a812016
commit 470e5cec90
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
td/telegram/DialogDb.cpp
View File

@ -356,7 +356,7 @@ class DialogDbAsync : public DialogDbAsyncInterface {
DialogDbSyncInterface *sync_db_ = nullptr; DialogDbSyncInterface *sync_db_ = nullptr;
static constexpr size_t MAX_PENDING_QUERIES_COUNT{50}; static constexpr size_t MAX_PENDING_QUERIES_COUNT{50};
static constexpr double MAX_PENDING_QUERIES_DELAY{1}; static constexpr double MAX_PENDING_QUERIES_DELAY{0.01};
vector<Promise<>> pending_writes_; vector<Promise<>> pending_writes_;
double wakeup_at_ = 0; double wakeup_at_ = 0;
template <class F> template <class F>

2
td/telegram/MessagesDb.cpp
View File

@ -1027,7 +1027,7 @@ class MessagesDbAsync : public MessagesDbAsyncInterface {
MessagesDbSyncInterface *sync_db_ = nullptr; MessagesDbSyncInterface *sync_db_ = nullptr;
static constexpr size_t MAX_PENDING_QUERIES_COUNT{50}; static constexpr size_t MAX_PENDING_QUERIES_COUNT{50};
static constexpr double MAX_PENDING_QUERIES_DELAY{1}; static constexpr double MAX_PENDING_QUERIES_DELAY{0.01};
std::vector<Promise<>> pending_writes_; std::vector<Promise<>> pending_writes_;
double wakeup_at_ = 0; double wakeup_at_ = 0;
template <class F> template <class F>

2
tddb/td/db/SqliteKeyValueAsync.cpp
View File

@ -87,7 +87,7 @@ class SqliteKeyValueAsync : public SqliteKeyValueAsyncInterface {
std::shared_ptr<SqliteKeyValueSafe> kv_safe_; std::shared_ptr<SqliteKeyValueSafe> kv_safe_;
SqliteKeyValue *kv_ = nullptr; SqliteKeyValue *kv_ = nullptr;
static constexpr double MAX_PENDING_QUERIES_DELAY = 1; static constexpr double MAX_PENDING_QUERIES_DELAY = 0.01;
static constexpr size_t MAX_PENDING_QUERIES_COUNT = 100; static constexpr size_t MAX_PENDING_QUERIES_COUNT = 100;
std::unordered_map<string, optional<string>> buffer_; std::unordered_map<string, optional<string>> buffer_;
std::vector<Promise<>> buffer_promises_; std::vector<Promise<>> buffer_promises_;