{-# LANGUAGE TypeOperators, CPP #-} #include "DPH_Header.h" import Data.Array.Parallel.Base import qualified Prelude as P import Prelude ( Eq(..), Num(..), Bool(..), ($), (.) ) #include "DPH_Interface.h" #define ASSERT assert __FILE__ __LINE__ assert :: P.String -> Int -> Bool -> a -> a assert file line False _ = P.error $ file P.++ " (line " P.++ P.show line P.++ "): assertion failure" assert _ _ _ x = x class Elt a instance Elt a => Elt [a] type Array a = [a] data Segd = Segd { segd_lengths :: [Int] , segd_indices :: [Int] , segd_elements :: Int } data Sel2 = Sel2 { sel2_tags :: [Int] , sel2_indices :: [Int] , sel2_elements0 :: Int , sel2_elements1 :: Int } type SelRep2 = () length = P.length empty = [] replicate = P.replicate repeat n _ xs = P.concat (replicate n xs) (!:) = (P.!!) extract xs i n = P.take n (P.drop i xs) drop = P.drop permute = P.error "Not implemented: dph-prim-interface:Data.Array.Parallel.Unlifted.permute" bpermute xs ns = map (xs !:) ns update = P.error "Not implemented: dph-prim-interface:Data.Array.Parallel.Unlifted.update" (+:+) = (P.++) mbpermute = P.error "Not implemented: dph-prim-interface:Data.Array.Parallel.Unlifted.mbpermute" bpermuteDft = P.error "Not implemented: dph-prim-interface:Data.Array.Parallel.Unlifted.bpermuteDft" interleave xs ys = P.concat [[x,y] | (x,y) <- P.zip xs ys] mkSel2 tags idxs n0 n1 _ = Sel2 tags idxs n0 n1 tagsSel2 = sel2_tags indicesSel2 = sel2_indices elementsSel2_0 = sel2_elements0 elementsSel2_1 = sel2_elements1 repSel2 _ = () mkSelRep2 _ = () indicesSelRep2 tags _ = P.zipWith pick tags $ P.init $ P.scanl add (0,0) tags where pick 0 (i,j) = i pick 1 (i,j) = j add (i,j) 0 = (i+1,j) add (i,j) 1 = (i,j+1) elementsSelRep2_0 tags _ = P.length [() | 0 <- tags] elementsSelRep2_1 tags _ = P.length [() | 1 <- tags] pack xs bs = [x | (x,b) <- P.zip xs bs, b] combine [] [] [] = [] combine (True : bs) (x : xs) ys = x : combine bs xs ys combine (False : bs) xs (y : ys) = y : combine bs xs ys combine2 tags _ xs ys = go tags xs ys where go [] [] [] = [] go (0 : bs) (x : xs) ys = x : go bs xs ys go (1 : bs) xs (y : ys) = y : go bs xs ys map = P.map filter = P.filter zip = P.zipWith (:*:) unzip = P.unzip . P.map unpairS fsts = map fstS snds = map sndS zipWith = P.zipWith fold = P.foldr -- or equivalently foldl fold1 = P.foldr1 -- or equivalently foldr1 and = P.and sum = P.sum scan f z = P.init . P.scanl f z indices_s segd = P.concat [[0 .. n-1] | n <- segd_lengths segd] indexed xs = zip [0 .. length xs - 1] xs enumFromTo m n = [m .. n] enumFromThenTo m n s = [m, n..s] enumFromStepLen i k 0 = [] enumFromStepLen i k n = i : enumFromStepLen (i+k) k (n-1) enumFromStepLenEach size starts steps lens = ASSERT (size == sum lens) P.concat $ P.zipWith3 (\x y z -> P.enumFromThenTo x (x+y) (x+y*z)) starts steps lens randoms n = P.take n . System.Random.randoms randomRs n r = P.take n . System.Random.randomRs r nest :: Segd -> [a] -> [[a]] nest (Segd ns is _) xs = go ns xs where go [] [] = [] go (n : ns) xs = let (ys, zs) = P.splitAt n xs in ys : go ns zs replicate_s segd xs = P.concat $ zipWith replicate (lengthsSegd segd) xs replicate_rs n xs = P.concat $ P.map (P.replicate n) xs append_s _ xd xs yd ys = P.concat (P.zipWith (P.++) (nest xd xs) (nest yd ys)) fold_s f z segd xs = P.map (P.foldr f z) (nest segd xs) fold1_s f segd xs = P.map (P.foldr1 f) (nest segd xs) fold_r f z segSize xs = P.error "FIXME GABI PLEASE PLEASE PLEASE" sum_r segSize xs = P.error "FIXME GABI PLEASE PLEASE PLEASE" lengthSegd = length . lengthsSegd lengthsSegd = segd_lengths indicesSegd = segd_indices elementsSegd = segd_elements mkSegd = Segd class Elt a => IOElt a hPut = P.error "Not implemented: dph-prim-interface:Data.Array.Parallel.Unlifted.hPut" hGet = P.error "Not implemented: dph-prim-interface:Data.Array.Parallel.Unlifted.hGet" toList x = x fromList x = x toList_s x = x fromList_s x = x