2768

pending completion

Build # 2768

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/742b64d6792f141de2fded9752ae0d66b860cd6d">742b64d67<a href="https://github.com/composewell/streamly/commit/742b64d6792f141de2fded9752ae0d66b860cd6d">">Merge </a><a class="double-link" href="https://github.com/composewell/streamly/commit/<a class="double-link" href="https://github.com/composewell/streamly/commit/19c21cc1bb47acbea2b0769d03d9209e612f100a">19c21cc1b</a>">19c21cc1b</a><a href="https://github.com/composewell/streamly/commit/742b64d6792f141de2fded9752ae0d66b860cd6d"> into 70fb99217">70fb99217</a>

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

Run Details

110 of 110 new or added lines in 8 files covered. (100.0%)

3069 of 8206 relevant lines covered (37.4%)

0.37 hits per line

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

0.0

/src/Streamly/Internal/Data/Prim/Pinned/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.Pinned.Array.Types
-- Copyright   : (c) 2019 Composewell Technologies
--
-- License     : BSD3
-- Maintainer  : streamly@composewell.com
-- Stability   : experimental
-- Portability : GHC
--
module Streamly.Internal.Data.Prim.Pinned.Array.Types
    (
      Array (..)
    , unsafeFreeze
    , unsafeThaw
    , defaultChunkSize
    , nil

    -- * Construction
    , spliceTwo

    , fromList
    , fromListN
    , fromStreamDN
    , fromStreamD

    -- * Streams of arrays
    , fromStreamDArraysOf
    , FlattenState (..) -- for inspection testing
    , flattenArrays
    , flattenArraysRev
    , packArraysChunksOf
    , lpackArraysChunksOf
#if !defined(mingw32_HOST_OS)
--    , groupIOVecsOf
#endif
    , splitOn
    , breakOn

    -- * Elimination
    , unsafeIndex
    , byteLength
    , length

    , foldl'
    , foldr
    , foldr'
    , foldlM'
    , splitAt

    , toStreamD
    , toStreamDRev
    , toStreamK
    , toStreamKRev
    , toList
--    , toArrayMinChunk
    , writeN
    , write

    , unlines

    , toPtr
    , memcmp
    , memcpy
    , unsafeInlineIO

    , touchArray
    , withArrayAsPtr
    )
where

import Foreign.C.Types (CSize(..), CInt(..))
import Control.Monad (void)
import GHC.IO (IO(..))

import qualified Streamly.Internal.Data.Prim.Pinned.Mutable.Array.Types as MA

#include "prim-array-types.hs"

-------------------------------------------------------------------------------
-- Utility functions
-------------------------------------------------------------------------------

-- XXX It seems these are not being used anymore, should be removed, or moved
-- to the module where they are being used.

foreign import ccall unsafe "string.h memcpy" c_memcpy
    :: Ptr Word8 -> Ptr Word8 -> CSize -> IO (Ptr Word8)

-- XXX we are converting Int to CSize
memcpy :: Ptr Word8 -> Ptr Word8 -> Int -> IO ()
memcpy dst src len = void (c_memcpy dst src (fromIntegral len))

-- Check if this is safe
foreign import ccall unsafe "string.h memcmp" c_memcmp
    :: Ptr Word8 -> Ptr Word8 -> CSize -> IO CInt

