diff options
author | galaxycrab <UgnineSirdis@ydb.tech> | 2022-10-26 19:03:15 +0300 |
---|---|---|
committer | galaxycrab <UgnineSirdis@ydb.tech> | 2022-10-26 19:03:15 +0300 |
commit | 608252fc836bcc17fd845053126f1e60bee2f767 (patch) | |
tree | 9e44fb87310b895462aecac3f58fed65518f5f39 /library/cpp/neh | |
parent | 7a8c83ad951880f91a587a3d7c772e05b7e2b61b (diff) | |
download | ydb-608252fc836bcc17fd845053126f1e60bee2f767.tar.gz |
Fix incorrect base class for TEvStateRequest
Diffstat (limited to 'library/cpp/neh')
-rw-r--r-- | library/cpp/neh/http2.cpp | 7 |
1 files changed, 5 insertions, 2 deletions
diff --git a/library/cpp/neh/http2.cpp b/library/cpp/neh/http2.cpp index fb8b08fd81..e4b024d093 100644 --- a/library/cpp/neh/http2.cpp +++ b/library/cpp/neh/http2.cpp @@ -1563,7 +1563,10 @@ namespace { size_t buffPos = 0; //DBGOUT("receive and parse: " << TStringBuf(Buff_.Get(), amount)); while (P_->Parse(Buff_.Get() + buffPos, amount - buffPos)) { - SeenMessageWithoutKeepalive_ |= !P_->IsKeepAlive() || LeftRequestsToDisconnect_ == 1; + if (!P_->IsKeepAlive() || LeftRequestsToDisconnect_ == 1) { + SeenMessageWithoutKeepalive_ = true; + } + char rt = *P_->FirstLine().data(); const size_t extraDataSize = P_->GetExtraDataSize(); if (rt == 'P' || rt == 'p') { @@ -1858,7 +1861,7 @@ namespace { THashMap<TAtomicBase, TResponseDataRef> ResponsesData_; TAtomicBool Canceled_; - bool SeenMessageWithoutKeepalive_ = false; + TAtomicBool SeenMessageWithoutKeepalive_ = false; i32 LeftRequestsToDisconnect_ = -1; }; |