aboutsummaryrefslogtreecommitdiffstats
path: root/library/cpp/http/server/http_ut.cpp
diff options
context:
space:
mode:
authoratayan1 <atayan1@yandex-team.ru>2022-02-10 16:49:38 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:49:38 +0300
commitc711d9aae73052830cd54065a75b3e3739893aba (patch)
treecef06878f1e78cd17308827f661e7bd19bd96d49 /library/cpp/http/server/http_ut.cpp
parent5ab412f19b9312abbfa362391df45d6603bb84c3 (diff)
downloadydb-c711d9aae73052830cd54065a75b3e3739893aba.tar.gz
Restoring authorship annotation for <atayan1@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'library/cpp/http/server/http_ut.cpp')
-rw-r--r--library/cpp/http/server/http_ut.cpp86
1 files changed, 43 insertions, 43 deletions
diff --git a/library/cpp/http/server/http_ut.cpp b/library/cpp/http/server/http_ut.cpp
index cc62bb988e..61bf44a7ed 100644
--- a/library/cpp/http/server/http_ut.cpp
+++ b/library/cpp/http/server/http_ut.cpp
@@ -507,25 +507,25 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
TString ExceptionMessage;
};
- class TListenerSockAddrReplyServer: public THttpServer::ICallBack {
- class TRequest: public TClientRequest {
- public:
- bool Reply(void* /*tsr*/) override {
- Output() << "HTTP/1.1 200 Ok\r\n\r\n";
- Output() << PrintHostAndPort(*GetListenerSockAddrRef());
-
- Output().Finish();
-
- return true;
- }
- };
-
- public:
- TClientRequest* CreateClient() override {
- return new TRequest();
- }
- };
-
+ class TListenerSockAddrReplyServer: public THttpServer::ICallBack {
+ class TRequest: public TClientRequest {
+ public:
+ bool Reply(void* /*tsr*/) override {
+ Output() << "HTTP/1.1 200 Ok\r\n\r\n";
+ Output() << PrintHostAndPort(*GetListenerSockAddrRef());
+
+ Output().Finish();
+
+ return true;
+ }
+ };
+
+ public:
+ TClientRequest* CreateClient() override {
+ return new TRequest();
+ }
+ };
+
Y_UNIT_TEST(TTestResetConnection) {
TPortManager pm;
const ui16 port = pm.GetPort();
@@ -660,30 +660,30 @@ Y_UNIT_TEST_SUITE(THttpServerTest) {
server.Stop();
}
- Y_UNIT_TEST(TTestListenerSockAddrConnection) {
- TPortManager pm;
- const ui16 port1 = pm.GetPort();
- const ui16 port2 = pm.GetPort();
-
- TListenerSockAddrReplyServer serverImpl;
- THttpServer server(&serverImpl, THttpServer::TOptions().EnableKeepAlive(true).AddBindAddress("127.0.0.1", port1).AddBindAddress("127.0.0.1", port2));
- UNIT_ASSERT(server.Start());
-
- TTestRequest r1(port1);
- r1.KeepAliveConnection = true;
-
- TString resp = r1.Execute();
- UNIT_ASSERT(resp == TString::Join("127.0.0.1", ":", ToString(port1)));
-
- TTestRequest r2(port2);
- r2.KeepAliveConnection = true;
-
- resp = r2.Execute();
- UNIT_ASSERT(resp == TString::Join("127.0.0.1", ":", ToString(port2)));
-
- server.Stop();
- };
-
+ Y_UNIT_TEST(TTestListenerSockAddrConnection) {
+ TPortManager pm;
+ const ui16 port1 = pm.GetPort();
+ const ui16 port2 = pm.GetPort();
+
+ TListenerSockAddrReplyServer serverImpl;
+ THttpServer server(&serverImpl, THttpServer::TOptions().EnableKeepAlive(true).AddBindAddress("127.0.0.1", port1).AddBindAddress("127.0.0.1", port2));
+ UNIT_ASSERT(server.Start());
+
+ TTestRequest r1(port1);
+ r1.KeepAliveConnection = true;
+
+ TString resp = r1.Execute();
+ UNIT_ASSERT(resp == TString::Join("127.0.0.1", ":", ToString(port1)));
+
+ TTestRequest r2(port2);
+ r2.KeepAliveConnection = true;
+
+ resp = r2.Execute();
+ UNIT_ASSERT(resp == TString::Join("127.0.0.1", ":", ToString(port2)));
+
+ server.Stop();
+ };
+
#if 0
Y_UNIT_TEST(TestSocketsLeak) {
const bool trueFalse[] = {true, false};