Rename unsafePinnedCreateUsingPtr to unsafeCreateWithPtr'

Author: adithyaov

core/src/Streamly/Internal/Data/MutArray/Type.hs

@@ -117,7 +117,7 @@ module Streamly.Internal.Data.MutArray.Type
     , fromChunksK
     , fromChunksRealloced -- fromSmallChunks
 
-    , unsafePinnedCreateUsingPtr
+    , unsafeCreateWithPtr'
 
     -- ** Random writes
     , putIndex
@@ -3526,18 +3526,18 @@ unsafeAsPtr arr f =
         (arrContents arr)
         (\ptr -> f (ptr `plusPtr` arrStart arr) (byteLength arr))
 
--- | @unsafePinnedCreateUsingPtr capacity populator@ creates a pinned array of
+-- | @unsafeCreateWithPtr' capacity populator@ creates a pinned array of
 -- @capacity@ bytes and invokes the @populator@ function to populate it.
 -- @populator ptr len@ gets the pointer to the array and MUST return the amount
 -- of the capacity populated in bytes.
 --
 -- /Unsafe/ because the populator is allowed to use the pointer only up to
 -- specified length. In other words, bytes populated MUST be less than or equal
 -- to the total capacity.
-{-# INLINE unsafePinnedCreateUsingPtr #-}
-unsafePinnedCreateUsingPtr
+{-# INLINE unsafeCreateWithPtr' #-}
+unsafeCreateWithPtr'
     :: MonadIO m => Int -> (Ptr Word8 -> IO Int) -> m (MutArray Word8)
-unsafePinnedCreateUsingPtr cap pop = do
+unsafeCreateWithPtr' cap pop = do
     (arr :: MutArray Word8) <- emptyOf' cap
     len <- Unboxed.unsafeAsPtr (arrContents arr) pop
     when (len > cap) (error (errMsg len))
@@ -3548,7 +3548,7 @@ unsafePinnedCreateUsingPtr cap pop = do
     where
 
     errMsg len =
-        "unsafePinnedCreateUsingPtr: length > capacity, "
+        "unsafeCreateWithPtr': length > capacity, "
              ++ "length = " ++ show len ++ ", "
              ++ "capacity = " ++ show cap
 

core/src/Streamly/Internal/FileSystem/Handle.hs

@@ -178,7 +178,7 @@ import qualified Streamly.Internal.Data.StreamK.Type as K (mkStream)
 getChunk :: MonadIO m => Int -> Handle -> m (Array Word8)
 getChunk size h = liftIO $ do
     -- ptr <- mallocPlainForeignPtrAlignedBytes size (alignment (undefined :: Word8))
-    arr <- MArray.unsafePinnedCreateUsingPtr size $ \p -> hGetBufSome h p size
+    arr <- MArray.unsafeCreateWithPtr' size $ \p -> hGetBufSome h p size
     -- XXX shrink only if the diff is significant
     pure $ unsafeFreezeWithShrink arr
 

src/Streamly/Internal/FileSystem/FD.hs

@@ -219,7 +219,7 @@ openFile path mode = Handle . fst <$> FD.openFile path mode True
 readArrayUpto :: Int -> Handle -> IO (Array Word8)
 readArrayUpto size (Handle fd) = do
     arr <-
-        MArray.unsafePinnedCreateUsingPtr size $ \p ->
+        MArray.unsafeCreateWithPtr' size $ \p ->
              -- n <- hGetBufSome h p size
 #if MIN_VERSION_base(4,15,0)
             RawIO.read fd p 0 size

src/Streamly/Internal/Network/Socket.hs

@@ -101,7 +101,7 @@ import qualified Streamly.Internal.Data.Array as A
     ( unsafeFreeze, unsafePinnedAsPtr, chunksOf',
       createOf', unsafeCreateOf, scanCompactMin )
 import qualified Streamly.Internal.Data.MutArray as MArray
-    (unsafePinnedCreateUsingPtr)
+    (unsafeCreateWithPtr')
 import qualified Streamly.Internal.Data.Stream as S (fromStreamK, Stream(..), Step(..))
 import qualified Streamly.Internal.Data.StreamK as K (mkStream)
 
@@ -261,7 +261,7 @@ readArrayUptoWith
     -> h
     -> IO (Array Word8)
 readArrayUptoWith f size h = do
-    arr <- MArray.unsafePinnedCreateUsingPtr size $ \p -> f h p size
+    arr <- MArray.unsafeCreateWithPtr' size $ \p -> f h p size
     -- XXX shrink only if the diff is significant
     -- unsafeFreezeWithShrink
     pure $ A.unsafeFreeze arr