From 7dd1cff6821f70e3b6a499f55eaef42b785284cd Mon Sep 17 00:00:00 2001 From: Jorge Leitao Date: Sun, 25 Jul 2021 11:28:28 +0200 Subject: [PATCH] Removed un-used unsafe. (#225) --- src/array/binary/ffi.rs | 16 +++++----------- src/array/fixed_size_binary/mod.rs | 12 ++++-------- src/array/list/ffi.rs | 12 ++++-------- src/array/primitive/ffi.rs | 12 ++++-------- src/array/utf8/ffi.rs | 16 +++++----------- 5 files changed, 22 insertions(+), 46 deletions(-) diff --git a/src/array/binary/ffi.rs b/src/array/binary/ffi.rs index e93d4f93a41..2771ee9a276 100644 --- a/src/array/binary/ffi.rs +++ b/src/array/binary/ffi.rs @@ -10,17 +10,11 @@ use super::BinaryArray; unsafe impl ToFfi for BinaryArray { fn buffers(&self) -> Vec>> { - unsafe { - vec![ - self.validity.as_ref().map(|x| x.as_ptr()), - Some(std::ptr::NonNull::new_unchecked( - self.offsets.as_ptr() as *mut u8 - )), - Some(std::ptr::NonNull::new_unchecked( - self.values.as_ptr() as *mut u8 - )), - ] - } + vec![ + self.validity.as_ref().map(|x| x.as_ptr()), + std::ptr::NonNull::new(self.offsets.as_ptr() as *mut u8), + std::ptr::NonNull::new(self.values.as_ptr() as *mut u8), + ] } #[inline] diff --git a/src/array/fixed_size_binary/mod.rs b/src/array/fixed_size_binary/mod.rs index 1da1d24d36c..ee4405cfd2f 100644 --- a/src/array/fixed_size_binary/mod.rs +++ b/src/array/fixed_size_binary/mod.rs @@ -133,14 +133,10 @@ impl std::fmt::Display for FixedSizeBinaryArray { unsafe impl ToFfi for FixedSizeBinaryArray { fn buffers(&self) -> Vec>> { - unsafe { - vec![ - self.validity.as_ref().map(|x| x.as_ptr()), - Some(std::ptr::NonNull::new_unchecked( - self.values.as_ptr() as *mut u8 - )), - ] - } + vec![ + self.validity.as_ref().map(|x| x.as_ptr()), + std::ptr::NonNull::new(self.values.as_ptr() as *mut u8), + ] } fn offset(&self) -> usize { diff --git a/src/array/list/ffi.rs b/src/array/list/ffi.rs index ebc256b7d01..cd794ff5cca 100644 --- a/src/array/list/ffi.rs +++ b/src/array/list/ffi.rs @@ -7,14 +7,10 @@ use super::ListArray; unsafe impl ToFfi for ListArray { fn buffers(&self) -> Vec>> { - unsafe { - vec![ - self.validity.as_ref().map(|x| x.as_ptr()), - Some(std::ptr::NonNull::new_unchecked( - self.offsets.as_ptr() as *mut u8 - )), - ] - } + vec![ + self.validity.as_ref().map(|x| x.as_ptr()), + std::ptr::NonNull::new(self.offsets.as_ptr() as *mut u8), + ] } fn offset(&self) -> usize { diff --git a/src/array/primitive/ffi.rs b/src/array/primitive/ffi.rs index 68871899bb2..87980219c0c 100644 --- a/src/array/primitive/ffi.rs +++ b/src/array/primitive/ffi.rs @@ -10,14 +10,10 @@ use super::PrimitiveArray; unsafe impl ToFfi for PrimitiveArray { fn buffers(&self) -> Vec>> { - unsafe { - vec![ - self.validity.as_ref().map(|x| x.as_ptr()), - Some(std::ptr::NonNull::new_unchecked( - self.values.as_ptr() as *mut u8 - )), - ] - } + vec![ + self.validity.as_ref().map(|x| x.as_ptr()), + std::ptr::NonNull::new(self.values.as_ptr() as *mut u8), + ] } #[inline] diff --git a/src/array/utf8/ffi.rs b/src/array/utf8/ffi.rs index dcf3db2d601..adc2a1ea86c 100644 --- a/src/array/utf8/ffi.rs +++ b/src/array/utf8/ffi.rs @@ -8,17 +8,11 @@ use super::Utf8Array; unsafe impl ToFfi for Utf8Array { fn buffers(&self) -> Vec>> { - unsafe { - vec![ - self.validity.as_ref().map(|x| x.as_ptr()), - Some(std::ptr::NonNull::new_unchecked( - self.offsets.as_ptr() as *mut u8 - )), - Some(std::ptr::NonNull::new_unchecked( - self.values.as_ptr() as *mut u8 - )), - ] - } + vec![ + self.validity.as_ref().map(|x| x.as_ptr()), + std::ptr::NonNull::new(self.offsets.as_ptr() as *mut u8), + std::ptr::NonNull::new(self.values.as_ptr() as *mut u8), + ] } fn offset(&self) -> usize {