{-# LANGUAGE GeneralizedNewtypeDeriving, TypeFamilies, FlexibleContexts, TupleSections, FlexibleInstances, MultiParamTypeClasses #-}
{-# LANGUAGE ConstraintKinds #-}
{-# LANGUAGE UndecidableInstances #-}
{-# LANGUAGE DefaultSignatures #-}
{-# OPTIONS_GHC -fno-warn-orphans #-}
module Futhark.Pass.ExplicitAllocations
( explicitAllocations
, explicitAllocationsInStms
, simplifiable
, arraySizeInBytesExp
)
where
import Control.Monad.State
import Control.Monad.Writer
import Control.Monad.Reader
import Control.Monad.RWS.Strict
import qualified Data.Map.Strict as M
import qualified Data.Set as S
import qualified Control.Monad.Fail as Fail
import Data.Maybe
import Futhark.Representation.Kernels
import Futhark.Optimise.Simplify.Lore
(mkWiseBody,
mkWiseLetStm,
removeExpWisdom,
removeScopeWisdom)
import Futhark.MonadFreshNames
import Futhark.Representation.ExplicitMemory
import qualified Futhark.Representation.ExplicitMemory.IndexFunction as IxFun
import Futhark.Tools
import qualified Futhark.Analysis.SymbolTable as ST
import Futhark.Optimise.Simplify.Engine (SimpleOps (..))
import qualified Futhark.Optimise.Simplify.Engine as Engine
import Futhark.Pass
import Futhark.Util (splitFromEnd, takeLast)
type InInKernel = Futhark.Representation.Kernels.InKernel
type OutInKernel = Futhark.Representation.ExplicitMemory.InKernel
data AllocStm = SizeComputation VName (PrimExp VName)
| Allocation VName SubExp Space
| ArrayCopy VName VName
deriving (Eq, Ord, Show)
bindAllocStm :: (MonadBinder m, Op (Lore m) ~ MemOp inner) =>
AllocStm -> m ()
bindAllocStm (SizeComputation name pe) =
letBindNames_ [name] =<< toExp (coerceIntPrimExp Int64 pe)
bindAllocStm (Allocation name size space) =
letBindNames_ [name] $ Op $ Alloc size space
bindAllocStm (ArrayCopy name src) =
letBindNames_ [name] $ BasicOp $ Copy src
class (MonadFreshNames m, HasScope lore m, ExplicitMemorish lore) =>
Allocator lore m where
addAllocStm :: AllocStm -> m ()
default addAllocStm :: (Allocable fromlore lore,
Op lore ~ MemOp inner,
m ~ AllocM fromlore lore)
=> AllocStm -> m ()
addAllocStm (SizeComputation name se) =
letBindNames_ [name] =<< toExp (coerceIntPrimExp Int64 se)
addAllocStm (Allocation name size space) =
letBindNames_ [name] $ Op $ Alloc size space
addAllocStm (ArrayCopy name src) =
letBindNames_ [name] $ BasicOp $ Copy src
dimAllocationSize :: SubExp -> m SubExp
default dimAllocationSize :: m ~ AllocM fromlore lore
=> SubExp -> m SubExp
dimAllocationSize (Var v) =
maybe (return $ Var v) dimAllocationSize =<< asks (M.lookup v . chunkMap)
dimAllocationSize size =
return size
expHints :: Exp lore -> m [ExpHint]
expHints e = return $ replicate (expExtTypeSize e) NoHint
allocateMemory :: Allocator lore m =>
String -> SubExp -> Space -> m VName
allocateMemory desc size space = do
v <- newVName desc
addAllocStm $ Allocation v size space
return v
computeSize :: Allocator lore m =>
String -> PrimExp VName -> m SubExp
computeSize desc se = do
v <- newVName desc
addAllocStm $ SizeComputation v se
return $ Var v
type Allocable fromlore tolore =
(ExplicitMemorish tolore,
SameScope fromlore Kernels,
RetType fromlore ~ RetType Kernels,
BranchType fromlore ~ BranchType Kernels,
BodyAttr fromlore ~ (),
BodyAttr tolore ~ (),
ExpAttr tolore ~ (),
SizeSubst (Op tolore),
BinderOps tolore)
type ChunkMap = M.Map VName SubExp
data AllocEnv fromlore tolore =
AllocEnv { chunkMap :: ChunkMap
, aggressiveReuse :: Bool
, allocInOp :: Op fromlore -> AllocM fromlore tolore (Op tolore)
}
boundDims :: ChunkMap -> AllocEnv fromlore tolore
-> AllocEnv fromlore tolore
boundDims m env = env { chunkMap = m <> chunkMap env }
boundDim :: VName -> SubExp -> AllocEnv fromlore tolore
-> AllocEnv fromlore tolore
boundDim name se = boundDims $ M.singleton name se
newtype AllocM fromlore tolore a =
AllocM (BinderT tolore (ReaderT (AllocEnv fromlore tolore) (State VNameSource)) a)
deriving (Applicative, Functor, Monad,
MonadFreshNames,
HasScope tolore,
LocalScope tolore,
MonadReader (AllocEnv fromlore tolore))
instance Fail.MonadFail (AllocM fromlore tolore) where
fail = error . ("AllocM.fail: "++)
instance (Allocable fromlore tolore, Allocator tolore (AllocM fromlore tolore)) =>
MonadBinder (AllocM fromlore tolore) where
type Lore (AllocM fromlore tolore) = tolore
mkExpAttrM _ _ = return ()
mkLetNamesM names e = do
pat <- patternWithAllocations names e
return $ Let pat (defAux ()) e
mkBodyM bnds res = return $ Body () bnds res
addStms binding = AllocM $ addBinderStms binding
collectStms (AllocM m) = AllocM $ collectBinderStms m
certifying cs (AllocM m) = AllocM $ certifyingBinder cs m
instance Allocable fromlore OutInKernel =>
Allocator ExplicitMemory (AllocM fromlore ExplicitMemory) where
expHints = kernelExpHints
instance Allocable fromlore OutInKernel =>
Allocator OutInKernel (AllocM fromlore OutInKernel) where
expHints = inKernelExpHints
runAllocM :: MonadFreshNames m =>
(Op fromlore -> AllocM fromlore tolore (Op tolore))
-> AllocM fromlore tolore a -> m a
runAllocM handleOp (AllocM m) =
fmap fst $ modifyNameSource $ runState $ runReaderT (runBinderT m mempty) env
where env = AllocEnv mempty False handleOp
subAllocM :: (SameScope tolore1 tolore2, ExplicitMemorish tolore2) =>
(Op fromlore1 -> AllocM fromlore1 tolore1 (Op tolore1)) -> Bool
-> AllocM fromlore1 tolore1 a
-> AllocM fromlore2 tolore2 a
subAllocM handleOp b (AllocM m) = do
scope <- castScope <$> askScope
chunks <- asks chunkMap
let env = AllocEnv chunks b handleOp
fmap fst $ modifyNameSource $ runState $ runReaderT (runBinderT m scope) env
newtype PatAllocM lore a = PatAllocM (RWS
(Scope lore)
[AllocStm]
VNameSource
a)
deriving (Applicative, Functor, Monad,
HasScope lore,
MonadWriter [AllocStm],
MonadFreshNames)
instance Allocator ExplicitMemory (PatAllocM ExplicitMemory) where
addAllocStm = tell . pure
dimAllocationSize = return
instance Allocator OutInKernel (PatAllocM OutInKernel) where
addAllocStm = tell . pure
dimAllocationSize = return
runPatAllocM :: MonadFreshNames m =>
PatAllocM lore a -> Scope lore
-> m (a, [AllocStm])
runPatAllocM (PatAllocM m) mems =
modifyNameSource $ frob . runRWS m mems
where frob (a,s,w) = ((a,w),s)
arraySizeInBytesExp :: Type -> PrimExp VName
arraySizeInBytesExp t =
product
[ toInt64 $ product $ map (primExpFromSubExp int32) (arrayDims t)
, ValueExp $ IntValue $ Int64Value $ primByteSize $ elemType t ]
where toInt64 = ConvOpExp $ SExt Int32 Int64
arraySizeInBytesExpM :: Allocator lore m => Type -> m (PrimExp VName)
arraySizeInBytesExpM t = do
dims <- mapM dimAllocationSize (arrayDims t)
let dim_prod_i32 = product $ map (primExpFromSubExp int32) dims
let elm_size_i64 = ValueExp $ IntValue $ Int64Value $ primByteSize $ elemType t
return $ product [ toInt64 dim_prod_i32, elm_size_i64 ]
where toInt64 = ConvOpExp $ SExt Int32 Int64
arraySizeInBytes :: Allocator lore m => Type -> m SubExp
arraySizeInBytes = computeSize "bytes" <=< arraySizeInBytesExpM
allocForArray :: Allocator lore m =>
Type -> Space -> m (SubExp, VName)
allocForArray t space = do
size <- arraySizeInBytes t
m <- allocateMemory "mem" size space
return (size, m)
allocsForStm :: (Allocator lore m, ExpAttr lore ~ ()) =>
[Ident] -> [Ident] -> Exp lore
-> m (Stm lore, [AllocStm])
allocsForStm sizeidents validents e = do
rts <- expReturns e
hints <- expHints e
(ctxElems, valElems, postbnds) <- allocsForPattern sizeidents validents rts hints
return (Let (Pattern ctxElems valElems) (defAux ()) e,
postbnds)
patternWithAllocations :: (Allocator lore m, ExpAttr lore ~ ()) =>
[VName]
-> Exp lore
-> m (Pattern lore)
patternWithAllocations names e = do
(ts',sizes) <- instantiateShapes' =<< expExtType e
let identForBindage name t =
pure $ Ident name t
vals <- sequence [ identForBindage name t | (name, t) <- zip names ts' ]
(Let pat _ _, extrabnds) <- allocsForStm sizes vals e
case extrabnds of
[] -> return pat
_ -> fail $ "Cannot make allocations for pattern of " ++ pretty e
allocsForPattern :: Allocator lore m =>
[Ident] -> [Ident] -> [ExpReturns] -> [ExpHint]
-> m ([PatElem ExplicitMemory],
[PatElem ExplicitMemory],
[AllocStm])
allocsForPattern sizeidents validents rts hints = do
let sizes' = [ PatElem size $ MemPrim int32 | size <- map identName sizeidents ]
(vals,(mems_and_sizes, postbnds)) <-
runWriterT $ forM (zip3 validents rts hints) $ \(ident, rt, hint) -> do
let shape = arrayShape $ identType ident
case rt of
MemPrim _ -> do
summary <- lift $ summaryForBindage (identType ident) hint
return $ PatElem (identName ident) summary
MemMem (Free size) space ->
return $ PatElem (identName ident) $
MemMem size space
MemMem Ext{} space ->
return $ PatElem (identName ident) $
MemMem (intConst Int32 0) space
MemArray bt _ u (Just (ReturnsInBlock mem ixfun)) ->
PatElem (identName ident) . MemArray bt shape u .
ArrayIn mem <$> instantiateIxFun ixfun
MemArray _ extshape _ Nothing
| Just _ <- knownShape extshape -> do
summary <- lift $ summaryForBindage (identType ident) hint
return $ PatElem (identName ident) summary
MemArray bt _ u ret -> do
let space = case ret of
Just (ReturnsNewBlock mem_space _ _ _) -> mem_space
_ -> DefaultSpace
(memsize,mem,(ident',ixfun)) <- lift $ memForBindee ident
tell ([PatElem (identName memsize) $ MemPrim int64,
PatElem (identName mem) $ MemMem (Var $ identName memsize) space],
[])
return $ PatElem (identName ident') $ MemArray bt shape u $
ArrayIn (identName mem) ixfun
return (sizes' <> mems_and_sizes,
vals,
postbnds)
where knownShape = mapM known . shapeDims
known (Free v) = Just v
known Ext{} = Nothing
instantiateIxFun :: Monad m => ExtIxFun -> m IxFun
instantiateIxFun = traverse $ traverse inst
where inst Ext{} = fail "instantiateIxFun: not yet"
inst (Free x) = return x
summaryForBindage :: Allocator lore m =>
Type -> ExpHint
-> m (MemBound NoUniqueness)
summaryForBindage (Prim bt) _ =
return $ MemPrim bt
summaryForBindage (Mem size space) _ =
return $ MemMem size space
summaryForBindage t@(Array bt shape u) NoHint = do
(_, m) <- allocForArray t DefaultSpace
return $ directIndexFunction bt shape u m t
summaryForBindage t (Hint ixfun space) = do
let bt = elemType t
bytes <- computeSize "bytes" $
product [ConvOpExp (SExt Int32 Int64) (product (IxFun.base ixfun)),
fromIntegral (primByteSize (elemType t)::Int64)]
m <- allocateMemory "mem" bytes space
return $ MemArray bt (arrayShape t) NoUniqueness $ ArrayIn m ixfun
memForBindee :: (MonadFreshNames m) =>
Ident
-> m (Ident,
Ident,
(Ident, IxFun))
memForBindee ident = do
size <- newIdent (memname <> "_size") (Prim int64)
mem <- newIdent memname $ Mem (Var $ identName size) DefaultSpace
return (size,
mem,
(ident, IxFun.iota $ map (primExpFromSubExp int32) $ arrayDims t))
where memname = baseString (identName ident) <> "_mem"
t = identType ident
directIndexFunction :: PrimType -> Shape -> u -> VName -> Type -> MemBound u
directIndexFunction bt shape u mem t =
MemArray bt shape u $ ArrayIn mem $
IxFun.iota $ map (primExpFromSubExp int32) $ arrayDims t
allocInFParams :: (Allocable fromlore tolore) =>
[(FParam fromlore, Space)] ->
([FParam tolore] -> AllocM fromlore tolore a)
-> AllocM fromlore tolore a
allocInFParams params m = do
(valparams, memparams) <-
runWriterT $ mapM (uncurry allocInFParam) params
let params' = memparams <> valparams
summary = scopeOfFParams params'
localScope summary $ m params'
allocInFParam :: (Allocable fromlore tolore) =>
FParam fromlore
-> Space
-> WriterT [FParam tolore]
(AllocM fromlore tolore) (FParam tolore)
allocInFParam param pspace =
case paramDeclType param of
Array bt shape u -> do
let memname = baseString (paramName param) <> "_mem"
ixfun = IxFun.iota $ map (primExpFromSubExp int32) $ shapeDims shape
memsize <- lift $ newVName (memname <> "_size")
mem <- lift $ newVName memname
tell [ Param memsize $ MemPrim int64
, Param mem $ MemMem (Var memsize) pspace]
return param { paramAttr = MemArray bt shape u $ ArrayIn mem ixfun }
Prim bt ->
return param { paramAttr = MemPrim bt }
Mem size space ->
return param { paramAttr = MemMem size space }
allocInMergeParams :: (Allocable fromlore tolore,
Allocator tolore (AllocM fromlore tolore)) =>
[VName]
-> [(FParam fromlore,SubExp)]
-> ([FParam tolore]
-> [FParam tolore]
-> ([SubExp] -> AllocM fromlore tolore ([SubExp], [SubExp]))
-> AllocM fromlore tolore a)
-> AllocM fromlore tolore a
allocInMergeParams variant merge m = do
((valparams, handle_loop_subexps), mem_and_size_params) <-
runWriterT $ unzip <$> mapM allocInMergeParam merge
let mergeparams' = mem_and_size_params <> valparams
summary = scopeOfFParams mergeparams'
mk_loop_res ses = do
(valargs, memargs) <-
runWriterT $ zipWithM ($) handle_loop_subexps ses
return (memargs, valargs)
localScope summary $ m mem_and_size_params valparams mk_loop_res
where allocInMergeParam (mergeparam, Var v)
| Array bt shape u <- paramDeclType mergeparam = do
(mem, ixfun) <- lift $ lookupArraySummary v
Mem _ space <- lift $ lookupType mem
reuse <- asks aggressiveReuse
if space /= Space "local" &&
reuse &&
u == Unique &&
loopInvariantShape mergeparam &&
IxFun.isLinear ixfun
then return (mergeparam { paramAttr = MemArray bt shape Unique $ ArrayIn mem ixfun },
lift . ensureArrayIn (paramType mergeparam) mem ixfun)
else doDefault mergeparam space
allocInMergeParam (mergeparam, _) = doDefault mergeparam DefaultSpace
doDefault mergeparam space = do
mergeparam' <- allocInFParam mergeparam space
return (mergeparam', linearFuncallArg (paramType mergeparam) space)
variant_names = variant ++ map (paramName . fst) merge
loopInvariantShape =
not . any (`elem` variant_names) . subExpVars . arrayDims . paramType
ensureArrayIn :: (Allocable fromlore tolore,
Allocator tolore (AllocM fromlore tolore)) =>
Type -> VName -> IxFun -> SubExp
-> AllocM fromlore tolore SubExp
ensureArrayIn _ _ _ (Constant v) =
fail $ "ensureArrayIn: " ++ pretty v ++ " cannot be an array."
ensureArrayIn t mem ixfun (Var v) = do
(src_mem, src_ixfun) <- lookupArraySummary v
if src_mem == mem && src_ixfun == ixfun
then return $ Var v
else do copy <- newIdent (baseString v ++ "_ensure_copy") t
let summary = MemArray (elemType t) (arrayShape t) NoUniqueness $
ArrayIn mem ixfun
pat = Pattern [] [PatElem (identName copy) summary]
letBind_ pat $ BasicOp $ Copy v
return $ Var $ identName copy
ensureDirectArray :: (Allocable fromlore tolore,
Allocator tolore (AllocM fromlore tolore)) =>
Maybe Space -> VName -> AllocM fromlore tolore (SubExp, VName, SubExp)
ensureDirectArray space_ok v = do
(mem, ixfun) <- lookupArraySummary v
Mem size mem_space <- lookupType mem
if IxFun.isDirect ixfun && maybe True (==mem_space) space_ok
then return (size, mem, Var v)
else needCopy (fromMaybe DefaultSpace space_ok)
where needCopy space =
allocLinearArray space (baseString v) v
allocLinearArray :: (Allocable fromlore tolore, Allocator tolore (AllocM fromlore tolore)) =>
Space -> String -> VName
-> AllocM fromlore tolore (SubExp, VName, SubExp)
allocLinearArray space s v = do
t <- lookupType v
(size, mem) <- allocForArray t space
v' <- newIdent (s ++ "_linear") t
let pat = Pattern [] [PatElem (identName v') $
directIndexFunction (elemType t) (arrayShape t)
NoUniqueness mem t]
addStm $ Let pat (defAux ()) $ BasicOp $ Copy v
return (size, mem, Var $ identName v')
funcallArgs :: (Allocable fromlore tolore,
Allocator tolore (AllocM fromlore tolore)) =>
[(SubExp,Diet)] -> AllocM fromlore tolore [(SubExp,Diet)]
funcallArgs args = do
(valargs, mem_and_size_args) <- runWriterT $ forM args $ \(arg,d) -> do
t <- lift $ subExpType arg
arg' <- linearFuncallArg t DefaultSpace arg
return (arg', d)
return $ map (,Observe) mem_and_size_args <> valargs
linearFuncallArg :: (Allocable fromlore tolore,
Allocator tolore (AllocM fromlore tolore)) =>
Type -> Space -> SubExp
-> WriterT [SubExp] (AllocM fromlore tolore) SubExp
linearFuncallArg Array{} space (Var v) = do
(size, mem, arg') <- lift $ ensureDirectArray (Just space) v
tell [size, Var mem]
return arg'
linearFuncallArg _ _ arg =
return arg
explicitAllocations :: Pass Kernels ExplicitMemory
explicitAllocations =
Pass "explicit allocations" "Transform program to explicit memory representation" $
intraproceduralTransformation allocInFun
explicitAllocationsInStms :: (MonadFreshNames m, HasScope ExplicitMemory m) =>
Stms Kernels -> m (Stms ExplicitMemory)
explicitAllocationsInStms stms = do
scope <- askScope
runAllocM handleKernel $ localScope scope $ allocInStms stms return
memoryInRetType :: [RetType Kernels] -> [RetType ExplicitMemory]
memoryInRetType ts = evalState (mapM addAttr ts) $ startOfFreeIDRange ts
where addAttr (Prim t) = return $ MemPrim t
addAttr Mem{} = fail "memoryInRetType: too much memory"
addAttr (Array bt shape u) = do
i <- get <* modify (+2)
return $ MemArray bt shape u $ ReturnsNewBlock DefaultSpace (i+1) (Ext i) $
IxFun.iota $ map convert $ shapeDims shape
convert (Ext i) = LeafExp (Ext i) int32
convert (Free v) = Free <$> primExpFromSubExp int32 v
startOfFreeIDRange :: [TypeBase ExtShape u] -> Int
startOfFreeIDRange = S.size . shapeContext
allocInFun :: MonadFreshNames m => FunDef Kernels -> m (FunDef ExplicitMemory)
allocInFun (FunDef entry fname rettype params fbody) =
runAllocM handleKernel $
allocInFParams (zip params $ repeat DefaultSpace) $ \params' -> do
fbody' <- insertStmsM $ allocInFunBody
(map (const $ Just DefaultSpace) rettype) fbody
return $ FunDef entry fname (memoryInRetType rettype) params' fbody'
handleKernel :: Kernel InInKernel
-> AllocM Kernels ExplicitMemory (MemOp (Kernel OutInKernel))
handleKernel (GetSize key size_class) =
return $ Inner $ GetSize key size_class
handleKernel (GetSizeMax size_class) =
return $ Inner $ GetSizeMax size_class
handleKernel (CmpSizeLe key size_class x) =
return $ Inner $ CmpSizeLe key size_class x
handleKernel (Kernel desc space kernel_ts kbody) = subInKernel $
Inner . Kernel desc space kernel_ts <$>
localScope (scopeOfKernelSpace space) (allocInKernelBody kbody)
handleKernel (SegRed space comm red_op nes ts body) = do
body' <- subInKernel $ localScope (scopeOfKernelSpace space) $ allocInBodyNoDirect body
red_op' <- allocInSegRedLambda (spaceGlobalId space) (spaceNumThreads space) red_op
return $ Inner $ SegRed space comm red_op' nes ts body'
subInKernel :: AllocM InInKernel OutInKernel a
-> AllocM fromlore2 ExplicitMemory a
subInKernel = subAllocM handleKernelExp True
where handleKernelExp (Barrier se) =
return $ Inner $ Barrier se
handleKernelExp (SplitSpace o w i elems_per_thread) =
return $ Inner $ SplitSpace o w i elems_per_thread
handleKernelExp (Combine cspace ts active body) =
Inner . Combine cspace ts active <$> allocInBodyNoDirect body
handleKernelExp (GroupReduce w lam input) = do
summaries <- mapM lookupArraySummary arrs
lam' <- allocInReduceLambda lam summaries
return $ Inner $ GroupReduce w lam' input
where arrs = map snd input
handleKernelExp (GroupScan w lam input) = do
summaries <- mapM lookupArraySummary arrs
lam' <- allocInReduceLambda lam summaries
return $ Inner $ GroupScan w lam' input
where arrs = map snd input
handleKernelExp (GroupGenReduce w dests op bucket vs locks) = do
let (x_params, y_params) = splitAt (length vs) $ lambdaParams op
sliceDest dest = do
dest_t <- lookupType dest
sliceInfo dest $ fullSlice dest_t $ map DimFix bucket
x_params' <- zipWith Param (map paramName x_params) <$>
mapM sliceDest dests
y_params' <- zipWith Param (map paramName y_params) <$>
mapM subExpMemInfo vs
op' <- allocInLambda (x_params'<>y_params') (lambdaBody op) (lambdaReturnType op)
return $ Inner $ GroupGenReduce w dests op' bucket vs locks
handleKernelExp (GroupStream w maxchunk lam accs arrs) = do
acc_summaries <- mapM accSummary accs
arr_summaries <- mapM lookupArraySummary arrs
lam' <- allocInGroupStreamLambda maxchunk lam acc_summaries arr_summaries
return $ Inner $ GroupStream w maxchunk lam' accs arrs
where accSummary (Constant v) = return $ MemPrim $ primValueType v
accSummary (Var v) = lookupMemInfo v
allocInBodyNoDirect :: (Allocable fromlore tolore, Allocator tolore (AllocM fromlore tolore)) =>
Body fromlore -> AllocM fromlore tolore (Body tolore)
allocInBodyNoDirect (Body _ bnds res) =
allocInStms bnds $ \bnds' ->
return $ Body () bnds' res
bodyReturnMemCtx :: (Allocable fromlore tolore, Allocator tolore (AllocM fromlore tolore)) =>
SubExp -> AllocM fromlore tolore [SubExp]
bodyReturnMemCtx Constant{} =
return []
bodyReturnMemCtx (Var v) = do
info <- lookupMemInfo v
case info of
MemPrim{} -> return []
MemMem{} -> return []
MemArray _ _ _ (ArrayIn mem _) -> do
size <- lookupMemSize mem
return [size, Var mem]
allocInFunBody :: (Allocable fromlore tolore, Allocator tolore (AllocM fromlore tolore)) =>
[Maybe Space] -> Body fromlore -> AllocM fromlore tolore (Body tolore)
allocInFunBody space_oks (Body _ bnds res) =
allocInStms bnds $ \bnds' -> do
(res'', allocs) <- collectStms $ do
res' <- zipWithM ensureDirect space_oks' res
let (ctx_res, val_res) = splitFromEnd num_vals res'
mem_ctx_res <- concat <$> mapM bodyReturnMemCtx val_res
return $ ctx_res <> mem_ctx_res <> val_res
return $ Body () (bnds'<>allocs) res''
where num_vals = length space_oks
space_oks' = replicate (length res - num_vals) Nothing ++ space_oks
ensureDirect _ se@Constant{} = return se
ensureDirect space_ok (Var v) = do
bt <- primType <$> lookupType v
if bt
then return $ Var v
else do (_, _, v') <- ensureDirectArray space_ok v
return v'
allocInStms :: (Allocable fromlore tolore, Allocator tolore (AllocM fromlore tolore)) =>
Stms fromlore -> (Stms tolore -> AllocM fromlore tolore a)
-> AllocM fromlore tolore a
allocInStms origbnds m = allocInStms' (stmsToList origbnds) mempty
where allocInStms' [] bnds' =
m bnds'
allocInStms' (x:xs) bnds' = do
allocbnds <- allocInStm' x
let summaries = scopeOf allocbnds
localScope summaries $
local (boundDims $ mconcat $ map sizeSubst $ stmsToList allocbnds) $
allocInStms' xs (bnds'<>allocbnds)
allocInStm' bnd = do
((),bnds') <- collectStms $ certifying (stmCerts bnd) $ allocInStm bnd
return bnds'
allocInStm :: (Allocable fromlore tolore, Allocator tolore (AllocM fromlore tolore)) =>
Stm fromlore -> AllocM fromlore tolore ()
allocInStm (Let (Pattern sizeElems valElems) _ e) = do
e' <- allocInExp e
let sizeidents = map patElemIdent sizeElems
validents = map patElemIdent valElems
(bnd, bnds) <- allocsForStm sizeidents validents e'
addStm bnd
mapM_ addAllocStm bnds
allocInExp :: (Allocable fromlore tolore, Allocator tolore (AllocM fromlore tolore)) =>
Exp fromlore -> AllocM fromlore tolore (Exp tolore)
allocInExp (DoLoop ctx val form (Body () bodybnds bodyres)) =
allocInMergeParams mempty ctx $ \_ ctxparams' _ ->
allocInMergeParams (map paramName ctxparams') val $
\new_ctx_params valparams' mk_loop_val -> do
form' <- allocInLoopForm form
localScope (scopeOf form') $ do
(valinit_ctx, valinit') <- mk_loop_val valinit
body' <- insertStmsM $ allocInStms bodybnds $ \bodybnds' -> do
((val_ses,valres'),val_retbnds) <- collectStms $ mk_loop_val valres
return $ Body () (bodybnds'<>val_retbnds) (ctxres++val_ses++valres')
return $
DoLoop
(zip (ctxparams'++new_ctx_params) (ctxinit++valinit_ctx))
(zip valparams' valinit')
form' body'
where (_ctxparams, ctxinit) = unzip ctx
(_valparams, valinit) = unzip val
(ctxres, valres) = splitAt (length ctx) bodyres
allocInExp (Apply fname args rettype loc) = do
args' <- funcallArgs args
return $ Apply fname args' (memoryInRetType rettype) loc
allocInExp (If cond tbranch fbranch (IfAttr rets ifsort)) = do
tbranch' <- allocInFunBody (map (const Nothing) rets) tbranch
space_oks <- mkSpaceOks (length rets) tbranch'
fbranch' <- allocInFunBody space_oks fbranch
let rets' = createBodyReturns rets space_oks
res_then = bodyResult tbranch'
res_else = bodyResult fbranch'
size_ext = length res_then - length rets'
(ind_ses0, r_then_else) =
foldl (\(acc_ise,acc_ext) (r_then, r_else, i) ->
if r_then == r_else then ((i,r_then):acc_ise, acc_ext)
else (acc_ise, (r_then, r_else):acc_ext)
) ([],[]) $ reverse $ zip3 res_then res_else [0..size_ext-1]
(r_then_ext, r_else_ext) = unzip r_then_else
ind_ses = zipWith (\(i,se) k -> (i-k,se)) ind_ses0 [0..length ind_ses0 - 1]
rets'' = foldl (\acc (i,se) -> fixExt i se acc) rets' ind_ses
tbranch'' = tbranch' { bodyResult = r_then_ext ++ drop size_ext res_then }
fbranch'' = fbranch' { bodyResult = r_else_ext ++ drop size_ext res_else }
return $ If cond tbranch'' fbranch'' $ IfAttr rets'' ifsort
allocInExp e = mapExpM alloc e
where alloc =
identityMapper { mapOnBody = fail "Unhandled Body in ExplicitAllocations"
, mapOnRetType = fail "Unhandled RetType in ExplicitAllocations"
, mapOnBranchType = fail "Unhandled BranchType in ExplicitAllocations"
, mapOnFParam = fail "Unhandled FParam in ExplicitAllocations"
, mapOnLParam = fail "Unhandled LParam in ExplicitAllocations"
, mapOnOp = \op -> do handle <- asks allocInOp
handle op
}
mkSpaceOks :: (ExplicitMemorish tolore, LocalScope tolore m) =>
Int -> Body tolore -> m [Maybe Space]
mkSpaceOks num_vals (Body _ stms res) =
inScopeOf stms $
mapM mkSpaceOK $ takeLast num_vals res
where mkSpaceOK (Var v) = do
v_info <- lookupMemInfo v
case v_info of MemArray _ _ _ (ArrayIn mem _) -> do
mem_info <- lookupMemInfo mem
case mem_info of MemMem _ space -> return $ Just space
_ -> return Nothing
_ -> return Nothing
mkSpaceOK _ = return Nothing
createBodyReturns :: [ExtType] -> [Maybe Space] -> [BodyReturns]
createBodyReturns ts spaces =
evalState (zipWithM inspect ts spaces) $ S.size $ shapeContext ts
where inspect (Array pt shape u) space = do
i <- get <* modify (+2)
let space' = fromMaybe DefaultSpace space
return $ MemArray pt shape u $ ReturnsNewBlock space' (i+1) (Ext i) $
IxFun.iota $ map convert $ shapeDims shape
inspect (Prim pt) _ =
return $ MemPrim pt
inspect (Mem size space) _ =
return $ MemMem (Free size) space
convert (Ext i) = LeafExp (Ext i) int32
convert (Free v) = Free <$> primExpFromSubExp int32 v
allocInLoopForm :: (Allocable fromlore tolore,
Allocator tolore (AllocM fromlore tolore)) =>
LoopForm fromlore -> AllocM fromlore tolore (LoopForm tolore)
allocInLoopForm (WhileLoop v) = return $ WhileLoop v
allocInLoopForm (ForLoop i it n loopvars) =
ForLoop i it n <$> mapM allocInLoopVar loopvars
where allocInLoopVar (p,a) = do
(mem, ixfun) <- lookupArraySummary a
case paramType p of
Array bt shape u ->
let ixfun' = IxFun.slice ixfun $
fullSliceNum (IxFun.shape ixfun) [DimFix $ LeafExp i int32]
in return (p { paramAttr = MemArray bt shape u $ ArrayIn mem ixfun' }, a)
Prim bt ->
return (p { paramAttr = MemPrim bt }, a)
Mem size space ->
return (p { paramAttr = MemMem size space }, a)
allocInReduceLambda :: Lambda InInKernel
-> [(VName, IxFun)]
-> AllocM InInKernel OutInKernel (Lambda OutInKernel)
allocInReduceLambda lam input_summaries = do
let (i, j_param, actual_params) =
partitionChunkedKernelLambdaParameters $ lambdaParams lam
(acc_params, arr_params) =
splitAt (length input_summaries) actual_params
this_index = LeafExp i int32
other_index = this_index + LeafExp (paramName j_param) int32
acc_params' <-
allocInReduceParameters this_index $
zip acc_params input_summaries
arr_params' <-
allocInReduceParameters other_index $
zip arr_params input_summaries
allocInLambda (Param i (MemPrim int32) :
j_param { paramAttr = MemPrim int32 } :
acc_params' ++ arr_params')
(lambdaBody lam) (lambdaReturnType lam)
allocInReduceParameters :: PrimExp VName
-> [(LParam InInKernel, (VName, IxFun))]
-> AllocM InInKernel OutInKernel [LParam ExplicitMemory]
allocInReduceParameters my_id = mapM allocInReduceParameter
where allocInReduceParameter (p, (mem, ixfun)) =
case paramType p of
(Array bt shape u) ->
let ixfun' = IxFun.slice ixfun $
fullSliceNum (IxFun.shape ixfun) [DimFix my_id]
in return p { paramAttr = MemArray bt shape u $ ArrayIn mem ixfun' }
Prim bt ->
return p { paramAttr = MemPrim bt }
Mem size space ->
return p { paramAttr = MemMem size space }
allocInSegRedLambda :: VName -> SubExp -> Lambda InInKernel
-> AllocM Kernels ExplicitMemory (Lambda OutInKernel)
allocInSegRedLambda gtid num_threads lam = do
let (acc_params, arr_params) =
splitAt (length (lambdaParams lam) `div` 2) $ lambdaParams lam
this_index = LeafExp gtid int32
other_index = this_index + primExpFromSubExp int32 num_threads
(acc_params', arr_params') <-
allocInSegRedParameters num_threads this_index other_index acc_params arr_params
subInKernel $ allocInLambda (acc_params' ++ arr_params')
(lambdaBody lam) (lambdaReturnType lam)
allocInSegRedParameters :: SubExp
-> PrimExp VName -> PrimExp VName
-> [LParam InInKernel]
-> [LParam InInKernel]
-> AllocM Kernels ExplicitMemory ([LParam ExplicitMemory], [LParam ExplicitMemory])
allocInSegRedParameters num_threads my_id other_id xs ys = unzip <$> zipWithM alloc xs ys
where alloc x y =
case paramType x of
Array bt shape u -> do
twice_num_threads <- letSubExp "twice_num_threads" $
BasicOp $ BinOp (Mul Int32) num_threads $ intConst Int32 2
let t = paramType x `arrayOfRow` twice_num_threads
(_, mem) <- allocForArray t DefaultSpace
let ixfun_base = IxFun.iota $
map (primExpFromSubExp int32) (arrayDims t)
ixfun_x = IxFun.slice ixfun_base $
fullSliceNum (IxFun.shape ixfun_base) [DimFix my_id]
ixfun_y = IxFun.slice ixfun_base $
fullSliceNum (IxFun.shape ixfun_base) [DimFix other_id]
return (x { paramAttr = MemArray bt shape u $ ArrayIn mem ixfun_x },
y { paramAttr = MemArray bt shape u $ ArrayIn mem ixfun_y })
Prim bt ->
return (x { paramAttr = MemPrim bt },
y { paramAttr = MemPrim bt })
Mem size space ->
return (x { paramAttr = MemMem size space },
y { paramAttr = MemMem size space })
allocInChunkedParameters :: PrimExp VName
-> [(LParam InInKernel, (VName, IxFun))]
-> AllocM InInKernel OutInKernel [LParam OutInKernel]
allocInChunkedParameters offset = mapM allocInChunkedParameter
where allocInChunkedParameter (p, (mem, ixfun)) =
case paramType p of
Array bt shape u ->
let ixfun' = IxFun.offsetIndex ixfun offset
in return p { paramAttr = MemArray bt shape u $ ArrayIn mem ixfun' }
Prim bt ->
return p { paramAttr = MemPrim bt }
Mem size space ->
return p { paramAttr = MemMem size space }
allocInLambda :: [LParam OutInKernel] -> Body InInKernel -> [Type]
-> AllocM InInKernel OutInKernel (Lambda OutInKernel)
allocInLambda params body rettype = do
body' <- localScope (scopeOfLParams params) $
allocInStms (bodyStms body) $ \bnds' ->
return $ Body () bnds' $ bodyResult body
return $ Lambda params body' rettype
allocInKernelBody :: KernelBody InInKernel
-> AllocM InInKernel OutInKernel (KernelBody OutInKernel)
allocInKernelBody (KernelBody () stms res) =
allocInStms stms $ \stms' ->
return $ KernelBody () stms' res
class SizeSubst op where
opSizeSubst :: PatternT attr -> op -> ChunkMap
instance SizeSubst (Kernel lore) where
opSizeSubst _ _ = mempty
instance SizeSubst op => SizeSubst (MemOp op) where
opSizeSubst pat (Inner op) = opSizeSubst pat op
opSizeSubst _ _ = mempty
instance SizeSubst (KernelExp lore) where
opSizeSubst (Pattern _ [size]) (SplitSpace _ _ _ elems_per_thread) =
M.singleton (patElemName size) elems_per_thread
opSizeSubst _ _ = mempty
sizeSubst :: SizeSubst (Op lore) => Stm lore -> ChunkMap
sizeSubst (Let pat _ (Op op)) = opSizeSubst pat op
sizeSubst _ = mempty
allocInGroupStreamLambda :: SubExp
-> GroupStreamLambda InInKernel
-> [MemBound NoUniqueness]
-> [(VName, IxFun)]
-> AllocM InInKernel OutInKernel (GroupStreamLambda OutInKernel)
allocInGroupStreamLambda maxchunk lam acc_summaries arr_summaries = do
let GroupStreamLambda block_size block_offset acc_params arr_params body = lam
acc_params' <-
allocInAccParameters acc_params acc_summaries
arr_params' <-
allocInChunkedParameters (LeafExp block_offset int32) $
zip arr_params arr_summaries
body' <- localScope (M.insert block_size (IndexInfo Int32) $
M.insert block_offset (IndexInfo Int32) $
scopeOfLParams $ acc_params' ++ arr_params') $
local (boundDim block_size maxchunk) $ do
body' <- allocInBodyNoDirect body
insertStmsM $ do
addStms (bodyStms body')
let maybeCopyResult r p =
case paramAttr p of
MemArray _ _ _ (ArrayIn mem ixfun) ->
ensureArrayIn (paramType p) mem ixfun r
_ ->
return r
resultBodyM =<<
zipWithM maybeCopyResult (bodyResult body') acc_params'
return $
GroupStreamLambda block_size block_offset acc_params' arr_params' body'
allocInAccParameters :: [LParam InInKernel]
-> [MemBound NoUniqueness]
-> AllocM InInKernel OutInKernel [LParam OutInKernel]
allocInAccParameters = zipWithM allocInAccParameter
where allocInAccParameter p attr = return p { paramAttr = attr }
mkLetNamesB' :: (Op (Lore m) ~ MemOp inner,
MonadBinder m, ExpAttr (Lore m) ~ (),
Allocator (Lore m) (PatAllocM (Lore m))) =>
ExpAttr (Lore m) -> [VName] -> Exp (Lore m) -> m (Stm (Lore m))
mkLetNamesB' attr names e = do
scope <- askScope
pat <- bindPatternWithAllocations scope names e
return $ Let pat (defAux attr) e
mkLetNamesB'' :: (Op (Lore m) ~ MemOp inner, ExpAttr lore ~ (),
HasScope (Engine.Wise lore) m, Allocator lore (PatAllocM lore),
MonadBinder m, Engine.CanBeWise (Op lore)) =>
[VName] -> Exp (Engine.Wise lore)
-> m (Stm (Engine.Wise lore))
mkLetNamesB'' names e = do
scope <- Engine.removeScopeWisdom <$> askScope
(pat, prestms) <- runPatAllocM (patternWithAllocations names $ Engine.removeExpWisdom e) scope
mapM_ bindAllocStm prestms
let pat' = Engine.addWisdomToPattern pat e
attr = Engine.mkWiseExpAttr pat' () e
return $ Let pat' (defAux attr) e
instance BinderOps ExplicitMemory where
mkExpAttrB _ _ = return ()
mkBodyB stms res = return $ Body () stms res
mkLetNamesB = mkLetNamesB' ()
instance BinderOps OutInKernel where
mkExpAttrB _ _ = return ()
mkBodyB stms res = return $ Body () stms res
mkLetNamesB = mkLetNamesB' ()
instance BinderOps (Engine.Wise ExplicitMemory) where
mkExpAttrB pat e = return $ Engine.mkWiseExpAttr pat () e
mkBodyB stms res = return $ Engine.mkWiseBody () stms res
mkLetNamesB = mkLetNamesB''
instance BinderOps (Engine.Wise OutInKernel) where
mkExpAttrB pat e = return $ Engine.mkWiseExpAttr pat () e
mkBodyB stms res = return $ Engine.mkWiseBody () stms res
mkLetNamesB = mkLetNamesB''
simplifiable :: (Engine.SimplifiableLore lore,
ExpAttr lore ~ (),
BodyAttr lore ~ (),
Op lore ~ MemOp inner,
Allocator lore (PatAllocM lore)) =>
(inner -> Engine.SimpleM lore (Engine.OpWithWisdom inner, Stms (Engine.Wise lore)))
-> SimpleOps lore
simplifiable simplifyInnerOp =
SimpleOps mkExpAttrS' mkBodyS' mkLetNamesS' simplifyOp
where mkExpAttrS' _ pat e =
return $ Engine.mkWiseExpAttr pat () e
mkBodyS' _ bnds res = return $ mkWiseBody () bnds res
mkLetNamesS' vtable names e = do
(pat', stms) <- runBinder $ bindPatternWithAllocations env names $
removeExpWisdom e
return (mkWiseLetStm pat' (defAux ()) e, stms)
where env = removeScopeWisdom $ ST.toScope vtable
simplifyOp (Alloc size space) =
(,) <$> (Alloc <$> Engine.simplify size <*> pure space) <*> pure mempty
simplifyOp (Inner k) = do (k', hoisted) <- simplifyInnerOp k
return (Inner k', hoisted)
bindPatternWithAllocations :: (MonadBinder m,
ExpAttr lore ~ (),
Op (Lore m) ~ MemOp inner,
Allocator lore (PatAllocM lore)) =>
Scope lore -> [VName] -> Exp lore
-> m (Pattern lore)
bindPatternWithAllocations types names e = do
(pat,prebnds) <- runPatAllocM (patternWithAllocations names e) types
mapM_ bindAllocStm prebnds
return pat
data ExpHint = NoHint
| Hint IxFun Space
kernelExpHints :: (Allocator lore m, Op lore ~ MemOp (Kernel somelore)) =>
Exp lore -> m [ExpHint]
kernelExpHints (BasicOp (Manifest perm v)) = do
dims <- arrayDims <$> lookupType v
let perm_inv = rearrangeInverse perm
dims' = rearrangeShape perm dims
ixfun = IxFun.permute (IxFun.iota $ map (primExpFromSubExp int32) dims')
perm_inv
return [Hint ixfun DefaultSpace]
kernelExpHints (Op (Inner (Kernel _ space rets kbody))) =
zipWithM hint rets $ kernelBodyResult kbody
where num_threads = spaceNumThreads space
spacy AllThreads = Just [num_threads]
spacy ThreadsInSpace = Just $ map snd $ spaceDimensions space
spacy _ = Nothing
coalesceReturnOfShape _ [] = False
coalesceReturnOfShape bs [Constant (IntValue (Int32Value d))] = bs * d > 4
coalesceReturnOfShape _ _ = True
hint t (ThreadsReturn threads _)
| coalesceReturnOfShape (primByteSize (elemType t)) $ arrayDims t,
Just space_dims <- spacy threads = do
t_dims <- mapM dimAllocationSize $ arrayDims t
return $ Hint (innermost space_dims t_dims) DefaultSpace
hint t (ConcatReturns SplitStrided{} w _ _ _) = do
t_dims <- mapM dimAllocationSize $ arrayDims t
return $ Hint (innermost [w] t_dims) DefaultSpace
hint Prim{} (ConcatReturns SplitContiguous w elems_per_thread Nothing _) = do
let ixfun_base = IxFun.iota $ map (primExpFromSubExp int32) [num_threads,elems_per_thread]
ixfun_tr = IxFun.permute ixfun_base [1,0]
ixfun = IxFun.reshape ixfun_tr $ map (DimNew . primExpFromSubExp int32) [w]
return $ Hint ixfun DefaultSpace
hint _ _ = return NoHint
kernelExpHints (Op (Inner (SegRed space _ _ nes ts body))) =
(map (const NoHint) red_res <>) <$> zipWithM mapHint (drop (length nes) ts) map_res
where (red_res, map_res) = splitAt (length nes) $ bodyResult body
mapHint t _ = do
t_dims <- mapM dimAllocationSize $ arrayDims t
return $ Hint (innermost (map snd $ spaceDimensions space) t_dims) DefaultSpace
kernelExpHints e =
return $ replicate (expExtTypeSize e) NoHint
innermost :: [SubExp] -> [SubExp] -> IxFun
innermost space_dims t_dims =
let r = length t_dims
dims = space_dims ++ t_dims
perm = [length space_dims..length space_dims+r-1] ++
[0..length space_dims-1]
perm_inv = rearrangeInverse perm
dims_perm = rearrangeShape perm dims
ixfun_base = IxFun.iota $ map (primExpFromSubExp int32) dims_perm
ixfun_rearranged = IxFun.permute ixfun_base perm_inv
in ixfun_rearranged
inKernelExpHints :: (Allocator lore m, Op lore ~ MemOp (KernelExp somelore)) =>
Exp lore -> m [ExpHint]
inKernelExpHints (Op (Inner (Combine (CombineSpace scatter cspace) ts _ _))) =
fmap (replicate (sum ns) NoHint ++) $ forM (drop (sum ns*2) ts) $ \t -> do
alloc_dims <- mapM dimAllocationSize $ dims ++ arrayDims t
let ixfun = IxFun.iota $ map (primExpFromSubExp int32) alloc_dims
return $ Hint ixfun $ Space "local"
where dims = map snd cspace
(_, ns, _) = unzip3 scatter
inKernelExpHints e =
return $ replicate (expExtTypeSize e) NoHint