mirror of
https://github.com/aljazceru/turso.git
synced 2026-02-18 22:45:10 +01:00
address suggestions
This commit is contained in:
@@ -1076,7 +1076,7 @@ pub fn read_record_size(payload: &[u8]) -> Result<usize> {
|
||||
offset += bytes_read;
|
||||
record_size += header_size;
|
||||
|
||||
while offset < header_size && offset < payload.len() {
|
||||
while offset < header_size {
|
||||
let (serial_type, bytes_read) = read_varint(&payload[offset..])?;
|
||||
offset += bytes_read;
|
||||
|
||||
|
||||
@@ -357,7 +357,6 @@ impl SortedChunk {
|
||||
|
||||
let drop_fn = Rc::new(|_buffer: BufferData| {});
|
||||
let read_buffer = Buffer::allocate(read_buffer_size, drop_fn);
|
||||
#[allow(clippy::arc_with_non_send_sync)]
|
||||
let read_buffer_ref = Arc::new(RefCell::new(read_buffer));
|
||||
|
||||
let chunk_io_state_copy = self.io_state.clone();
|
||||
@@ -410,7 +409,6 @@ impl SortedChunk {
|
||||
buf_pos += payload.len();
|
||||
}
|
||||
|
||||
#[allow(clippy::arc_with_non_send_sync)]
|
||||
let buffer_ref = Arc::new(RefCell::new(buffer));
|
||||
|
||||
let buffer_ref_copy = buffer_ref.clone();
|
||||
|
||||
Reference in New Issue
Block a user