validate canons without yatest_common

1 files changed, 37 insertions, 0 deletions

diff --git a/library/cpp/http/client/scheduler.cpp b/library/cpp/http/client/scheduler.cpp
new file mode 100644
index 0000000000..87670bfb45
--- /dev/null
+++ b/library/cpp/http/client/scheduler.cpp
@@ -0,0 +1,37 @@
+#include "scheduler.h"
+
+namespace NHttp {
+    namespace {
+        class TDefaultHostsPolicy: public IHostsPolicy {
+        public:
+            size_t GetMaxHostConnections(const TStringBuf&) const override {
+                return 20;
+            }
+        };
+
+    }
+
+    TScheduler::TScheduler()
+        : HostsPolicy_(new TDefaultHostsPolicy)
+    {
+    }
+
+    TFetchRequestRef TScheduler::Extract() {
+        {
+            auto g(Guard(Lock_));
+
+            if (!RequestQueue_.empty()) {
+                TFetchRequestRef result(RequestQueue_.front());
+                RequestQueue_.pop();
+                return result;
+            }
+        }
+        return TFetchRequestRef();
+    }
+
+    void TScheduler::Schedule(TFetchRequestRef req) {
+        auto g(Guard(Lock_));
+        RequestQueue_.push(req);
+    }
+
+}