{-# LANGUAGE QuasiQuotes #-} {-# LANGUAGE TupleSections #-} -- | This module defines a translation from imperative code with -- kernels to imperative code with OpenCL calls. module Futhark.CodeGen.ImpGen.Kernels.ToOpenCL ( kernelsToOpenCL ) where import Control.Monad.State import Control.Monad.Identity import Control.Monad.Writer import Control.Monad.Reader import Data.Maybe import qualified Data.Set as S import qualified Data.Map.Strict as M import qualified Data.Semigroup as Sem import qualified Language.C.Syntax as C import qualified Language.C.Quote.OpenCL as C import Futhark.Error import Futhark.Representation.AST.Attributes.Types (int32) import qualified Futhark.CodeGen.OpenCL.Kernels as Kernels import qualified Futhark.CodeGen.Backends.GenericC as GenericC import Futhark.CodeGen.Backends.SimpleRepresentation import Futhark.CodeGen.ImpCode.Kernels hiding (Program) import qualified Futhark.CodeGen.ImpCode.Kernels as ImpKernels import Futhark.CodeGen.ImpCode.OpenCL hiding (Program) import qualified Futhark.CodeGen.ImpCode.OpenCL as ImpOpenCL import Futhark.MonadFreshNames import Futhark.Util (zEncodeString) import Futhark.Util.Pretty (pretty, prettyOneLine) import Futhark.Util.IntegralExp (quotRoundingUp) -- | Translate a kernels-program to an OpenCL-program. kernelsToOpenCL :: ImpKernels.Program -> Either InternalError ImpOpenCL.Program kernelsToOpenCL (ImpKernels.Functions funs) = do (prog', ToOpenCL extra_funs kernels requirements sizes) <- runWriterT $ fmap Functions $ forM funs $ \(fname, fun) -> (fname,) <$> runReaderT (traverse onHostOp fun) fname let kernel_names = M.keys kernels opencl_code = openClCode $ M.elems kernels opencl_prelude = pretty $ genOpenClPrelude requirements return $ ImpOpenCL.Program opencl_code opencl_prelude kernel_names (S.toList $ kernelUsedTypes requirements) sizes $ ImpOpenCL.Functions (M.toList extra_funs) <> prog' pointerQuals :: Monad m => String -> m [C.TypeQual] pointerQuals "global" = return [C.ctyquals|__global|] pointerQuals "local" = return [C.ctyquals|__local|] pointerQuals "private" = return [C.ctyquals|__private|] pointerQuals "constant" = return [C.ctyquals|__constant|] pointerQuals "write_only" = return [C.ctyquals|__write_only|] pointerQuals "read_only" = return [C.ctyquals|__read_only|] pointerQuals "kernel" = return [C.ctyquals|__kernel|] pointerQuals s = fail $ "'" ++ s ++ "' is not an OpenCL kernel address space." type UsedFunctions = [(String,C.Func)] -- The ordering is important! data OpenClRequirements = OpenClRequirements { kernelUsedTypes :: S.Set PrimType , _kernelConstants :: [(VName, KernelConstExp)] } instance Sem.Semigroup OpenClRequirements where OpenClRequirements ts1 consts1 <> OpenClRequirements ts2 consts2 = OpenClRequirements (ts1 <> ts2) (consts1 <> consts2) instance Monoid OpenClRequirements where mempty = OpenClRequirements mempty mempty mappend = (Sem.<>) data ToOpenCL = ToOpenCL { clExtraFuns :: M.Map Name ImpOpenCL.Function , clKernels :: M.Map KernelName C.Func , clRequirements :: OpenClRequirements , clSizes :: M.Map VName (SizeClass, Name) } instance Sem.Semigroup ToOpenCL where ToOpenCL f1 k1 r1 sz1 <> ToOpenCL f2 k2 r2 sz2 = ToOpenCL (f1<>f2) (k1<>k2) (r1<>r2) (sz1<>sz2) instance Monoid ToOpenCL where mempty = ToOpenCL mempty mempty mempty mempty mappend = (Sem.<>) type OnKernelM = ReaderT Name (WriterT ToOpenCL (Either InternalError)) onHostOp :: HostOp -> OnKernelM OpenCL onHostOp (CallKernel k) = onKernel k onHostOp (ImpKernels.GetSize v key size_class) = do fname <- ask tell mempty { clSizes = M.singleton key (size_class, fname) } return $ ImpOpenCL.GetSize v key onHostOp (ImpKernels.CmpSizeLe v key size_class x) = do fname <- ask tell mempty { clSizes = M.singleton key (size_class, fname) } return $ ImpOpenCL.CmpSizeLe v key x onHostOp (ImpKernels.GetSizeMax v size_class) = return $ ImpOpenCL.GetSizeMax v size_class onKernel :: CallKernel -> OnKernelM OpenCL onKernel called@(Map kernel) = do let (funbody, _) = GenericC.runCompilerM (Functions []) inKernelOperations blankNameSource mempty $ do size <- GenericC.compileExp $ mapKernelSize kernel let check = [C.citem|if ($id:(mapKernelThreadNum kernel) >= $exp:size) return;|] body <- GenericC.blockScope $ GenericC.compileCode $ mapKernelBody kernel return $ check : body params = mapMaybe useAsParam $ mapKernelUses kernel tell mempty { clExtraFuns = mempty , clKernels = M.singleton (mapKernelName kernel) [C.cfun|__kernel void $id:(mapKernelName kernel) ($params:params) { const uint $id:(mapKernelThreadNum kernel) = get_global_id(0); $items:funbody }|] , clRequirements = OpenClRequirements (typesInKernel called) (mapMaybe useAsConst $ mapKernelUses kernel) } return $ LaunchKernel (calledKernelName called) (kernelArgs called) kernel_size workgroup_size where (kernel_size, workgroup_size) = kernelAndWorkgroupSize called onKernel called@(AnyKernel kernel) = do let (kernel_body, _) = GenericC.runCompilerM (Functions []) inKernelOperations blankNameSource mempty $ GenericC.blockScope $ GenericC.compileCode $ kernelBody kernel use_params = mapMaybe useAsParam $ kernelUses kernel (local_memory_params, local_memory_init) = unzip $ flip evalState (blankNameSource :: VNameSource) $ mapM prepareLocalMemory $ kernelLocalMemory kernel params = catMaybes local_memory_params ++ use_params tell mempty { clExtraFuns = mempty , clKernels = M.singleton name [C.cfun|__kernel void $id:name ($params:params) { $items:local_memory_init $items:kernel_body }|] , clRequirements = OpenClRequirements (typesInKernel called) (mapMaybe useAsConst $ kernelUses kernel) } return $ LaunchKernel (calledKernelName called) (kernelArgs called) kernel_size workgroup_size where prepareLocalMemory (mem, Left _) = do mem_aligned <- newVName $ baseString mem ++ "_aligned" return (Just [C.cparam|__local volatile typename int64_t* $id:mem_aligned|], [C.citem|__local volatile char* restrict $id:mem = $id:mem_aligned;|]) prepareLocalMemory (mem, Right size) = do let size' = compilePrimExp size return (Nothing, [C.citem|ALIGNED_LOCAL_MEMORY($id:mem, $exp:size');|]) name = calledKernelName called (kernel_size, workgroup_size) = kernelAndWorkgroupSize called onKernel (MapTranspose bt destmem destoffset srcmem srcoffset num_arrays x_elems y_elems in_elems out_elems) = do generateTransposeFunction bt return $ HostCode $ Call [] (transposeName bt) [MemArg destmem, ExpArg destoffset, MemArg srcmem, ExpArg srcoffset, ExpArg num_arrays, ExpArg x_elems, ExpArg y_elems, ExpArg in_elems, ExpArg out_elems] useAsParam :: KernelUse -> Maybe C.Param useAsParam (ScalarUse name bt) = let ctp = case bt of -- OpenCL does not permit bool as a kernel parameter type. Bool -> [C.cty|unsigned char|] _ -> GenericC.primTypeToCType bt in Just [C.cparam|$ty:ctp $id:name|] useAsParam (MemoryUse name _) = Just [C.cparam|__global unsigned char *$id:name|] useAsParam ConstUse{} = Nothing useAsConst :: KernelUse -> Maybe (VName, KernelConstExp) useAsConst (ConstUse v e) = Just (v,e) useAsConst _ = Nothing openClCode :: [C.Func] -> String openClCode kernels = pretty [C.cunit|$edecls:funcs|] where funcs = [[C.cedecl|$func:kernel_func|] | kernel_func <- kernels ] genOpenClPrelude :: OpenClRequirements -> [C.Definition] genOpenClPrelude (OpenClRequirements ts consts) = -- Clang-based OpenCL implementations need this for 'static' to work. [C.cedecl|$esc:("#pragma OPENCL EXTENSION cl_clang_storage_class_specifiers : enable")|] : [[C.cedecl|$esc:("#pragma OPENCL EXTENSION cl_khr_fp64 : enable")|] | uses_float64] ++ [C.cunit| /* Some OpenCL programs dislike empty progams, or programs with no kernels. * Declare a dummy kernel to ensure they remain our friends. */ __kernel void dummy_kernel(__global unsigned char *dummy, int n) { const int thread_gid = get_global_id(0); if (thread_gid >= n) return; } typedef char int8_t; typedef short int16_t; typedef int int32_t; typedef long int64_t; typedef uchar uint8_t; typedef ushort uint16_t; typedef uint uint32_t; typedef ulong uint64_t; $esc:("#define ALIGNED_LOCAL_MEMORY(m,size) __local unsigned char m[size] __attribute__ ((align))") |] ++ cIntOps ++ cFloat32Ops ++ cFloat32Funs ++ (if uses_float64 then cFloat64Ops ++ cFloat64Funs ++ cFloatConvOps else []) ++ [ [C.cedecl|$esc:def|] | def <- map constToDefine consts ] where uses_float64 = FloatType Float64 `S.member` ts constToDefine (name, e) = let e' = compilePrimExp e in unwords ["#define", zEncodeString (pretty name), "("++prettyOneLine e'++")"] compilePrimExp :: PrimExp KernelConst -> C.Exp compilePrimExp e = runIdentity $ GenericC.compilePrimExp compileKernelConst e where compileKernelConst (SizeConst key) = return [C.cexp|$id:(pretty key)|] mapKernelName :: MapKernel -> String mapKernelName k = "kernel_"++ mapKernelDesc k ++ "_" ++ show (baseTag $ mapKernelThreadNum k) calledKernelName :: CallKernel -> String calledKernelName (Map k) = mapKernelName k calledKernelName (AnyKernel k) = kernelDesc k ++ "_kernel_" ++ show (baseTag $ kernelName k) calledKernelName (MapTranspose bt _ _ _ _ _ _ _ _ _) = transposeKernelName bt Kernels.TransposeNormal kernelArgs :: CallKernel -> [KernelArg] kernelArgs (Map kernel) = mapMaybe useToArg $ mapKernelUses kernel kernelArgs (AnyKernel kernel) = mapMaybe (fmap (SharedMemoryKArg . memSizeToExp) . localMemorySize) (kernelLocalMemory kernel) ++ mapMaybe useToArg (kernelUses kernel) where localMemorySize (_, Left size) = Just size localMemorySize (_, Right{}) = Nothing kernelArgs (MapTranspose bt destmem destoffset srcmem srcoffset _ x_elems y_elems in_elems out_elems) = [ MemKArg destmem , ValueKArg destoffset int32 , MemKArg srcmem , ValueKArg srcoffset int32 , ValueKArg x_elems int32 , ValueKArg y_elems int32 , ValueKArg in_elems int32 , ValueKArg out_elems int32 , SharedMemoryKArg shared_memory ] where shared_memory = bytes $ (transposeBlockDim + 1) * transposeBlockDim * LeafExp (SizeOf bt) (IntType Int32) kernelAndWorkgroupSize :: CallKernel -> ([Exp], [Exp]) kernelAndWorkgroupSize (Map kernel) = ([sizeToExp (mapKernelNumGroups kernel) * sizeToExp (mapKernelGroupSize kernel)], [sizeToExp $ mapKernelGroupSize kernel]) kernelAndWorkgroupSize (AnyKernel kernel) = ([sizeToExp (kernelNumGroups kernel) * sizeToExp (kernelGroupSize kernel)], [sizeToExp $ kernelGroupSize kernel]) kernelAndWorkgroupSize (MapTranspose _ _ _ _ _ num_arrays x_elems y_elems _ _) = transposeKernelAndGroupSize num_arrays x_elems y_elems --- Generating C inKernelOperations :: GenericC.Operations KernelOp UsedFunctions inKernelOperations = GenericC.Operations { GenericC.opsCompiler = kernelOps , GenericC.opsMemoryType = kernelMemoryType , GenericC.opsWriteScalar = GenericC.writeScalarPointerWithQuals pointerQuals , GenericC.opsReadScalar = GenericC.readScalarPointerWithQuals pointerQuals , GenericC.opsAllocate = cannotAllocate , GenericC.opsDeallocate = cannotDeallocate , GenericC.opsCopy = copyInKernel , GenericC.opsStaticArray = noStaticArrays , GenericC.opsFatMemory = False } where kernelOps :: GenericC.OpCompiler KernelOp UsedFunctions kernelOps (GetGroupId v i) = GenericC.stm [C.cstm|$id:v = get_group_id($int:i);|] kernelOps (GetLocalId v i) = GenericC.stm [C.cstm|$id:v = get_local_id($int:i);|] kernelOps (GetLocalSize v i) = GenericC.stm [C.cstm|$id:v = get_local_size($int:i);|] kernelOps (GetGlobalId v i) = GenericC.stm [C.cstm|$id:v = get_global_id($int:i);|] kernelOps (GetGlobalSize v i) = GenericC.stm [C.cstm|$id:v = get_global_size($int:i);|] kernelOps (GetLockstepWidth v) = GenericC.stm [C.cstm|$id:v = LOCKSTEP_WIDTH;|] kernelOps Barrier = GenericC.stm [C.cstm|barrier(CLK_LOCAL_MEM_FENCE);|] kernelOps MemFence = GenericC.stm [C.cstm|mem_fence(CLK_GLOBAL_MEM_FENCE);|] kernelOps (Atomic aop) = atomicOps aop atomicOps (AtomicAdd old arr ind val) = do ind' <- GenericC.compileExp $ innerExp ind val' <- GenericC.compileExp val GenericC.stm [C.cstm|$id:old = atomic_add((volatile __global int *)&$id:arr[$exp:ind'], $exp:val');|] atomicOps (AtomicSMax old arr ind val) = do ind' <- GenericC.compileExp $ innerExp ind val' <- GenericC.compileExp val GenericC.stm [C.cstm|$id:old = atomic_max((volatile __global int *)&$id:arr[$exp:ind'], $exp:val');|] atomicOps (AtomicSMin old arr ind val) = do ind' <- GenericC.compileExp $ innerExp ind val' <- GenericC.compileExp val GenericC.stm [C.cstm|$id:old = atomic_min((volatile __global int *)&$id:arr[$exp:ind'], $exp:val');|] atomicOps (AtomicUMax old arr ind val) = do ind' <- GenericC.compileExp $ innerExp ind val' <- GenericC.compileExp val GenericC.stm [C.cstm|$id:old = atomic_max((volatile __global unsigned int *)&$id:arr[$exp:ind'], (unsigned int)$exp:val');|] atomicOps (AtomicUMin old arr ind val) = do ind' <- GenericC.compileExp $ innerExp ind val' <- GenericC.compileExp val GenericC.stm [C.cstm|$id:old = atomic_min((volatile __global unsigned int *)&$id:arr[$exp:ind'], (unsigned int)$exp:val');|] atomicOps (AtomicAnd old arr ind val) = do ind' <- GenericC.compileExp $ innerExp ind val' <- GenericC.compileExp val GenericC.stm [C.cstm|$id:old = atomic_and((volatile __global unsigned int *)&$id:arr[$exp:ind'], (unsigned int)$exp:val');|] atomicOps (AtomicOr old arr ind val) = do ind' <- GenericC.compileExp $ innerExp ind val' <- GenericC.compileExp val GenericC.stm [C.cstm|$id:old = atomic_or((volatile __global unsigned int *)&$id:arr[$exp:ind'], (unsigned int)$exp:val');|] atomicOps (AtomicXor old arr ind val) = do ind' <- GenericC.compileExp $ innerExp ind val' <- GenericC.compileExp val GenericC.stm [C.cstm|$id:old = atomic_xor((volatile __global unsigned int *)&$id:arr[$exp:ind'], (unsigned int)$exp:val');|] atomicOps (AtomicCmpXchg old arr ind cmp val) = do ind' <- GenericC.compileExp $ innerExp ind cmp' <- GenericC.compileExp cmp val' <- GenericC.compileExp val GenericC.stm [C.cstm|$id:old = atomic_cmpxchg((volatile __global int *)&$id:arr[$exp:ind'], $exp:cmp', $exp:val');|] atomicOps (AtomicXchg old arr ind val) = do ind' <- GenericC.compileExp $ innerExp ind val' <- GenericC.compileExp val GenericC.stm [C.cstm|$id:old = atomic_xchg((volatile __global int *)&$id:arr[$exp:ind'], $exp:val');|] cannotAllocate :: GenericC.Allocate KernelOp UsedFunctions cannotAllocate _ = fail "Cannot allocate memory in kernel" cannotDeallocate :: GenericC.Deallocate KernelOp UsedFunctions cannotDeallocate _ _ = fail "Cannot deallocate memory in kernel" copyInKernel :: GenericC.Copy KernelOp UsedFunctions copyInKernel _ _ _ _ _ _ _ = fail "Cannot bulk copy in kernel." noStaticArrays :: GenericC.StaticArray KernelOp UsedFunctions noStaticArrays _ _ _ _ = fail "Cannot create static array in kernel." kernelMemoryType space = do quals <- pointerQuals space return [C.cty|$tyquals:quals $ty:defaultMemBlockType|] --- Handling transpositions transposeKernelName :: PrimType -> Kernels.TransposeType -> String transposeKernelName bt Kernels.TransposeNormal = "fut_kernel_map_transpose_" ++ pretty bt transposeKernelName bt Kernels.TransposeLowWidth = "fut_kernel_map_transpose_lowwidth_" ++ pretty bt transposeKernelName bt Kernels.TransposeLowHeight = "fut_kernel_map_transpose_lowheight_" ++ pretty bt transposeKernelName bt Kernels.TransposeSmall = "fut_kernel_map_transpose_small_" ++ pretty bt transposeName :: PrimType -> Name transposeName bt = nameFromString $ "map_transpose_opencl_" ++ pretty bt generateTransposeFunction :: PrimType -> OnKernelM () generateTransposeFunction bt = -- We have special functions to handle transposing an input array with low -- width or low height, as this would cause very few threads to be active. See -- comment in Futhark.CodeGen.OpenCL.OpenCL.Kernels.hs for more details. tell mempty { clExtraFuns = M.singleton (transposeName bt) $ ImpOpenCL.Function False [] params transpose_code [] [] , clKernels = M.fromList $ map (\tt -> let name = transposeKernelName bt tt in (name, Kernels.mapTranspose name bt' tt)) [Kernels.TransposeNormal, Kernels.TransposeLowWidth, Kernels.TransposeLowHeight, Kernels.TransposeSmall] , clRequirements = mempty } where bt' = GenericC.primTypeToCType bt space = ImpOpenCL.Space "device" memparam s i = MemParam (VName (nameFromString s) i) space intparam s i = ScalarParam (VName (nameFromString s) i) $ IntType Int32 params = [destmem_p, destoffset_p, srcmem_p, srcoffset_p, num_arrays_p, x_p, y_p, in_p, out_p] [destmem_p, destoffset_p, srcmem_p, srcoffset_p, num_arrays_p, x_p, y_p, in_p, out_p, muly, new_height, mulx, new_width] = zipWith ($) [memparam "destmem", intparam "destoffset", memparam "srcmem", intparam "srcoffset", intparam "num_arrays", intparam "x_elems", intparam "y_elems", intparam "in_elems", intparam "out_elems", -- The following is only used for low width/height -- transpose kernels intparam "muly", intparam "new_height", intparam "mulx", intparam "new_width" ] [0..] asExp param = ImpOpenCL.LeafExp (ImpOpenCL.ScalarVar (paramName param)) (IntType Int32) asArg (MemParam name _) = MemKArg name asArg (ScalarParam name t) = ValueKArg (ImpOpenCL.LeafExp (ImpOpenCL.ScalarVar name) t) t normal_kernel_args = map asArg [destmem_p, destoffset_p, srcmem_p, srcoffset_p, x_p, y_p, in_p, out_p] ++ [SharedMemoryKArg shared_memory] lowwidth_kernel_args = map asArg [destmem_p, destoffset_p, srcmem_p, srcoffset_p, x_p, y_p, in_p, out_p, muly] ++ [SharedMemoryKArg shared_memory] lowheight_kernel_args = map asArg [destmem_p, destoffset_p, srcmem_p, srcoffset_p, x_p, y_p, in_p, out_p, mulx] ++ [SharedMemoryKArg shared_memory] shared_memory = bytes $ (transposeBlockDim + 1) * transposeBlockDim * LeafExp (SizeOf bt) (IntType Int32) transposeBlockDimDivTwo = BinOpExp (SQuot Int32) transposeBlockDim 2 should_use_lowwidth = BinOpExp LogAnd (CmpOpExp (CmpSle Int32) (asExp x_p) transposeBlockDimDivTwo) (CmpOpExp (CmpSlt Int32) transposeBlockDim (asExp y_p)) should_use_lowheight = BinOpExp LogAnd (CmpOpExp (CmpSle Int32) (asExp y_p) transposeBlockDimDivTwo) (CmpOpExp (CmpSlt Int32) transposeBlockDim (asExp x_p)) should_use_small = BinOpExp LogAnd (CmpOpExp (CmpSle Int32) (asExp x_p) transposeBlockDimDivTwo) (CmpOpExp (CmpSle Int32) (asExp y_p) transposeBlockDimDivTwo) -- When an input array has either width==1 or height==1, performing a -- transpose will be the same as performing a copy. If 'input_size' or -- 'output_size' is not equal to width*height, then this trick will not -- work when there are more than one array to process, as it is a per -- array limit. We could copy each array individually, but currently we -- do not. can_use_copy = let in_out_eq = CmpOpExp (CmpEq $ IntType Int32) (asExp in_p) (asExp out_p) onearr = CmpOpExp (CmpEq $ IntType Int32) (asExp num_arrays_p) 1 noprob_widthheight = CmpOpExp (CmpEq $ IntType Int32) (asExp x_p * asExp y_p) (asExp in_p) height_is_one = CmpOpExp (CmpEq $ IntType Int32) (asExp y_p) 1 width_is_one = CmpOpExp (CmpEq $ IntType Int32) (asExp x_p) 1 in BinOpExp LogAnd in_out_eq (BinOpExp LogAnd (BinOpExp LogOr onearr noprob_widthheight) (BinOpExp LogOr width_is_one height_is_one)) input_is_empty = CmpOpExp (CmpEq $ IntType Int32) (asExp num_arrays_p * asExp x_p * asExp y_p) 0 transpose_code = ImpOpenCL.If input_is_empty mempty (ImpOpenCL.If can_use_copy copy_code (ImpOpenCL.If should_use_lowwidth lowwidth_transpose_code (ImpOpenCL.If should_use_lowheight lowheight_transpose_code (ImpOpenCL.If should_use_small small_transpose_code normal_transpose_code)))) copy_code = let num_bytes = asExp in_p * ImpOpenCL.LeafExp (ImpOpenCL.SizeOf bt) (IntType Int32) in ImpOpenCL.Copy (paramName destmem_p) (Count $ asExp destoffset_p) space (paramName srcmem_p) (Count $ asExp srcoffset_p) space (Count num_bytes) normal_transpose_code = let (kernel_size, workgroup_size) = transposeKernelAndGroupSize (asExp num_arrays_p) (asExp x_p) (asExp y_p) in ImpOpenCL.Op $ LaunchKernel (transposeKernelName bt Kernels.TransposeNormal) normal_kernel_args kernel_size workgroup_size small_transpose_code = let group_size = (transposeBlockDim * transposeBlockDim) kernel_size = (asExp num_arrays_p * asExp x_p * asExp y_p) `roundUpTo` group_size in ImpOpenCL.Op $ LaunchKernel (transposeKernelName bt Kernels.TransposeSmall) (map asArg [destmem_p, destoffset_p, srcmem_p, srcoffset_p, num_arrays_p, x_p, y_p, in_p, out_p]) [kernel_size] [group_size] lowwidth_transpose_code = let set_muly = DeclareScalar (paramName muly) (IntType Int32) :>>: SetScalar (paramName muly) (BinOpExp (SQuot Int32) transposeBlockDim (asExp x_p)) set_new_height = DeclareScalar (paramName new_height) (IntType Int32) :>>: SetScalar (paramName new_height) (asExp y_p `quotRoundingUp` asExp muly) (kernel_size, workgroup_size) = transposeKernelAndGroupSize (asExp num_arrays_p) (asExp x_p) (asExp new_height) launch = ImpOpenCL.Op $ LaunchKernel (transposeKernelName bt Kernels.TransposeLowWidth) lowwidth_kernel_args kernel_size workgroup_size in set_muly :>>: set_new_height :>>: launch lowheight_transpose_code = let set_mulx = DeclareScalar (paramName mulx) (IntType Int32) :>>: SetScalar (paramName mulx) (BinOpExp (SQuot Int32) transposeBlockDim (asExp y_p)) set_new_width = DeclareScalar (paramName new_width) (IntType Int32) :>>: SetScalar (paramName new_width) (asExp x_p `quotRoundingUp` asExp mulx) (kernel_size, workgroup_size) = transposeKernelAndGroupSize (asExp num_arrays_p) (asExp new_width) (asExp y_p) launch = ImpOpenCL.Op $ LaunchKernel (transposeKernelName bt Kernels.TransposeLowHeight) lowheight_kernel_args kernel_size workgroup_size in set_mulx :>>: set_new_width :>>: launch transposeKernelAndGroupSize :: ImpOpenCL.Exp -> ImpOpenCL.Exp -> ImpOpenCL.Exp -> ([ImpOpenCL.Exp], [ImpOpenCL.Exp]) transposeKernelAndGroupSize num_arrays x_elems y_elems = ([x_elems `roundUpTo` transposeBlockDim , y_elems `roundUpTo` transposeBlockDim, num_arrays], [transposeBlockDim, transposeBlockDim, 1]) roundUpTo :: ImpOpenCL.Exp -> ImpOpenCL.Exp -> ImpOpenCL.Exp roundUpTo x y = x + ((y - (x `impRem` y)) `impRem` y) where impRem = BinOpExp $ SRem Int32 --- Checking requirements useToArg :: KernelUse -> Maybe KernelArg useToArg (MemoryUse mem _) = Just $ MemKArg mem useToArg (ScalarUse v bt) = Just $ ValueKArg (LeafExp (ScalarVar v) bt) bt useToArg ConstUse{} = Nothing typesInKernel :: CallKernel -> S.Set PrimType typesInKernel (Map kernel) = typesInCode $ mapKernelBody kernel typesInKernel (AnyKernel kernel) = typesInCode $ kernelBody kernel typesInKernel MapTranspose{} = mempty typesInCode :: ImpKernels.KernelCode -> S.Set PrimType typesInCode Skip = mempty typesInCode (c1 :>>: c2) = typesInCode c1 <> typesInCode c2 typesInCode (For _ it e c) = IntType it `S.insert` typesInExp e <> typesInCode c typesInCode (While e c) = typesInExp e <> typesInCode c typesInCode DeclareMem{} = mempty typesInCode (DeclareScalar _ t) = S.singleton t typesInCode (DeclareArray _ _ t _) = S.singleton t typesInCode (Allocate _ (Count e) _) = typesInExp e typesInCode Free{} = mempty typesInCode (Copy _ (Count e1) _ _ (Count e2) _ (Count e3)) = typesInExp e1 <> typesInExp e2 <> typesInExp e3 typesInCode (Write _ (Count e1) t _ _ e2) = typesInExp e1 <> S.singleton t <> typesInExp e2 typesInCode (SetScalar _ e) = typesInExp e typesInCode SetMem{} = mempty typesInCode (Call _ _ es) = mconcat $ map typesInArg es where typesInArg MemArg{} = mempty typesInArg (ExpArg e) = typesInExp e typesInCode (If e c1 c2) = typesInExp e <> typesInCode c1 <> typesInCode c2 typesInCode (Assert e _ _) = typesInExp e typesInCode (Comment _ c) = typesInCode c typesInCode (DebugPrint _ _ e) = typesInExp e typesInCode Op{} = mempty typesInExp :: Exp -> S.Set PrimType typesInExp (ValueExp v) = S.singleton $ primValueType v typesInExp (BinOpExp _ e1 e2) = typesInExp e1 <> typesInExp e2 typesInExp (CmpOpExp _ e1 e2) = typesInExp e1 <> typesInExp e2 typesInExp (ConvOpExp op e) = S.fromList [from, to] <> typesInExp e where (from, to) = convOpType op typesInExp (UnOpExp _ e) = typesInExp e typesInExp (FunExp _ args t) = S.singleton t <> mconcat (map typesInExp args) typesInExp (LeafExp (Index _ (Count e) t _ _) _) = S.singleton t <> typesInExp e typesInExp (LeafExp ScalarVar{} _) = mempty typesInExp (LeafExp (SizeOf t) _) = S.singleton t