{-# INLINE memcmp #-}
memcmp :: Ptr Word8 -> Ptr Word8 -> Int -> IO Bool
memcmp p1 p2 len = do
    r <- c_memcmp p1 p2 (fromIntegral len)
    return $ r == 0

-------------------------------------------------------------------------------
-- Using as a Pointer
-------------------------------------------------------------------------------

-- Change name later.
{-# INLINE toPtr #-}
toPtr :: Array a -> Ptr a
toPtr (Array arr#) = Ptr (byteArrayContents# arr#)

{-# INLINE touchArray #-}
touchArray :: Array a -> IO ()
touchArray arr = IO $ \s -> case touch# arr s of s1 -> (# s1, () #)

{-# INLINE withArrayAsPtr #-}
withArrayAsPtr :: Array a -> (Ptr a -> IO b) -> IO b
withArrayAsPtr arr f = do
    r <- f (toPtr arr)
    touchArray arr
    return r

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
11	#include "inline.hs"
12
13	-- \|
14	-- Module : Streamly.Internal.Data.Prim.Pinned.Array.Types
15	-- Copyright : (c) 2019 Composewell Technologies
16	--
17	-- License : BSD3
18	-- Maintainer : streamly@composewell.com
19	-- Stability : experimental
20	-- Portability : GHC
21	--
22	module Streamly.Internal.Data.Prim.Pinned.Array.Types
23	(
24	Array (..)
25	, unsafeFreeze
26	, unsafeThaw
27	, defaultChunkSize
28	, nil
29
30	-- * Construction
31	, spliceTwo
32
33	, fromList
34	, fromListN
35	, fromStreamDN
36	, fromStreamD
37
38	-- * Streams of arrays
39	, fromStreamDArraysOf
40	, FlattenState (..) -- for inspection testing
41	, flattenArrays
42	, flattenArraysRev
43	, packArraysChunksOf
44	, lpackArraysChunksOf
45	#if !defined(mingw32_HOST_OS)
46	-- , groupIOVecsOf
47	#endif
48	, splitOn
49	, breakOn
50
51	-- * Elimination
52	, unsafeIndex
53	, byteLength
54	, length
55
56	, foldl'
57	, foldr
58	, foldr'
59	, foldlM'
60	, splitAt
61
62	, toStreamD
63	, toStreamDRev
64	, toStreamK
65	, toStreamKRev
66	, toList
67	-- , toArrayMinChunk
68	, writeN
69	, write
70
71	, unlines
72
73	, toPtr
74	, memcmp
75	, memcpy
76	, unsafeInlineIO
77
78	, touchArray
79	, withArrayAsPtr
80	)
81	where
82
83	import Foreign.C.Types (CSize(..), CInt(..))
84	import Control.Monad (void)
85	import GHC.IO (IO(..))
86
87	import qualified Streamly.Internal.Data.Prim.Pinned.Mutable.Array.Types as MA
88
89	#include "prim-array-types.hs"
90
91	-------------------------------------------------------------------------------
92	-- Utility functions
93	-------------------------------------------------------------------------------
94
95	-- XXX It seems these are not being used anymore, should be removed, or moved
96	-- to the module where they are being used.
97
98	foreign import ccall unsafe "string.h memcpy" c_memcpy
99	:: Ptr Word8 -> Ptr Word8 -> CSize -> IO (Ptr Word8)
100
101	-- XXX we are converting Int to CSize
102	memcpy :: Ptr Word8 -> Ptr Word8 -> Int -> IO ()
103	memcpy dst src len = void (c_memcpy dst src (fromIntegral len))	×
104
105	-- Check if this is safe
106	foreign import ccall unsafe "string.h memcmp" c_memcmp
107	:: Ptr Word8 -> Ptr Word8 -> CSize -> IO CInt
108
109	{-# INLINE memcmp #-}
110	memcmp :: Ptr Word8 -> Ptr Word8 -> Int -> IO Bool
111	memcmp p1 p2 len = do	×
112	r <- c_memcmp p1 p2 (fromIntegral len)	×
113	return $ r == 0	×
114
115	-------------------------------------------------------------------------------
116	-- Using as a Pointer
117	-------------------------------------------------------------------------------
118
119	-- Change name later.
120	{-# INLINE toPtr #-}
121	toPtr :: Array a -> Ptr a
122	toPtr (Array arr#) = Ptr (byteArrayContents# arr#)	×
123
124	{-# INLINE touchArray #-}
125	touchArray :: Array a -> IO ()
126	touchArray arr = IO $ \s -> case touch# arr s of s1 -> (# s1, () #)	×
127
128	{-# INLINE withArrayAsPtr #-}
129	withArrayAsPtr :: Array a -> (Ptr a -> IO b) -> IO b
130	withArrayAsPtr arr f = do	×
131	r <- f (toPtr arr)	×
132	touchArray arr	×
133	return r	×

composewell / streamly / 2768

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