{-# LANGUAGE BangPatterns #-}
{-# LANGUAGE CPP #-}
{-# LANGUAGE FlexibleContexts #-}
{-# LANGUAGE FlexibleInstances #-}
{-# LANGUAGE MagicHash #-}
{-# LANGUAGE MultiParamTypeClasses #-}
{-# LANGUAGE ScopedTypeVariables #-}
{-# LANGUAGE TypeFamilies #-}
{-# LANGUAGE UndecidableInstances #-}
module Data.Massiv.Array.Manifest.Boxed
( B(..)
, N(..)
, Array(..)
, Uninitialized(..)
, unwrapArray
, evalArray
, unwrapMutableArray
, evalMutableArray
, unwrapNormalFormArray
, evalNormalFormArray
, unwrapNormalFormMutableArray
, evalNormalFormMutableArray
, castArrayToVector
, vectorToArray
, castVectorToArray
, seqArray
, deepseqArray
) where
import Control.DeepSeq (NFData (..), deepseq)
import Control.Exception
import Control.Monad.Primitive
import Control.Monad.ST (runST)
import qualified Data.Foldable as F (Foldable (..))
import Data.Massiv.Array.Delayed.Internal (eq, ord)
import Data.Massiv.Array.Manifest.Internal (M, toManifest)
import Data.Massiv.Array.Manifest.List as L
import Data.Massiv.Array.Mutable
import Data.Massiv.Array.Ops.Fold.Internal
import Data.Massiv.Array.Unsafe (unsafeGenerateArray,
unsafeGenerateArrayP)
import Data.Massiv.Core.Common
import Data.Massiv.Core.List
import qualified Data.Primitive.Array as A
import qualified Data.Vector as VB
import qualified Data.Vector.Mutable as VB
import GHC.Base (build)
import GHC.Exts as GHC (IsList (..))
import GHC.Prim
import GHC.Types
import Prelude hiding (mapM)
#include "massiv.h"
sizeofArray :: A.Array e -> Int
sizeofMutableArray :: A.MutableArray s e -> Int
#if MIN_VERSION_primitive(0,6,2)
sizeofArray = A.sizeofArray
sizeofMutableArray = A.sizeofMutableArray
#else
sizeofArray (A.Array a#) = I# (sizeofArray# a#)
sizeofMutableArray (A.MutableArray ma#) = I# (sizeofMutableArray# ma#)
#endif
data B = B deriving Show
type instance EltRepr B ix = M
data instance Array B ix e = BArray { bComp :: !Comp
, bSize :: !ix
, bData :: {-# UNPACK #-} !(A.Array e)
}
instance (Index ix, NFData e) => NFData (Array B ix e) where
rnf = (`deepseqArray` ())
instance (Index ix, Eq e) => Eq (Array B ix e) where
(==) = eq (==)
{-# INLINE (==) #-}
instance (Index ix, Ord e) => Ord (Array B ix e) where
compare = ord compare
{-# INLINE compare #-}
instance Index ix => Construct B ix e where
getComp = bComp
{-# INLINE getComp #-}
setComp c arr = arr { bComp = c }
{-# INLINE setComp #-}
unsafeMakeArray Seq !sz f = unsafeGenerateArray sz f
unsafeMakeArray (ParOn wIds) !sz f = unsafeGenerateArrayP wIds sz f
{-# INLINE unsafeMakeArray #-}
instance Index ix => Source B ix e where
unsafeLinearIndex (BArray _ _ a) =
INDEX_CHECK("(Source B ix e).unsafeLinearIndex", sizeofArray, A.indexArray) a
{-# INLINE unsafeLinearIndex #-}
instance Index ix => Size B ix e where
size = bSize
{-# INLINE size #-}
unsafeResize !sz !arr = arr { bSize = sz }
{-# INLINE unsafeResize #-}
unsafeExtract !sIx !newSz !arr = unsafeExtract sIx newSz (toManifest arr)
{-# INLINE unsafeExtract #-}
instance ( NFData e
, Index ix
, Index (Lower ix)
, Elt M ix e ~ Array M (Lower ix) e
, Elt B ix e ~ Array M (Lower ix) e
) =>
OuterSlice B ix e where
unsafeOuterSlice arr = unsafeOuterSlice (toManifest arr)
{-# INLINE unsafeOuterSlice #-}
instance ( NFData e
, Index ix
, Index (Lower ix)
, Elt M ix e ~ Array M (Lower ix) e
, Elt B ix e ~ Array M (Lower ix) e
) =>
InnerSlice B ix e where
unsafeInnerSlice arr = unsafeInnerSlice (toManifest arr)
{-# INLINE unsafeInnerSlice #-}
instance Index ix => Manifest B ix e where
unsafeLinearIndexM (BArray _ _ a) =
INDEX_CHECK("(Manifest B ix e).unsafeLinearIndexM", sizeofArray, A.indexArray) a
{-# INLINE unsafeLinearIndexM #-}
instance Index ix => Mutable B ix e where
data MArray s B ix e = MBArray !ix {-# UNPACK #-} !(A.MutableArray s e)
msize (MBArray sz _) = sz
{-# INLINE msize #-}
unsafeThaw (BArray _ sz a) = MBArray sz <$> A.unsafeThawArray a
{-# INLINE unsafeThaw #-}
unsafeFreeze comp (MBArray sz ma) = BArray comp sz <$> A.unsafeFreezeArray ma
{-# INLINE unsafeFreeze #-}
unsafeNew sz = MBArray sz <$> A.newArray (totalElem sz) uninitialized
{-# INLINE unsafeNew #-}
unsafeNewZero = unsafeNew
{-# INLINE unsafeNewZero #-}
unsafeLinearRead (MBArray _ ma) =
INDEX_CHECK("(Mutable B ix e).unsafeLinearRead", sizeofMutableArray, A.readArray) ma
{-# INLINE unsafeLinearRead #-}
unsafeLinearWrite (MBArray _ ma) i e = e `seq`
INDEX_CHECK("(Mutable B ix e).unsafeLinearWrite", sizeofMutableArray, A.writeArray) ma i e
{-# INLINE unsafeLinearWrite #-}
instance Index ix => Foldable (Array B ix) where
foldl = lazyFoldlS
{-# INLINE foldl #-}
foldl' = foldlS
{-# INLINE foldl' #-}
foldr = foldrFB
{-# INLINE foldr #-}
foldr' = foldrS
{-# INLINE foldr' #-}
null (BArray _ sz _) = totalElem sz == 0
{-# INLINE null #-}
sum = F.foldl' (+) 0
{-# INLINE sum #-}
product = F.foldl' (*) 1
{-# INLINE product #-}
length = totalElem . size
{-# INLINE length #-}
toList arr = build (\ c n -> foldrFB c n arr)
{-# INLINE toList #-}
instance ( IsList (Array L ix e)
, Nested LN ix e
, Nested L ix e
, Ragged L ix e
) =>
IsList (Array B ix e) where
type Item (Array B ix e) = Item (Array L ix e)
fromList = L.fromLists' Seq
{-# INLINE fromList #-}
toList = GHC.toList . toListArray
{-# INLINE toList #-}
data N = N deriving Show
type instance EltRepr N ix = M
newtype instance Array N ix e = NArray { bArray :: Array B ix e }
instance (Index ix, NFData e) => NFData (Array N ix e) where
rnf (NArray barr) = barr `deepseqArray` ()
instance (Index ix, NFData e, Eq e) => Eq (Array N ix e) where
(==) = eq (==)
{-# INLINE (==) #-}
instance (Index ix, NFData e, Ord e) => Ord (Array N ix e) where
compare = ord compare
{-# INLINE compare #-}
instance (Index ix, NFData e) => Construct N ix e where
getComp = bComp . bArray
{-# INLINE getComp #-}
setComp c (NArray arr) = NArray (arr { bComp = c })
{-# INLINE setComp #-}
unsafeMakeArray Seq !sz f = NArray $ unsafeGenerateArray sz f
unsafeMakeArray (ParOn wIds) !sz f = NArray $ unsafeGenerateArrayP wIds sz f
{-# INLINE unsafeMakeArray #-}
instance (Index ix, NFData e) => Source N ix e where
unsafeLinearIndex (NArray arr) =
INDEX_CHECK("(Source N ix e).unsafeLinearIndex", totalElem . size, unsafeLinearIndex) arr
{-# INLINE unsafeLinearIndex #-}
instance (Index ix, NFData e) => Size N ix e where
size = bSize . bArray
{-# INLINE size #-}
unsafeResize !sz = NArray . unsafeResize sz . bArray
{-# INLINE unsafeResize #-}
unsafeExtract !sIx !newSz !arr = unsafeExtract sIx newSz (toManifest arr)
{-# INLINE unsafeExtract #-}
instance ( NFData e
, Index ix
, Index (Lower ix)
, Elt M ix e ~ Array M (Lower ix) e
, Elt N ix e ~ Array M (Lower ix) e
) =>
OuterSlice N ix e where
unsafeOuterSlice = unsafeOuterSlice . toManifest
{-# INLINE unsafeOuterSlice #-}
instance ( NFData e
, Index ix
, Index (Lower ix)
, Elt M ix e ~ Array M (Lower ix) e
, Elt N ix e ~ Array M (Lower ix) e
) =>
InnerSlice N ix e where
unsafeInnerSlice = unsafeInnerSlice . toManifest
{-# INLINE unsafeInnerSlice #-}
instance (Index ix, NFData e) => Manifest N ix e where
unsafeLinearIndexM (NArray arr) =
INDEX_CHECK("(Manifest N ix e).unsafeLinearIndexM", totalElem . size, unsafeLinearIndexM) arr
{-# INLINE unsafeLinearIndexM #-}
instance (Index ix, NFData e) => Mutable N ix e where
newtype MArray s N ix e = MNArray { bmArray :: MArray s B ix e }
msize = msize . bmArray
{-# INLINE msize #-}
unsafeThaw (NArray arr) = MNArray <$> unsafeThaw arr
{-# INLINE unsafeThaw #-}
unsafeFreeze comp (MNArray marr) = NArray <$> unsafeFreeze comp marr
{-# INLINE unsafeFreeze #-}
unsafeNew sz = MNArray <$> unsafeNew sz
{-# INLINE unsafeNew #-}
unsafeNewZero = unsafeNew
{-# INLINE unsafeNewZero #-}
unsafeLinearRead (MNArray ma) =
INDEX_CHECK("(Mutable N ix e).unsafeLinearRead", totalElem . msize, unsafeLinearRead) ma
{-# INLINE unsafeLinearRead #-}
unsafeLinearWrite (MNArray ma) i e = e `deepseq`
INDEX_CHECK("(Mutable N ix e).unsafeLinearWrite", totalElem . msize, unsafeLinearWrite) ma i e
{-# INLINE unsafeLinearWrite #-}
instance ( NFData e
, IsList (Array L ix e)
, Nested LN ix e
, Nested L ix e
, Ragged L ix e
) =>
IsList (Array N ix e) where
type Item (Array N ix e) = Item (Array L ix e)
fromList = L.fromLists' Seq
{-# INLINE fromList #-}
toList = GHC.toList . toListArray
{-# INLINE toList #-}
data Uninitialized = Uninitialized
instance Show Uninitialized where
show Uninitialized = "Array element is uninitialized"
instance Exception Uninitialized
uninitialized :: a
uninitialized = throw Uninitialized
unwrapArray :: Array B ix e -> A.Array e
unwrapArray = bData
{-# INLINE unwrapArray #-}
evalArray ::
Comp
-> A.Array e
-> Array B Ix1 e
evalArray = fromArraySeq (\a -> a `seqArray` a)
{-# INLINE evalArray #-}
unwrapMutableArray :: MArray s B ix e -> A.MutableArray s e
unwrapMutableArray (MBArray _ marr) = marr
{-# INLINE unwrapMutableArray #-}
evalMutableArray ::
PrimMonad m
=> A.MutableArray (PrimState m) e
-> m (MArray (PrimState m) B Ix1 e)
evalMutableArray = fromMutableArraySeq seq
{-# INLINE evalMutableArray #-}
unwrapNormalFormArray :: Array N ix e -> A.Array e
unwrapNormalFormArray = bData . bArray
{-# INLINE unwrapNormalFormArray #-}
evalNormalFormArray ::
NFData e
=> Comp
-> A.Array e
-> Array N Ix1 e
evalNormalFormArray = fromArraySeq (\a -> a `deepseqArray` NArray a)
{-# INLINE evalNormalFormArray #-}
unwrapNormalFormMutableArray :: MArray s N ix e -> A.MutableArray s e
unwrapNormalFormMutableArray (MNArray (MBArray _ marr)) = marr
{-# INLINE unwrapNormalFormMutableArray #-}
evalNormalFormMutableArray ::
(PrimMonad m, NFData e)
=> A.MutableArray (PrimState m) e
-> m (MArray (PrimState m) N Ix1 e)
evalNormalFormMutableArray marr = MNArray <$> fromMutableArraySeq deepseq marr
{-# INLINE evalNormalFormMutableArray #-}
fromMutableArraySeq ::
PrimMonad m
=> (e -> m () -> m a)
-> A.MutableArray (PrimState m) e
-> m (MArray (PrimState m) B Ix1 e)
fromMutableArraySeq with mbarr = do
let !sz = sizeofMutableArray mbarr
loopM_ 0 (< sz) (+ 1) $ \i -> A.readArray mbarr i >>= (`with` return ())
return $! MBArray sz mbarr
{-# INLINE fromMutableArraySeq #-}
fromArraySeq ::
(Array B Ix1 e -> a)
-> Comp
-> A.Array e
-> a
fromArraySeq with comp barr = with (BArray comp (sizeofArray barr) barr)
{-# INLINE fromArraySeq #-}
seqArray :: Index ix => Array B ix a -> t -> t
seqArray !arr t = foldlInternal (flip seq) () (flip seq) () arr `seq` t
{-# INLINE seqArray #-}
deepseqArray :: (NFData a, Index ix) => Array B ix a -> t -> t
deepseqArray !arr t = foldlInternal (flip deepseq) () (flip seq) () arr `seq` t
{-# INLINE deepseqArray #-}
castArrayToVector :: A.Array a -> VB.Vector a
castArrayToVector arr = runST $ do
marr <- A.unsafeThawArray arr
VB.unsafeFreeze $ VB.MVector 0 (sizeofArray arr) marr
{-# INLINE castArrayToVector #-}
vectorToArray :: VB.Vector a -> A.Array a
vectorToArray v =
runST $ do
VB.MVector start len marr <- VB.unsafeThaw v
marr' <-
if start == 0
then return marr
else A.cloneMutableArray marr start len
A.unsafeFreezeArray marr'
{-# INLINE vectorToArray #-}
castVectorToArray :: VB.Vector a -> Maybe (A.Array a)
castVectorToArray v =
runST $ do
VB.MVector start end marr <- VB.unsafeThaw v
if start == 0 && end == sizeofMutableArray marr
then Just <$> A.unsafeFreezeArray marr
else return Nothing
{-# INLINE castVectorToArray #-}