refactor: ClArray.Free and *.FreeAndWait

Author: IgorErin

benchmarks/GraphBLAS-sharp.Benchmarks/BenchmarksBFS.fs

@@ -83,7 +83,7 @@ type BFSBenchmarks<'matrixT, 'elem when 'matrixT :> IDeviceMemObject and 'elem :
         (matrix :> IDeviceMemObject).Dispose this.Processor
 
     member this.ClearResult() =
-        this.ResultVector.Free this.Processor
+        this.ResultVector.FreeAndWait this.Processor
 
     member this.ReadMatrix() =
         let matrixReader = this.InputMatrixReader

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

@@ -64,7 +64,9 @@ module internal Scatter =
     /// </code>
     /// </example>
     let firstOccurrence clContext =
-        general <| Predicates.firstOccurrence () <| clContext
+        general
+        <| Predicates.firstOccurrence ()
+        <| clContext
 
     /// <summary>
     /// Creates a new array from the given one where it is indicated by the array of positions at which position in the new array
@@ -85,7 +87,9 @@ module internal Scatter =
     /// </code>
     /// </example>
     let lastOccurrence clContext =
-        general <| Predicates.lastOccurrence () <| clContext
+        general
+        <| Predicates.lastOccurrence ()
+        <| clContext
 
     let private generalInit<'a> predicate valueMap (clContext: ClContext) workGroupSize =
 

src/GraphBLAS-sharp.Backend/Objects/ArraysExtentions.fs

@@ -4,15 +4,15 @@ open Brahma.FSharp
 
 module ArraysExtensions =
     type ClArray<'a> with
-        member this.Free(q: MailboxProcessor<Msg>) =
+        member this.FreeAndWait(q: MailboxProcessor<Msg>) =
             q.Post(Msg.CreateFreeMsg this)
             q.PostAndReply(Msg.MsgNotifyMe)
 
         member this.ToHost(q: MailboxProcessor<Msg>) =
             let dst = Array.zeroCreate this.Length
             q.PostAndReply(fun ch -> Msg.CreateToHostMsg(this, dst, ch))
 
-        // member this.Free(q: MailboxProcessor<_>) = q.Post <| Msg.CreateFreeMsg this TODO()
+        member this.Free(q: MailboxProcessor<_>) = q.Post <| Msg.CreateFreeMsg this
 
         member this.ToHostAndFree(q: MailboxProcessor<_>) =
             let result = this.ToHost q

src/GraphBLAS-sharp.Backend/Objects/Vector.fs

@@ -34,4 +34,4 @@ type ClVector<'a when 'a: struct> =
     member this.Dispose(q) =
         match this with
         | Sparse vector -> vector.Dispose(q)
-        | Dense vector -> vector.Free(q)
+        | Dense vector -> vector.FreeAndWait(q)

src/GraphBLAS-sharp.Backend/Quotes/Predicates.fs

@@ -11,10 +11,10 @@ module Predicates =
 
     let inline lastOccurrence () =
         <@ fun (gid: int) (length: int) (inputArray: ClArray<'a>) ->
-                  gid = length - 1
-                  || inputArray.[gid] <> inputArray.[gid + 1] @>
+            gid = length - 1
+            || inputArray.[gid] <> inputArray.[gid + 1] @>
 
     let inline firstOccurrence () =
         <@ fun (gid: int) (_: int) (inputArray: ClArray<'a>) ->
-                  gid = 0
-                  || inputArray.[gid - 1] <> inputArray.[gid] @>
+            gid = 0
+            || inputArray.[gid - 1] <> inputArray.[gid] @>

tests/GraphBLAS-sharp.Tests/Common/Reduce/ReduceByKey.fs

@@ -458,10 +458,10 @@ let testsSegmentsSequential2DOption =
 
 let allTests =
     testList
-       "Reduce.ByKey"
-       [ sequentialTest
-         oneWorkGroupTest
-         sequentialSegmentTests
-         sequential2DTest
-         sequentialSegment2DTests
-         testsSegmentsSequential2DOption ]
+        "Reduce.ByKey"
+        [ sequentialTest
+          oneWorkGroupTest
+          sequentialSegmentTests
+          sequential2DTest
+          sequentialSegment2DTests
+          testsSegmentsSequential2DOption ]

tests/GraphBLAS-sharp.Tests/Vector/SpMV.fs

@@ -77,8 +77,7 @@ let correctnessGenericTest
 
                 (ClMatrix.CSR m).Dispose q
                 v.Free q
-                let hostRes = res.ToHost q
-                res.Free q
+                let hostRes = res.ToHostAndFree q
 
                 checkResult isEqual sumOp mulOp zero matrix vector hostRes
             | _ -> failwith "Impossible"