Deleting unused and duplicated methods

Author: kirillgarbar

src/GraphBLAS-sharp.Backend/Common/Utils.fs

@@ -21,7 +21,3 @@ module internal Utils =
         >> fun x -> x ||| (x >>> 8)
         >> fun x -> x ||| (x >>> 16)
         >> fun x -> x + 1
-
-    let toHost (processor: MailboxProcessor<_>) (src: ClArray<_>) =
-        let dst = Array.zeroCreate src.Length
-        processor.PostAndReply(fun ch -> Msg.CreateToHostMsg(src, dst, ch))

src/GraphBLAS-sharp.Backend/Matrix/CSRMatrix/Elementwise.fs

@@ -8,63 +8,6 @@ open GraphBLAS.FSharp.Backend.Common
 open Microsoft.FSharp.Quotations
 
 module internal Elementwise =
-    let expandCompressedRowPointers (clContext: ClContext) workGroupSize =
-
-        let kernel =
-            <@ fun (ndRange: Range1D) nonZeroRows nnz numberOfRows (compressedRowPointers: ClArray<int>) (compressedRows: ClArray<int>) (rowPointers: ClArray<int>) ->
-
-                let i = ndRange.GlobalID0
-
-                //Init with zeroes
-                if i < numberOfRows then
-                    rowPointers.[i] <- 0
-
-                if i < nonZeroRows then
-                    rowPointers.[compressedRows.[i]] <-
-                        compressedRowPointers.[i + 1]
-                        - compressedRowPointers.[i] @>
-
-        let sum =
-            ClArray.prefixSumExcludeInplace clContext workGroupSize
-
-        let kernel = clContext.Compile(kernel)
-
-        fun (processor: MailboxProcessor<_>) (numberOfRows: int) (nnz: int) (compressedRowPointers: ClArray<int>) (compressedRows: ClArray<int>) ->
-
-            let rowPointers =
-                clContext.CreateClArray<int>(
-                    numberOfRows + 1,
-                    hostAccessMode = HostAccessMode.NotAccessible,
-                    deviceAccessMode = DeviceAccessMode.ReadWrite,
-                    allocationMode = AllocationMode.Default
-                )
-
-            let ndRange =
-                Range1D.CreateValid(numberOfRows + 1, workGroupSize)
-
-            let kernel = kernel.GetKernel()
-
-            processor.Post(
-                Msg.MsgSetArguments
-                    (fun () ->
-                        kernel.KernelFunc
-                            ndRange
-                            compressedRows.Length
-                            nnz
-                            numberOfRows
-                            compressedRowPointers
-                            compressedRows
-                            rowPointers)
-            )
-
-            processor.Post(Msg.CreateRunMsg<_, _>(kernel))
-
-            let sumCell = clContext.CreateClCell 0
-            sum processor rowPointers sumCell |> ignore
-            processor.Post(Msg.CreateFreeMsg<_>(sumCell))
-
-            rowPointers
-
     let preparePositions<'a, 'b, 'c when 'a: struct and 'b: struct and 'c: struct and 'c: equality>
         (clContext: ClContext)
         (opAdd: Expr<'a option -> 'b option -> 'c option>)
@@ -311,84 +254,6 @@ module internal Elementwise =
 
             resultRows, resultColumns, resultValues, positions, resultLength
 
-    let getCompressedRowPointers (clContext: ClContext) workGroupSize =
-
-        let getCompressedRowPointers =
-            <@ fun (ndRange: Range1D) allRowsLength nonZeroRows nnz (allRows: ClArray<int>) (positions: ClArray<int>) (isEndOfRowBitmap: ClArray<int>) (rowPointers: ClArray<int>) (compressedRows: ClArray<int>) ->
-
-                let i = ndRange.GlobalID0
-
-                if i > 0
-                   && i < allRowsLength
-                   && isEndOfRowBitmap.[i] <> isEndOfRowBitmap.[i - 1] then
-                    let row = isEndOfRowBitmap.[i]
-
-                    rowPointers.[row] <- positions.[i]
-                    compressedRows.[row] <- allRows.[i]
-                elif i = 0 then
-                    rowPointers.[0] <- 0
-                    compressedRows.[0] <- allRows.[0]
-                elif i = allRowsLength then
-                    rowPointers.[nonZeroRows] <- nnz @>
-
-        let kernel =
-            clContext.Compile(getCompressedRowPointers)
-
-        let sum =
-            ClArray.prefixSumExcludeInplace clContext workGroupSize
-
-        fun (processor: MailboxProcessor<_>) nnz (allRows: ClArray<int>) (positions: ClArray<int>) (isRowEnd: ClArray<int>) ->
-
-            let nonZeroRows = Array.zeroCreate 1
-
-            let rowEndSum = clContext.CreateClCell 0
-
-            let _, rowEndSum = sum processor isRowEnd rowEndSum
-
-            processor.PostAndReply(fun ch -> Msg.CreateToHostMsg<_>(rowEndSum, nonZeroRows, ch))
-            let nonZeroRows = nonZeroRows.[0]
-            processor.Post(Msg.CreateFreeMsg<_>(rowEndSum))
-
-            let compressedRowPointers =
-                clContext.CreateClArray<int>(
-                    nonZeroRows + 1,
-                    hostAccessMode = HostAccessMode.NotAccessible,
-                    deviceAccessMode = DeviceAccessMode.ReadWrite,
-                    allocationMode = AllocationMode.Default
-                )
-
-            let compressedRows =
-                clContext.CreateClArray<int>(
-                    nonZeroRows,
-                    hostAccessMode = HostAccessMode.NotAccessible,
-                    deviceAccessMode = DeviceAccessMode.ReadWrite,
-                    allocationMode = AllocationMode.Default
-                )
-
-            let ndRange =
-                Range1D.CreateValid(allRows.Length + 1, workGroupSize)
-
-            let kernel = kernel.GetKernel()
-
-            processor.Post(
-                Msg.MsgSetArguments
-                    (fun () ->
-                        kernel.KernelFunc
-                            ndRange
-                            allRows.Length
-                            nonZeroRows
-                            nnz
-                            allRows
-                            positions
-                            isRowEnd
-                            compressedRowPointers
-                            compressedRows)
-            )
-
-            processor.Post(Msg.CreateRunMsg<_, _>(kernel))
-
-            compressedRowPointers, compressedRows, nonZeroRows
-
     let merge<'a, 'b when 'a: struct and 'b: struct> (clContext: ClContext) workGroupSize =
         let localArraySize = workGroupSize + 2