diff options
author | arcadia-devtools <[email protected]> | 2022-06-01 02:28:37 +0300 |
---|---|---|
committer | arcadia-devtools <[email protected]> | 2022-06-01 02:28:37 +0300 |
commit | 1f8fed0d87db2306d61b41c0dfb7b33ce7417341 (patch) | |
tree | 1e23712360d41fc6dfebbc099933473b2212c69c /library/cpp/actors/http/http_ut.cpp | |
parent | 25a2cfb08f14d8e2368a8e329c90062165ead0da (diff) |
intermediate changes
ref:c234234dab27a004d8ea6b9fa34ee745cc4736a1
Diffstat (limited to 'library/cpp/actors/http/http_ut.cpp')
-rw-r--r-- | library/cpp/actors/http/http_ut.cpp | 13 |
1 files changed, 10 insertions, 3 deletions
diff --git a/library/cpp/actors/http/http_ut.cpp b/library/cpp/actors/http/http_ut.cpp index ad3b49e869f..7a569a08c36 100644 --- a/library/cpp/actors/http/http_ut.cpp +++ b/library/cpp/actors/http/http_ut.cpp @@ -102,9 +102,16 @@ Y_UNIT_TEST_SUITE(HttpProxy) { NHttp::THttpOutgoingResponsePtr response = new NHttp::THttpOutgoingResponse(request, "HTTP", "1.1", "200", "OK"); TString compressedBody = "something very long to compress with deflate algorithm. something very long to compress with deflate algorithm."; response->EnableCompression(); + size_t size1 = response->Size(); response->SetBody(compressedBody); + size_t size2 = response->Size(); + size_t compressedBodySize = size2 - size1; UNIT_ASSERT_VALUES_EQUAL("deflate", response->ContentEncoding); - UNIT_ASSERT_VALUES_UNEQUAL(compressedBody, response->Body); + UNIT_ASSERT(compressedBodySize < compressedBody.size()); + NHttp::THttpOutgoingResponsePtr response2 = response->Duplicate(request); + UNIT_ASSERT_VALUES_EQUAL(response->Body, response2->Body); + UNIT_ASSERT_VALUES_EQUAL(response->ContentLength, response2->ContentLength); + UNIT_ASSERT_VALUES_EQUAL(response->Size(), response2->Size()); } Y_UNIT_TEST(BasicPartialParsing) { @@ -192,7 +199,7 @@ Y_UNIT_TEST_SUITE(HttpProxy) { TIpPort port = portManager.GetTcpPort(); TAutoPtr<NActors::IEventHandle> handle; actorSystem.Initialize(); - actorSystem.SetLogPriority(NActorsServices::HTTP, NActors::NLog::PRI_DEBUG); + //actorSystem.SetLogPriority(NActorsServices::HTTP, NActors::NLog::PRI_DEBUG); NActors::IActor* proxy = NHttp::CreateHttpProxy(); NActors::TActorId proxyId = actorSystem.Register(proxy); @@ -225,7 +232,7 @@ Y_UNIT_TEST_SUITE(HttpProxy) { TIpPort port = portManager.GetTcpPort(); TAutoPtr<NActors::IEventHandle> handle; actorSystem.Initialize(); - actorSystem.SetLogPriority(NActorsServices::HTTP, NActors::NLog::PRI_DEBUG); + //actorSystem.SetLogPriority(NActorsServices::HTTP, NActors::NLog::PRI_DEBUG); NActors::IActor* proxy = NHttp::CreateHttpProxy(); NActors::TActorId proxyId = actorSystem.Register(proxy); |