Add used memory to output

prooph · Jul 26, 2020 · 0be21e3 · 0be21e3
1 parent 259cf3f
commit 0be21e3
Show file tree

Hide file tree

Showing 5 changed files with 12 additions and 3 deletions.
diff --git a/src/AllProjector.php b/src/AllProjector.php
@@ -66,7 +66,7 @@ public function run()
             $avg = $this->stopAt / $time;
 
             outputText("Projection $this->id read $readEvents events");
-            outputText("Projection $this->id used $time seconds, avg $avg events/second");
+            outputText("Projection $this->id used $time seconds, avg $avg events/second " . getMemoryConsumption());
             outputText("Projection $this->id checking integrity ...", true, '');
             Assertion::eq($readEvents, $stopAt, 'Number of all projected events invalid: Value "%s" does not equal expected value "%s".');
             outputText(" ok\n", false);

diff --git a/src/CategoryProjector.php b/src/CategoryProjector.php
@@ -70,7 +70,7 @@ public function run()
             $avg = $this->stopAt / $time;
 
             outputText("Projection $this->id read $readEvents events");
-            outputText("Projection $this->id used $time seconds, avg $avg events/second");
+            outputText("Projection $this->id used $time seconds, avg $avg events/second " . getMemoryConsumption());
             outputText("Projection $this->id checking integrity ...", true, '');
             Assertion::eq($readEvents, 2500, 'Number of category projected events invalid: Value "%s" does not equal expected value "%s".');
             outputText(" ok\n", false);

diff --git a/src/StreamCreator.php b/src/StreamCreator.php
@@ -73,7 +73,7 @@ public function run()
             $avg = ($this->executions * $this->numberOfEvents) / $time;
 
             outputText("Writer $this->id-$this->category wrote $this->eventsWritten events");
-            outputText("Writer $this->id-$this->category used $time seconds, avg $avg events/second");
+            outputText("Writer $this->id-$this->category used $time seconds, avg $avg events/second " . getMemoryConsumption());
             outputText("Writer $this->id checking integrity ...", true, '');
             Assertion::eq($count, $this->numberOfEvents * $this->executions, 'Number of writer events invalid: Value "%s" does not equal expected value "%s".');
             outputText(" ok\n", false);

diff --git a/src/benchmark.php b/src/benchmark.php
@@ -252,4 +252,5 @@
     outputText('test 6 checking integrity ...', true, '');
     Assertion::eq($projection->getState()['count'], 1000, 'Number of projected events invalid: Value "%s" does not equal expected value "%s".');
     outputText(" ok\n", false);
+    outputText( "Mem usage/peak: " . getMemoryConsumption() . PHP_EOL, false);
 }
diff --git a/src/functions.php b/src/functions.php
@@ -400,3 +400,11 @@ function getStreamHandlerFactory(): StreamHandlerFactoryInterface
 {
     return new ArrayStreamHandlerFactory();
 }
+
+function getMemoryConsumption(): string
+{
+    $memUsage = memory_get_usage();
+    $memPeak = memory_get_peak_usage();
+
+    return '(' . round($memUsage / 1024 / 1024, 2) . 'MB / ' . round($memPeak / 1024 / 1024, 2) . ' MB)';
+}