2842

pending completion

Build # 2842

Build Type

Pull #550

travis-ci-com

Committed by

web-flow

Commit Message

<a href="https://github.com/composewell/streamly/commit/<a class=hub.com/composewell/streamly/commit/d434b49e1fc62b41acb5630b775c7f8d1b77c06e">d434b49e1<a href="https://github.com/composewell/streamly/commit/d434b49e1fc62b41acb5630b775c7f8d1b77c06e">">Merge </a><a class="double-link" href="https://github.com/composewell/streamly/commit/<a class="double-link" href="https://github.com/composewell/streamly/commit/a7836c169ce42567462c2b18a9312eb5aadc86e0">a7836c169</a>">a7836c169</a><a href="https://github.com/composewell/streamly/commit/d434b49e1fc62b41acb5630b775c7f8d1b77c06e"> into 09f2fa7cb">09f2fa7cb</a>

Pull Request Pull Request #550: Extend Prim Array to be the default

Run Details

132 of 132 new or added lines in 9 files covered. (100.0%)

3094 of 8606 relevant lines covered (35.95%)

0.36 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

80.0

/src/Streamly/Internal/Data/Prim/Mutable/Array/Types.hs

{-# LANGUAGE CPP                       #-}
{-# LANGUAGE BangPatterns              #-}
{-# LANGUAGE ExistentialQuantification #-}
{-# LANGUAGE MagicHash                 #-}
{-# LANGUAGE RecordWildCards           #-}
{-# LANGUAGE ScopedTypeVariables       #-}
{-# LANGUAGE TypeFamilies              #-}
{-# LANGUAGE UnboxedTuples             #-}
{-# LANGUAGE FlexibleContexts          #-}
#include "inline.hs"

-- |
-- Module      : Streamly.Internal.Data.Prim.Mutable.Array.Types
-- Copyright   : (c) 2019 Composewell Technologies
--
-- License     : BSD3
-- Maintainer  : streamly@composewell.com
-- Stability   : experimental
-- Portability : GHC
--
module Streamly.Internal.Data.Prim.Mutable.Array.Types
    (
      Array (..)

    -- * Construction
    , newArray
    , writeArray

    , spliceTwo
    , unsafeCopy

    , fromListM
    , fromListNM
    , fromStreamDN
    , fromStreamD

    -- * Streams of arrays
    , fromStreamDArraysOf

    , packArraysChunksOf
    , lpackArraysChunksOf

#if !defined(mingw32_HOST_OS)
--    , groupIOVecsOf
#endif

    -- * Elimination
    , unsafeIndexM
    , length
    , byteLength

    , writeN
    , write

    -- * Utilities
    , resizeArray
    , shrinkArray
    )
where

#include "mutable-prim-array-types.hs"

-------------------------------------------------------------------------------
-- Allocation (Unpinned)
-------------------------------------------------------------------------------

-- | Allocate an array that is unpinned and can hold 'count' items.  The memory
-- of the array is uninitialized.
--
-- Note that this is internal routine, the reference to this array cannot be
-- given out until the array has been written to and frozen.
{-# INLINE newArray #-}
newArray ::
       forall m a. (PrimMonad m, Prim a)
    => Int
    -> m (Array (PrimState m) a)
newArray (I# n#) =
    primitive $ \s# ->
        let bytes = n# *# sizeOf# (undefined :: a)
        in case newByteArray# bytes s# of
            (# s1#, arr# #) -> (# s1#, Array arr# #)

-- | Resize (unpinned) mutable byte array to new specified size (in elem
-- count). The returned array is either the original array resized in-place or,
-- if not possible, a newly allocated (unpinned) array (with the original
-- content copied over).
{-# INLINE resizeArray #-}
resizeArray ::
       forall m a. (PrimMonad m, Prim a)
    => Array (PrimState m) a
    -> Int -- ^ new size in elem count
    -> m (Array (PrimState m) a)
resizeArray (Array arr#) (I# n#) =
    primitive $ \s# ->
        let bytes = n# *# sizeOf# (undefined :: a)
        in case resizeMutableByteArray# arr# bytes s# of
            (# s1#, arr1# #) -> (# s1#, Array arr1# #)

1	{-# LANGUAGE CPP #-}
2	{-# LANGUAGE BangPatterns #-}
3	{-# LANGUAGE ExistentialQuantification #-}
4	{-# LANGUAGE MagicHash #-}
5	{-# LANGUAGE RecordWildCards #-}
6	{-# LANGUAGE ScopedTypeVariables #-}
7	{-# LANGUAGE TypeFamilies #-}
8	{-# LANGUAGE UnboxedTuples #-}
9	{-# LANGUAGE FlexibleContexts #-}
10	#include "inline.hs"
11
12	-- \|
13	-- Module : Streamly.Internal.Data.Prim.Mutable.Array.Types
14	-- Copyright : (c) 2019 Composewell Technologies
15	--
16	-- License : BSD3
17	-- Maintainer : streamly@composewell.com
18	-- Stability : experimental
19	-- Portability : GHC
20	--
21	module Streamly.Internal.Data.Prim.Mutable.Array.Types
22	(
23	Array (..)
24
25	-- * Construction
26	, newArray
27	, writeArray
28
29	, spliceTwo
30	, unsafeCopy
31
32	, fromListM
33	, fromListNM
34	, fromStreamDN
35	, fromStreamD
36
37	-- * Streams of arrays
38	, fromStreamDArraysOf
39
40	, packArraysChunksOf
41	, lpackArraysChunksOf
42
43	#if !defined(mingw32_HOST_OS)
44	-- , groupIOVecsOf
45	#endif
46
47	-- * Elimination
48	, unsafeIndexM
49	, length
50	, byteLength
51
52	, writeN
53	, write
54
55	-- * Utilities
56	, resizeArray
57	, shrinkArray
58	)
59	where
60
61	#include "mutable-prim-array-types.hs"
62
63	-------------------------------------------------------------------------------
64	-- Allocation (Unpinned)
65	-------------------------------------------------------------------------------
66
67	-- \| Allocate an array that is unpinned and can hold 'count' items. The memory
68	-- of the array is uninitialized.
69	--
70	-- Note that this is internal routine, the reference to this array cannot be
71	-- given out until the array has been written to and frozen.
72	{-# INLINE newArray #-}
73	newArray ::
74	forall m a. (PrimMonad m, Prim a)
75	=> Int
76	-> m (Array (PrimState m) a)
77	newArray (I# n#) =	1✔
78	primitive $ \s# ->	1✔
79	let bytes = n# *# sizeOf# (undefined :: a)	×
80	in case newByteArray# bytes s# of	1✔
81	(# s1#, arr# #) -> (# s1#, Array arr# #)	1✔
82
83	-- \| Resize (unpinned) mutable byte array to new specified size (in elem
84	-- count). The returned array is either the original array resized in-place or,
85	-- if not possible, a newly allocated (unpinned) array (with the original
86	-- content copied over).
87	{-# INLINE resizeArray #-}
88	resizeArray ::
89	forall m a. (PrimMonad m, Prim a)
90	=> Array (PrimState m) a
91	-> Int -- ^ new size in elem count
92	-> m (Array (PrimState m) a)
93	resizeArray (Array arr#) (I# n#) =	1✔
94	primitive $ \s# ->	1✔
95	let bytes = n# *# sizeOf# (undefined :: a)	×
96	in case resizeMutableByteArray# arr# bytes s# of	1✔
97	(# s1#, arr1# #) -> (# s1#, Array arr1# #)	1✔

composewell / streamly / 2842

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous