aboutsummaryrefslogtreecommitdiffstats
path: root/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-s3/source/model/SelectObjectContentHandler.cpp
diff options
context:
space:
mode:
authororivej <orivej@yandex-team.ru>2022-02-10 16:45:01 +0300
committerDaniil Cherednik <dcherednik@yandex-team.ru>2022-02-10 16:45:01 +0300
commit2d37894b1b037cf24231090eda8589bbb44fb6fc (patch)
treebe835aa92c6248212e705f25388ebafcf84bc7a1 /contrib/libs/aws-sdk-cpp/aws-cpp-sdk-s3/source/model/SelectObjectContentHandler.cpp
parent718c552901d703c502ccbefdfc3c9028d608b947 (diff)
downloadydb-2d37894b1b037cf24231090eda8589bbb44fb6fc.tar.gz
Restoring authorship annotation for <orivej@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'contrib/libs/aws-sdk-cpp/aws-cpp-sdk-s3/source/model/SelectObjectContentHandler.cpp')
-rw-r--r--contrib/libs/aws-sdk-cpp/aws-cpp-sdk-s3/source/model/SelectObjectContentHandler.cpp88
1 files changed, 44 insertions, 44 deletions
diff --git a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-s3/source/model/SelectObjectContentHandler.cpp b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-s3/source/model/SelectObjectContentHandler.cpp
index 136e7ceffa..a4e8756d27 100644
--- a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-s3/source/model/SelectObjectContentHandler.cpp
+++ b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-s3/source/model/SelectObjectContentHandler.cpp
@@ -1,7 +1,7 @@
-/**
- * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
- * SPDX-License-Identifier: Apache-2.0.
- */
+/**
+ * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
+ * SPDX-License-Identifier: Apache-2.0.
+ */
#include <aws/s3/model/SelectObjectContentHandler.h>
#include <aws/s3/S3ErrorMarshaller.h>
@@ -26,7 +26,7 @@ namespace Model
SelectObjectContentHandler::SelectObjectContentHandler() : EventStreamHandler()
{
- m_onRecordsEvent = [&](const RecordsEvent&)
+ m_onRecordsEvent = [&](const RecordsEvent&)
{
AWS_LOGSTREAM_TRACE(SELECTOBJECTCONTENT_HANDLER_CLASS_TAG, "RecordsEvent received.");
};
@@ -68,7 +68,7 @@ namespace Model
return;
}
- const auto& headers = GetEventHeaders();
+ const auto& headers = GetEventHeaders();
auto messageTypeHeaderIter = headers.find(MESSAGE_TYPE_HEADER);
if (messageTypeHeaderIter == headers.end())
{
@@ -76,13 +76,13 @@ namespace Model
return;
}
- switch (Aws::Utils::Event::Message::GetMessageTypeForName(messageTypeHeaderIter->second.GetEventHeaderValueAsString()))
+ switch (Aws::Utils::Event::Message::GetMessageTypeForName(messageTypeHeaderIter->second.GetEventHeaderValueAsString()))
{
- case Aws::Utils::Event::Message::MessageType::EVENT:
+ case Aws::Utils::Event::Message::MessageType::EVENT:
HandleEventInMessage();
break;
- case Aws::Utils::Event::Message::MessageType::REQUEST_LEVEL_ERROR:
- case Aws::Utils::Event::Message::MessageType::REQUEST_LEVEL_EXCEPTION:
+ case Aws::Utils::Event::Message::MessageType::REQUEST_LEVEL_ERROR:
+ case Aws::Utils::Event::Message::MessageType::REQUEST_LEVEL_EXCEPTION:
{
HandleErrorInMessage();
break;
@@ -96,7 +96,7 @@ namespace Model
void SelectObjectContentHandler::HandleEventInMessage()
{
- const auto& headers = GetEventHeaders();
+ const auto& headers = GetEventHeaders();
auto eventTypeHeaderIter = headers.find(EVENT_TYPE_HEADER);
if (eventTypeHeaderIter == headers.end())
{
@@ -136,57 +136,57 @@ namespace Model
break;
}
case SelectObjectContentEventType::CONT:
- {
+ {
m_onContinuationEvent();
break;
- }
+ }
case SelectObjectContentEventType::END:
- {
+ {
m_onEndEvent();
break;
- }
+ }
default:
AWS_LOGSTREAM_WARN(SELECTOBJECTCONTENT_HANDLER_CLASS_TAG,
- "Unexpected event type: " << eventTypeHeaderIter->second.GetEventHeaderValueAsString());
+ "Unexpected event type: " << eventTypeHeaderIter->second.GetEventHeaderValueAsString());
break;
}
}
void SelectObjectContentHandler::HandleErrorInMessage()
{
- const auto& headers = GetEventHeaders();
- Aws::String errorCode;
- Aws::String errorMessage;
- auto errorHeaderIter = headers.find(ERROR_CODE_HEADER);
- if (errorHeaderIter == headers.end())
+ const auto& headers = GetEventHeaders();
+ Aws::String errorCode;
+ Aws::String errorMessage;
+ auto errorHeaderIter = headers.find(ERROR_CODE_HEADER);
+ if (errorHeaderIter == headers.end())
{
- errorHeaderIter = headers.find(EXCEPTION_TYPE_HEADER);
- if (errorHeaderIter == headers.end())
- {
- AWS_LOGSTREAM_WARN(SELECTOBJECTCONTENT_HANDLER_CLASS_TAG,
- "Error type was not found in the event message.");
- return;
- }
+ errorHeaderIter = headers.find(EXCEPTION_TYPE_HEADER);
+ if (errorHeaderIter == headers.end())
+ {
+ AWS_LOGSTREAM_WARN(SELECTOBJECTCONTENT_HANDLER_CLASS_TAG,
+ "Error type was not found in the event message.");
+ return;
+ }
}
-
- errorCode = errorHeaderIter->second.GetEventHeaderValueAsString();
- errorHeaderIter = headers.find(ERROR_MESSAGE_HEADER);
- if (errorHeaderIter == headers.end())
+
+ errorCode = errorHeaderIter->second.GetEventHeaderValueAsString();
+ errorHeaderIter = headers.find(ERROR_MESSAGE_HEADER);
+ if (errorHeaderIter == headers.end())
{
- errorHeaderIter = headers.find(EXCEPTION_TYPE_HEADER);
- if (errorHeaderIter == headers.end())
- {
- AWS_LOGSTREAM_WARN(SELECTOBJECTCONTENT_HANDLER_CLASS_TAG,
- "Error description was not found in the event message.");
- return;
- }
+ errorHeaderIter = headers.find(EXCEPTION_TYPE_HEADER);
+ if (errorHeaderIter == headers.end())
+ {
+ AWS_LOGSTREAM_WARN(SELECTOBJECTCONTENT_HANDLER_CLASS_TAG,
+ "Error description was not found in the event message.");
+ return;
+ }
}
- errorMessage = errorHeaderIter->second.GetEventHeaderValueAsString();
- MarshallError(errorCode, errorMessage);
- }
+ errorMessage = errorHeaderIter->second.GetEventHeaderValueAsString();
+ MarshallError(errorCode, errorMessage);
+ }
- void SelectObjectContentHandler::MarshallError(const Aws::String& errorCode, const Aws::String& errorMessage)
- {
+ void SelectObjectContentHandler::MarshallError(const Aws::String& errorCode, const Aws::String& errorMessage)
+ {
S3ErrorMarshaller errorMarshaller;
AWSError<CoreErrors> error;