Refactor delay

Author: Илья

slo-workload/src/Commands/RunCommand.php

@@ -213,7 +213,7 @@ protected function readJob(string $endpoint, string $path, $tableName, int $init
                 $table->getLogger()->error($e->getMessage());
                 Utils::metricFail("read", $this->queueId, $attemps, get_class($e), $this->getLatency($begin));
             } finally {
-                $delay = ($begin - microtime(true)) * 1e6 + 1e6 / Defaults::RPS_PER_WRITE_FORK;
+                $delay = $begin * 1e6 + 1e6 / Defaults::RPS_PER_WRITE_FORK - microtime(true);
                 usleep($delay > 0 ? $delay : 1);
             }
         }
@@ -246,7 +246,7 @@ protected function writeJob(string $endpoint, string $path, $tableName, int $ini
                 $table->getLogger()->error($e->getMessage());
                 Utils::metricFail("write", $this->queueId, $attemps, get_class($e), $this->getLatency($begin));
             } finally {
-                $delay = ($begin - microtime(true)) * 1e6 + 1e6 / Defaults::RPS_PER_READ_FORK;
+                $delay = $begin * 1e6 + 1e6 / Defaults::RPS_PER_READ_FORK - microtime(true);
                 usleep($delay > 0 ? $delay : 1);
             }
         }