aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/http
diff options
context:
space:
mode:
authoreeight <eeight@yandex-team.ru>2022-02-10 16:46:19 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:46:19 +0300
commitbd085aee9b4f7a0bee302ce687964ffb7098f986 (patch)
tree1a2c5ffcf89eb53ecd79dbc9bc0a195c27404d0c /library/cpp/http
parent475c0a46f28166e83fd263badc7546377cddcabe (diff)
downloadydb-bd085aee9b4f7a0bee302ce687964ffb7098f986.tar.gz
Restoring authorship annotation for <eeight@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'library/cpp/http')
-rw-r--r--library/cpp/http/io/compression.h4
-rw-r--r--library/cpp/http/misc/parsed_request.cpp2
-rw-r--r--library/cpp/http/server/http.cpp2
-rw-r--r--library/cpp/http/server/http.h6
-rw-r--r--library/cpp/http/server/http_ut.cpp20
-rw-r--r--library/cpp/http/server/response.cpp2
6 files changed, 18 insertions, 18 deletions
diff --git a/library/cpp/http/io/compression.h b/library/cpp/http/io/compression.h
index 3287c6f34c..f16c4a18eb 100644
--- a/library/cpp/http/io/compression.h
+++ b/library/cpp/http/io/compression.h
@@ -2,7 +2,7 @@
#include "stream.h"
-#include <util/generic/deque.h>
+#include <util/generic/deque.h>
#include <util/generic/hash.h>
class TCompressionCodecFactory {
@@ -44,7 +44,7 @@ private:
TEncoderConstructor Encoder;
};
- TDeque<TString> Strings_;
+ TDeque<TString> Strings_;
THashMap<TStringBuf, TCodec> Codecs_;
TVector<TStringBuf> BestCodecs_;
};
diff --git a/library/cpp/http/misc/parsed_request.cpp b/library/cpp/http/misc/parsed_request.cpp
index 7f322ce0ea..e332a24e91 100644
--- a/library/cpp/http/misc/parsed_request.cpp
+++ b/library/cpp/http/misc/parsed_request.cpp
@@ -2,7 +2,7 @@
#include <util/string/strip.h>
#include <util/generic/yexception.h>
-#include <util/string/cast.h>
+#include <util/string/cast.h>
static inline TStringBuf StripLeft(const TStringBuf& s) noexcept {
const char* b = s.begin();
diff --git a/library/cpp/http/server/http.cpp b/library/cpp/http/server/http.cpp
index 48498e6b8b..128583bdd7 100644
--- a/library/cpp/http/server/http.cpp
+++ b/library/cpp/http/server/http.cpp
@@ -17,7 +17,7 @@
#include <util/system/mutex.h>
#include <util/system/pipe.h>
#include <util/system/thread.h>
-#include <util/thread/factory.h>
+#include <util/thread/factory.h>
#include <cerrno>
#include <cstring>
diff --git a/library/cpp/http/server/http.h b/library/cpp/http/server/http.h
index 517fcf9eb2..b292d38f27 100644
--- a/library/cpp/http/server/http.h
+++ b/library/cpp/http/server/http.h
@@ -3,14 +3,14 @@
#include "conn.h"
#include "options.h"
-#include <util/thread/pool.h>
+#include <util/thread/pool.h>
#include <library/cpp/http/io/stream.h>
#include <util/memory/blob.h>
#include <util/generic/ptr.h>
#include <util/generic/vector.h>
#include <util/system/atomic.h>
-class IThreadFactory;
+class IThreadFactory;
class TClientRequest;
class TClientConnection;
@@ -62,7 +62,7 @@ public:
};
typedef THttpServerOptions TOptions;
- typedef TSimpleSharedPtr<IThreadPool> TMtpQueueRef;
+ typedef TSimpleSharedPtr<IThreadPool> TMtpQueueRef;
THttpServer(ICallBack* cb, const TOptions& options = TOptions(), IThreadFactory* pool = nullptr);
THttpServer(ICallBack* cb, TMtpQueueRef mainWorkers, TMtpQueueRef failWorkers, const TOptions& options = TOptions());
diff --git a/library/cpp/http/server/http_ut.cpp b/library/cpp/http/server/http_ut.cpp
index 1199007496..cc62bb988e 100644
--- a/library/cpp/http/server/http_ut.cpp
+++ b/library/cpp/http/server/http_ut.cpp
@@ -289,7 +289,7 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
bool Expect100Continue = false;
};
- class TFailingMtpQueue: public TSimpleThreadPool {
+ class TFailingMtpQueue: public TSimpleThreadPool {
private:
bool FailOnAdd_ = false;
@@ -297,16 +297,16 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
void SetFailOnAdd(bool fail = true) {
FailOnAdd_ = fail;
}
- [[nodiscard]] bool Add(IObjectInQueue* pObj) override {
+ [[nodiscard]] bool Add(IObjectInQueue* pObj) override {
if (FailOnAdd_) {
return false;
}
- return TSimpleThreadPool::Add(pObj);
+ return TSimpleThreadPool::Add(pObj);
}
TFailingMtpQueue() = default;
- TFailingMtpQueue(IThreadFactory* pool)
- : TSimpleThreadPool(pool)
+ TFailingMtpQueue(IThreadFactory* pool)
+ : TSimpleThreadPool(pool)
{
}
};
@@ -434,9 +434,9 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
THttpServer::TOptions options(port);
options.EnableKeepAlive(true);
options.EnableCompression(true);
- using TFailingServerMtpQueue = TThreadPoolBinder<TFailingMtpQueue, THttpServer::ICallBack>;
- THttpServer::TMtpQueueRef mainWorkers = new TFailingServerMtpQueue(&serverImpl, SystemThreadFactory());
- THttpServer::TMtpQueueRef failWorkers = new TThreadPool(SystemThreadFactory());
+ using TFailingServerMtpQueue = TThreadPoolBinder<TFailingMtpQueue, THttpServer::ICallBack>;
+ THttpServer::TMtpQueueRef mainWorkers = new TFailingServerMtpQueue(&serverImpl, SystemThreadFactory());
+ THttpServer::TMtpQueueRef failWorkers = new TThreadPool(SystemThreadFactory());
THttpServer server(&serverImpl, mainWorkers, failWorkers, options);
UNIT_ASSERT(server.Start());
@@ -703,7 +703,7 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
for (bool keepAlive : trueFalse) {
server.ResetCounters();
- TVector<TAutoPtr<IThreadFactory::IThread>> threads;
+ TVector<TAutoPtr<IThreadFactory::IThread>> threads;
server.Busy(3);
server.BusyThread();
@@ -715,7 +715,7 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
r->KeepAliveConnection = keepAlive;
r->Execute();
};
- threads.push_back(SystemThreadFactory()->Run(func));
+ threads.push_back(SystemThreadFactory()->Run(func));
}
server.FreeThread(); // all threads get connection & go to processing
diff --git a/library/cpp/http/server/response.cpp b/library/cpp/http/server/response.cpp
index b94a2f4482..52d64c91ce 100644
--- a/library/cpp/http/server/response.cpp
+++ b/library/cpp/http/server/response.cpp
@@ -2,7 +2,7 @@
#include <util/stream/output.h>
#include <util/stream/mem.h>
-#include <util/string/cast.h>
+#include <util/string/cast.h>
THttpResponse& THttpResponse::AddMultipleHeaders(const THttpHeaders& headers) {
for (THttpHeaders::TConstIterator i = headers.Begin(); i != headers.End(); ++i) {