Block after setup and cleanup in benchmarks

Author: kirillgarbar

benchmarks/GraphBLAS-sharp.Benchmarks/Algorithms/BFS.fs

@@ -113,10 +113,12 @@ type WithoutTransferBenchmark<'elem when 'elem : struct>(
     override this.GlobalSetup() =
         this.ReadMatrix()
         this.LoadMatrixToGPU()
+        this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
     [<IterationCleanup>]
     override this.IterationCleanup() =
         this.ClearResult()
+        this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
     [<GlobalCleanup>]
     override this.GlobalCleanup() =
@@ -180,6 +182,7 @@ type WithTransferBenchmark<'elem when 'elem : struct>(
     [<GlobalSetup>]
     override this.GlobalSetup() =
         this.ReadMatrix()
+        this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
     [<GlobalCleanup>]
     override this.GlobalCleanup() =
@@ -189,6 +192,7 @@ type WithTransferBenchmark<'elem when 'elem : struct>(
     override this.IterationCleanup() =
         this.ClearInputMatrix()
         this.ClearResult()
+        this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
     [<Benchmark>]
     override this.Benchmark() =

benchmarks/GraphBLAS-sharp.Benchmarks/Algorithms/PageRank.fs

@@ -117,10 +117,12 @@ type PageRankWithoutTransferBenchmarkFloat32() =
         this.Processor.PostAndReply(Msg.MsgNotifyMe)
         this.PrepareMatrix()
         this.ClearInputMatrix()
+        this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
     [<IterationCleanup>]
     override this.IterationCleanup() =
         this.ClearResult()
+        this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
     [<GlobalCleanup>]
     override this.GlobalCleanup() =

benchmarks/GraphBLAS-sharp.Benchmarks/Matrix/Map2/Map2.fs

@@ -251,6 +251,7 @@ module WithTransfer =
         [<GlobalSetup>]
         override this.GlobalSetup() =
             this.ReadMatrices()
+            this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
         [<GlobalCleanup>]
         override this.GlobalCleanup() = ()
@@ -259,6 +260,7 @@ module WithTransfer =
         override this.IterationCleanup() =
             this.ClearInputMatrices()
             this.ClearResult()
+            this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
         [<Benchmark>]
         override this.Benchmark() =

benchmarks/GraphBLAS-sharp.Benchmarks/Matrix/SpGeMM/Expand.fs

@@ -115,6 +115,7 @@ module WithoutTransfer =
         override this.GlobalSetup() =
             this.ReadMatrices()
             this.LoadMatricesToGPU()
+            this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
         [<Benchmark>]
         override this.Benchmark() =
@@ -124,6 +125,7 @@ module WithoutTransfer =
         [<IterationCleanup>]
         override this.IterationCleanup () =
             this.ClearResult()
+            this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
         [<GlobalCleanup>]
         override this.GlobalCleanup () =

benchmarks/GraphBLAS-sharp.Benchmarks/Matrix/SpGeMM/Masked.fs

@@ -152,6 +152,7 @@ type MxmBenchmarksMultiplicationOnly<'elem when 'elem : struct>(
         this.ReadMatrices ()
         this.LoadMatricesToGPU ()
         this.ConvertSecondMatrixToCSC()
+        this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
     [<Benchmark>]
     override this.Benchmark () =
@@ -161,6 +162,7 @@ type MxmBenchmarksMultiplicationOnly<'elem when 'elem : struct>(
     [<IterationCleanup>]
     override this.IterationCleanup () =
         this.ClearResult()
+        this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
     [<GlobalCleanup>]
     override this.GlobalCleanup () =
@@ -182,6 +184,7 @@ type MxmBenchmarksWithTransposing<'elem when 'elem : struct>(
     override this.GlobalSetup() =
         this.ReadMatrices()
         this.LoadMatricesToGPU ()
+        this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
     [<Benchmark>]
     override this.Benchmark() =
@@ -194,6 +197,7 @@ type MxmBenchmarksWithTransposing<'elem when 'elem : struct>(
     override this.IterationCleanup() =
         this.ClearResult()
         this.ConvertSecondMatrixToCSR()
+        this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
     [<GlobalCleanup>]
     override this.GlobalCleanup() =

benchmarks/GraphBLAS-sharp.Benchmarks/Vector/Map2.fs

@@ -115,6 +115,7 @@ module WithoutTransfer =
         override this.IterationCleanup() =
             this.ClearResult()
             this.ClearInputVectors()
+            this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
         [<GlobalCleanup>]
         override this.GlobalCleanup() = ()
@@ -159,6 +160,7 @@ module WithTransfer =
         [<IterationSetup>]
         override this.IterationSetup() =
             this.CreateVectors()
+            this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
         [<Benchmark>]
         override this.Benchmark () =
@@ -175,6 +177,7 @@ module WithTransfer =
         override this.IterationCleanup () =
             this.ClearInputVectors()
             this.ClearResult()
+            this.Processor.PostAndReply(Msg.MsgNotifyMe)
 
         [<GlobalCleanup>]
         override this.GlobalCleanup() = ()