mirrors/limbo
1
0
Fork 0
mirror of https://github.com/tursodatabase/limbo.git synced 2025-08-03 17:48:17 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 3

more trace logs

Browse source
This commit is contained in:
Pere Diaz Bou 2024-11-13 11:31:22 +00:00
parent 87957bf4f2
commit cbfb45e55b
2 changed files with 5 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
core/io/linux.rs
View file

@ -81,6 +81,7 @@ impl InnerLinuxIO {
impl WrappedIOUring {
fn submit_entry(&mut self, entry: &io_uring::squeue::Entry, c: Rc<Completion>) {
log::trace!("submit_entry({:?})", entry);
self.pending.insert(entry.get_user_data(), c);
unsafe {
self.ring
@ -100,6 +101,7 @@ impl WrappedIOUring {
// NOTE: This works because CompletionQueue's next function pops the head of the queue. This is not normal behaviour of iterators
let entry = self.ring.completion().next();
if entry.is_some() {
log::trace!("get_completion({:?})", entry);
// consumed an entry from completion queue, update pending_ops
self.pending_ops -= 1;
}

3
core/storage/sqlite3_ondisk.rs
View file

@ -539,6 +539,7 @@ pub fn begin_write_btree_page(
let page_finish = page.clone();
let page_id = page.borrow().id;
log::trace!("begin_write_btree_page(page_id={})", page_id);
let buffer = {
let page = page.borrow();
let contents = page.contents.read().unwrap();
@ -549,6 +550,7 @@ pub fn begin_write_btree_page(
*write_counter.borrow_mut() += 1;
let write_complete = {
let buf_copy = buffer.clone();
log::trace!("finish_write_btree_page");
Box::new(move |bytes_written: i32| {
let buf_copy = buf_copy.clone();
let buf_len = buf_copy.borrow().len();
@ -1054,6 +1056,7 @@ pub fn begin_write_wal_frame(
*write_counter.borrow_mut() += 1;
let write_complete = {
let buf_copy = buffer.clone();
log::info!("finished");
Box::new(move |bytes_written: i32| {
let buf_copy = buf_copy.clone();
let buf_len = buf_copy.borrow().len();