Use high-precision sleep for throttling

Summary: Makes op delay results more accurate.

Reviewed By: pbhandar2

Differential Revision: D86894250

fbshipit-source-id: dd06225aa894b0c2b3d3eeaa0eac7d98eb4bc8dc

Author: Rob Lyerly

cachelib/cachebench/main.cpp

@@ -23,6 +23,7 @@
 
 #include "cachelib/cachebench/runner/Runner.h"
 #include "cachelib/cachebench/runner/Stressor.h"
+#include "cachelib/cachebench/util/Sleep.h"
 #include "cachelib/common/Utils.h"
 
 #ifdef CACHEBENCH_FB_ENV
@@ -123,6 +124,7 @@ int main(int argc, char** argv) {
   using namespace facebook::cachelib;
   using namespace facebook::cachelib::cachebench;
 
+  calibrateSleep();
 #ifdef CACHEBENCH_FB_ENV
   facebook::initFacebook(&argc, &argv);
   if (!checkArgsValidity()) {

cachelib/cachebench/runner/AsyncCacheStressor.h

@@ -36,6 +36,7 @@
 #include "cachelib/cachebench/util/Exceptions.h"
 #include "cachelib/cachebench/util/Parallel.h"
 #include "cachelib/cachebench/util/Request.h"
+#include "cachelib/cachebench/util/Sleep.h"
 #include "cachelib/cachebench/workload/GeneratorBase.h"
 
 namespace facebook {
@@ -418,7 +419,7 @@ class AsyncCacheStressor : public Stressor {
     auto throttleFn = [&] {
       if (needDelay && ++opCounter == opDelayBatch) {
         opCounter = 0;
-        std::this_thread::sleep_for(opDelay);
+        highPrecisionSleep(opDelay);
       }
       // Limit the rate if specified.
       limitRate();

cachelib/cachebench/runner/CacheStressor.h

@@ -35,6 +35,7 @@
 #include "cachelib/cachebench/util/Exceptions.h"
 #include "cachelib/cachebench/util/Parallel.h"
 #include "cachelib/cachebench/util/Request.h"
+#include "cachelib/cachebench/util/Sleep.h"
 #include "cachelib/cachebench/workload/GeneratorBase.h"
 
 namespace facebook {
@@ -229,7 +230,7 @@ class CacheStressor : public CacheStressorBase {
     auto throttleFn = [&] {
       if (needDelay && ++opCounter == opDelayBatch) {
         opCounter = 0;
-        std::this_thread::sleep_for(opDelay);
+        highPrecisionSleep(opDelay);
       }
       // Limit the rate if specified.
       limitRate();