diskless message cache #3
@ -279,8 +279,8 @@ class MessagesDbImpl : public MessagesDbSyncInterface {
|
|||||||
|
|
||||||
seqno_++;
|
seqno_++;
|
||||||
|
|
||||||
if (seqno_ % 4096 == 0) {
|
if (seqno_ % 8128 == 0) {
|
||||||
TRY_STATUS(db_memory_.exec("DELETE FROM messages WHERE seqno < " + to_string(seqno_ - 3072)));
|
TRY_STATUS(db_memory_.exec("DELETE FROM messages WHERE seqno < " + to_string(seqno_ - 1024)));
|
||||||
}
|
}
|
||||||
|
|
||||||
add_message_stmt_.bind_int32(12, seqno_).ensure();
|
add_message_stmt_.bind_int32(12, seqno_).ensure();
|
||||||
|
Reference in New Issue
Block a user