We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent eab95af commit ca0814dCopy full SHA for ca0814d
crates/core/src/db/commit_log.rs
@@ -76,7 +76,6 @@ impl CommitLog {
76
77
const COMMIT_SIZE: usize = 1;
78
79
- let tx = datastore.begin_mut_tx();
80
if unwritten_commit.transactions.len() >= COMMIT_SIZE {
81
{
82
let mut guard = self.odb.lock().unwrap();
@@ -98,8 +97,6 @@ impl CommitLog {
98
97
unwritten_commit.min_tx_offset += unwritten_commit.transactions.len() as u64;
99
unwritten_commit.transactions.clear();
100
101
- datastore.rollback_mut_tx(tx);
102
-
103
Some(bytes)
104
} else {
105
None
0 commit comments