diff --git a/core/vdbe/sorter.rs b/core/vdbe/sorter.rs index b2b3a8429..21a0f1bea 100644 --- a/core/vdbe/sorter.rs +++ b/core/vdbe/sorter.rs @@ -390,7 +390,7 @@ impl SortedChunk { read_buffer_ref, read_complete, ))); - self.file.pread(self.total_bytes_read.get(), c)?; + self.file.pread(self.total_bytes_read.get(), Arc::new(c))?; Ok(()) } @@ -422,7 +422,7 @@ impl SortedChunk { }); let c = Completion::new(CompletionType::Write(WriteCompletion::new(write_complete))); - self.file.pwrite(0, buffer_ref, c)?; + self.file.pwrite(0, buffer_ref, Arc::new(c))?; Ok(()) } }