Calculate seconds and initialize interval with it

prooph · Apr 30, 2018 · 5e74bde · 5e74bde
1 parent b49ef28
commit 5e74bde
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/src/Projection/PdoEventStoreProjector.php b/src/Projection/PdoEventStoreProjector.php
@@ -955,10 +955,12 @@ private function shouldUpdateLock(DateTimeImmutable $now): bool
             return true;
         }
 
+        $intervalSeconds = floor($this->updateLockThreshold / 1000);
+
         //Create a 0 interval
-        $updateLockThreshold = new \DateInterval('PT0S');
+        $updateLockThreshold = new \DateInterval("PT{$intervalSeconds}S");
         //and manually add split seconds
-        $updateLockThreshold->f = $this->updateLockThreshold / 1000;
+        $updateLockThreshold->f = ($this->updateLockThreshold % 1000) / 1000;
 
         $threshold = $this->lastLockUpdate->add($updateLockThreshold);
 

diff --git a/src/Projection/PdoEventStoreReadModelProjector.php b/src/Projection/PdoEventStoreReadModelProjector.php
@@ -902,10 +902,12 @@ private function shouldUpdateLock(DateTimeImmutable $now): bool
             return true;
         }
 
+        $intervalSeconds = floor($this->updateLockThreshold / 1000);
+
         //Create a 0 interval
-        $updateLockThreshold = new \DateInterval('PT0S');
+        $updateLockThreshold = new \DateInterval("PT{$intervalSeconds}S");
         //and manually add split seconds
-        $updateLockThreshold->f = $this->updateLockThreshold / 1000;
+        $updateLockThreshold->f = ($this->updateLockThreshold % 1000) / 1000;
 
         $threshold = $this->lastLockUpdate->add($updateLockThreshold);