diff options
author | orivej <orivej@yandex-team.ru> | 2022-02-10 16:44:49 +0300 |
---|---|---|
committer | Daniil Cherednik <dcherednik@yandex-team.ru> | 2022-02-10 16:44:49 +0300 |
commit | 718c552901d703c502ccbefdfc3c9028d608b947 (patch) | |
tree | 46534a98bbefcd7b1f3faa5b52c138ab27db75b7 /contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event | |
parent | e9656aae26e0358d5378e5b63dcac5c8dbe0e4d0 (diff) | |
download | ydb-718c552901d703c502ccbefdfc3c9028d608b947.tar.gz |
Restoring authorship annotation for <orivej@yandex-team.ru>. Commit 1 of 2.
Diffstat (limited to 'contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event')
8 files changed, 147 insertions, 147 deletions
diff --git a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventDecoderStream.cpp b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventDecoderStream.cpp index 5ecd2d0444..16fc5e69d6 100644 --- a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventDecoderStream.cpp +++ b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventDecoderStream.cpp @@ -1,22 +1,22 @@ -/** - * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. - * SPDX-License-Identifier: Apache-2.0. - */ -#include <aws/core/utils/event/EventDecoderStream.h> -#include <iostream> - -namespace Aws -{ - namespace Utils - { - namespace Event - { - EventDecoderStream::EventDecoderStream(EventStreamDecoder& decoder, size_t bufferSize) : - Aws::IOStream(&m_eventStreamBuf), - m_eventStreamBuf(decoder, bufferSize) - - { - } - } - } -} +/** + * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. + * SPDX-License-Identifier: Apache-2.0. + */ +#include <aws/core/utils/event/EventDecoderStream.h> +#include <iostream> + +namespace Aws +{ + namespace Utils + { + namespace Event + { + EventDecoderStream::EventDecoderStream(EventStreamDecoder& decoder, size_t bufferSize) : + Aws::IOStream(&m_eventStreamBuf), + m_eventStreamBuf(decoder, bufferSize) + + { + } + } + } +} diff --git a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventEncoderStream.cpp b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventEncoderStream.cpp index f8640f0e8c..08b791ed56 100644 --- a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventEncoderStream.cpp +++ b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventEncoderStream.cpp @@ -1,28 +1,28 @@ -/** - * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. - * SPDX-License-Identifier: Apache-2.0. - */ -#include <aws/core/utils/event/EventEncoderStream.h> -#include <iostream> - -namespace Aws -{ - namespace Utils - { - namespace Event - { - EventEncoderStream::EventEncoderStream(size_t bufferSize) : - Aws::IOStream(&m_streambuf), - m_streambuf(bufferSize) - { - } - - EventEncoderStream& EventEncoderStream::WriteEvent(const Aws::Utils::Event::Message& msg) - { - auto bits = m_encoder.EncodeAndSign(msg); - write(reinterpret_cast<char*>(bits.data()), bits.size()); - return *this; - } - } - } -} +/** + * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved. + * SPDX-License-Identifier: Apache-2.0. + */ +#include <aws/core/utils/event/EventEncoderStream.h> +#include <iostream> + +namespace Aws +{ + namespace Utils + { + namespace Event + { + EventEncoderStream::EventEncoderStream(size_t bufferSize) : + Aws::IOStream(&m_streambuf), + m_streambuf(bufferSize) + { + } + + EventEncoderStream& EventEncoderStream::WriteEvent(const Aws::Utils::Event::Message& msg) + { + auto bits = m_encoder.EncodeAndSign(msg); + write(reinterpret_cast<char*>(bits.data()), bits.size()); + return *this; + } + } + } +} diff --git a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventHeader.cpp b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventHeader.cpp index c3c989bedb..b79dd2b4a5 100644 --- a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventHeader.cpp +++ b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventHeader.cpp @@ -1,6 +1,6 @@ -/** - * 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/core/utils/event/EventHeader.h> diff --git a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventMessage.cpp b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventMessage.cpp index de8b904775..ed21d7d7d6 100644 --- a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventMessage.cpp +++ b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventMessage.cpp @@ -1,6 +1,6 @@ -/** - * 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/core/utils/event/EventMessage.h> @@ -19,16 +19,16 @@ namespace Aws const char MESSAGE_TYPE_HEADER[] = ":message-type"; const char ERROR_CODE_HEADER[] = ":error-code"; const char ERROR_MESSAGE_HEADER[] = ":error-message"; - const char EXCEPTION_TYPE_HEADER[] = ":exception-type"; + const char EXCEPTION_TYPE_HEADER[] = ":exception-type"; static const int EVENT_HASH = HashingUtils::HashString("event"); static const int ERROR_HASH = HashingUtils::HashString("error"); - static const int EXCEPTION_HASH = HashingUtils::HashString("exception"); - - static const int CONTENT_TYPE_APPLICATION_OCTET_STREAM_HASH = HashingUtils::HashString("application/octet-stream"); - static const int CONTENT_TYPE_APPLICATION_JSON_HASH = HashingUtils::HashString("application/json"); - static const int CONTENT_TYPE_TEXT_PLAIN_HASH = HashingUtils::HashString("text/plain"); + static const int EXCEPTION_HASH = HashingUtils::HashString("exception"); + static const int CONTENT_TYPE_APPLICATION_OCTET_STREAM_HASH = HashingUtils::HashString("application/octet-stream"); + static const int CONTENT_TYPE_APPLICATION_JSON_HASH = HashingUtils::HashString("application/json"); + static const int CONTENT_TYPE_TEXT_PLAIN_HASH = HashingUtils::HashString("text/plain"); + Message::MessageType Message::GetMessageTypeForName(const Aws::String& name) { int hashCode = Aws::Utils::HashingUtils::HashString(name.c_str()); @@ -40,10 +40,10 @@ namespace Aws { return MessageType::REQUEST_LEVEL_ERROR; } - else if (hashCode == EXCEPTION_HASH) - { - return MessageType::REQUEST_LEVEL_EXCEPTION; - } + else if (hashCode == EXCEPTION_HASH) + { + return MessageType::REQUEST_LEVEL_EXCEPTION; + } else { return MessageType::UNKNOWN; @@ -58,49 +58,49 @@ namespace Aws return "event"; case MessageType::REQUEST_LEVEL_ERROR: return "error"; - case MessageType::REQUEST_LEVEL_EXCEPTION: - return "exception"; - default: - return "unknown"; - } - } - - Message::ContentType Message::GetContentTypeForName(const Aws::String& name) - { - int hashCode = Aws::Utils::HashingUtils::HashString(name.c_str()); - if (hashCode == CONTENT_TYPE_APPLICATION_OCTET_STREAM_HASH) - { - return ContentType::APPLICATION_OCTET_STREAM; - } - else if (hashCode == CONTENT_TYPE_APPLICATION_JSON_HASH) - { - return ContentType::APPLICATION_JSON; - } - else if (hashCode == CONTENT_TYPE_TEXT_PLAIN_HASH) - { - return ContentType::TEXT_PLAIN; - } - else - { - return ContentType::UNKNOWN; - } - } - - Aws::String Message::GetNameForContentType(ContentType value) - { - switch (value) - { - case ContentType::APPLICATION_OCTET_STREAM: - return "application/octet-stream"; - case ContentType::APPLICATION_JSON: - return "application/json"; - case ContentType::TEXT_PLAIN: - return "text/plain"; + case MessageType::REQUEST_LEVEL_EXCEPTION: + return "exception"; default: return "unknown"; } } + Message::ContentType Message::GetContentTypeForName(const Aws::String& name) + { + int hashCode = Aws::Utils::HashingUtils::HashString(name.c_str()); + if (hashCode == CONTENT_TYPE_APPLICATION_OCTET_STREAM_HASH) + { + return ContentType::APPLICATION_OCTET_STREAM; + } + else if (hashCode == CONTENT_TYPE_APPLICATION_JSON_HASH) + { + return ContentType::APPLICATION_JSON; + } + else if (hashCode == CONTENT_TYPE_TEXT_PLAIN_HASH) + { + return ContentType::TEXT_PLAIN; + } + else + { + return ContentType::UNKNOWN; + } + } + + Aws::String Message::GetNameForContentType(ContentType value) + { + switch (value) + { + case ContentType::APPLICATION_OCTET_STREAM: + return "application/octet-stream"; + case ContentType::APPLICATION_JSON: + return "application/json"; + case ContentType::TEXT_PLAIN: + return "text/plain"; + default: + return "unknown"; + } + } + void Message::Reset() { m_totalLength = 0; @@ -111,21 +111,21 @@ namespace Aws m_eventPayload.clear(); } - void Message::WriteEventPayload(const unsigned char* data, size_t length) - { - std::copy(data, data + length, std::back_inserter(m_eventPayload)); - } - + void Message::WriteEventPayload(const unsigned char* data, size_t length) + { + std::copy(data, data + length, std::back_inserter(m_eventPayload)); + } + void Message::WriteEventPayload(const Aws::Vector<unsigned char>& bits) { std::copy(bits.cbegin(), bits.cend(), std::back_inserter(m_eventPayload)); } - void Message::WriteEventPayload(const Aws::String& bits) - { - std::copy(bits.cbegin(), bits.cend(), std::back_inserter(m_eventPayload)); - } - + void Message::WriteEventPayload(const Aws::String& bits) + { + std::copy(bits.cbegin(), bits.cend(), std::back_inserter(m_eventPayload)); + } + } // namespace Event } // namespace Utils } // namespace Aws diff --git a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamBuf.cpp b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamBuf.cpp index 6a1766bb9f..4c52368e07 100644 --- a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamBuf.cpp +++ b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamBuf.cpp @@ -1,6 +1,6 @@ -/** - * 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/core/utils/event/EventStreamBuf.h> #include <cassert> @@ -11,8 +11,8 @@ namespace Aws { namespace Event { - const size_t DEFAULT_BUF_SIZE = 1024; - + const size_t DEFAULT_BUF_SIZE = 1024; + EventStreamBuf::EventStreamBuf(EventStreamDecoder& decoder, size_t bufferLength) : m_byteBuffer(bufferLength), m_bufferLength(bufferLength), diff --git a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamDecoder.cpp b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamDecoder.cpp index f70a6c88f6..d0474f77eb 100644 --- a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamDecoder.cpp +++ b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamDecoder.cpp @@ -1,6 +1,6 @@ -/** - * 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/common/common.h> @@ -9,7 +9,7 @@ #include <aws/core/utils/event/EventStreamDecoder.h> #include <aws/core/utils/logging/LogMacros.h> #include <aws/core/utils/UnreferencedParam.h> -#include <aws/core/utils/memory/AWSMemory.h> +#include <aws/core/utils/memory/AWSMemory.h> namespace Aws { @@ -21,8 +21,8 @@ namespace Aws EventStreamDecoder::EventStreamDecoder(EventStreamHandler* handler) : m_eventStreamHandler(handler) { - aws_event_stream_streaming_decoder_init(&m_decoder, - get_aws_allocator(), + aws_event_stream_streaming_decoder_init(&m_decoder, + get_aws_allocator(), onPayloadSegment, onPreludeReceived, onHeaderReceived, @@ -53,7 +53,7 @@ namespace Aws void EventStreamDecoder::ResetEventStreamHandler(EventStreamHandler* handler) { - aws_event_stream_streaming_decoder_init(&m_decoder, get_aws_allocator(), + aws_event_stream_streaming_decoder_init(&m_decoder, get_aws_allocator(), onPayloadSegment, onPreludeReceived, onHeaderReceived, diff --git a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamEncoder.cpp b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamEncoder.cpp index ef7104e839..5380a793e1 100644 --- a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamEncoder.cpp +++ b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamEncoder.cpp @@ -1,6 +1,6 @@ -/** - * 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/core/utils/event/EventHeader.h> @@ -9,7 +9,7 @@ #include <aws/core/utils/logging/LogMacros.h> #include <aws/core/auth/AWSAuthSigner.h> #include <aws/common/byte_order.h> -#include <aws/core/utils/memory/AWSMemory.h> +#include <aws/core/utils/memory/AWSMemory.h> #include <cassert> @@ -23,7 +23,7 @@ namespace Aws static void EncodeHeaders(const Aws::Utils::Event::Message& msg, aws_array_list* headers) { - aws_array_list_init_dynamic(headers, get_aws_allocator(), msg.GetEventHeaders().size(), sizeof(aws_event_stream_header_value_pair)); + aws_array_list_init_dynamic(headers, get_aws_allocator(), msg.GetEventHeaders().size(), sizeof(aws_event_stream_header_value_pair)); for (auto&& header : msg.GetEventHeaders()) { const uint8_t headerKeyLen = static_cast<uint8_t>(header.first.length()); @@ -37,18 +37,18 @@ namespace Aws aws_event_stream_add_bool_header(headers, header.first.c_str(), headerKeyLen, header.second.GetEventHeaderValueAsByte()); break; case EventHeaderValue::EventHeaderType::INT16: - aws_event_stream_add_int16_header(headers, header.first.c_str(), headerKeyLen, header.second.GetEventHeaderValueAsInt16()); + aws_event_stream_add_int16_header(headers, header.first.c_str(), headerKeyLen, header.second.GetEventHeaderValueAsInt16()); break; case EventHeaderValue::EventHeaderType::INT32: - aws_event_stream_add_int32_header(headers, header.first.c_str(), headerKeyLen, header.second.GetEventHeaderValueAsInt32()); + aws_event_stream_add_int32_header(headers, header.first.c_str(), headerKeyLen, header.second.GetEventHeaderValueAsInt32()); break; case EventHeaderValue::EventHeaderType::INT64: - aws_event_stream_add_int64_header(headers, header.first.c_str(), headerKeyLen, header.second.GetEventHeaderValueAsInt64()); + aws_event_stream_add_int64_header(headers, header.first.c_str(), headerKeyLen, header.second.GetEventHeaderValueAsInt64()); break; case EventHeaderValue::EventHeaderType::BYTE_BUF: { const auto& bytes = header.second.GetEventHeaderValueAsBytebuf(); - aws_event_stream_add_bytebuf_header(headers, header.first.c_str(), headerKeyLen, bytes.GetUnderlyingData(), static_cast<uint16_t>(bytes.GetLength()), 1 /*copy*/); + aws_event_stream_add_bytebuf_header(headers, header.first.c_str(), headerKeyLen, bytes.GetUnderlyingData(), static_cast<uint16_t>(bytes.GetLength()), 1 /*copy*/); } break; case EventHeaderValue::EventHeaderType::STRING: @@ -58,7 +58,7 @@ namespace Aws } break; case EventHeaderValue::EventHeaderType::TIMESTAMP: - aws_event_stream_add_timestamp_header(headers, header.first.c_str(), headerKeyLen, header.second.GetEventHeaderValueAsTimestamp()); + aws_event_stream_add_timestamp_header(headers, header.first.c_str(), headerKeyLen, header.second.GetEventHeaderValueAsTimestamp()); break; case EventHeaderValue::EventHeaderType::UUID: { @@ -104,16 +104,16 @@ namespace Aws payload.allocator = nullptr; aws_event_stream_message encoded; - if(aws_event_stream_message_init(&encoded, get_aws_allocator(), &headers, &payload) == AWS_OP_ERR) + if(aws_event_stream_message_init(&encoded, get_aws_allocator(), &headers, &payload) == AWS_OP_ERR) { - AWS_LOGSTREAM_ERROR(TAG, "Error creating event-stream message from payload."); - aws_event_stream_headers_list_cleanup(&headers); + AWS_LOGSTREAM_ERROR(TAG, "Error creating event-stream message from payload."); + aws_event_stream_headers_list_cleanup(&headers); // GCC 4.9.4 issues a warning with -Wextra if we simply do // return {}; aws_event_stream_message empty{nullptr, nullptr, 0}; return empty; } - aws_event_stream_headers_list_cleanup(&headers); + aws_event_stream_headers_list_cleanup(&headers); return encoded; } @@ -143,16 +143,16 @@ namespace Aws payload.allocator = nullptr; aws_event_stream_message signedmsg; - if(aws_event_stream_message_init(&signedmsg, get_aws_allocator(), &headers, &payload)) + if(aws_event_stream_message_init(&signedmsg, get_aws_allocator(), &headers, &payload)) { - AWS_LOGSTREAM_ERROR(TAG, "Error creating event-stream message from payload."); - aws_event_stream_headers_list_cleanup(&headers); + AWS_LOGSTREAM_ERROR(TAG, "Error creating event-stream message from payload."); + aws_event_stream_headers_list_cleanup(&headers); // GCC 4.9.4 issues a warning with -Wextra if we simply do // return {}; aws_event_stream_message empty{nullptr, nullptr, 0}; return empty; } - aws_event_stream_headers_list_cleanup(&headers); + aws_event_stream_headers_list_cleanup(&headers); return signedmsg; } diff --git a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamErrors.cpp b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamErrors.cpp index 836d0b47c5..c8736b8ffa 100644 --- a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamErrors.cpp +++ b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/event/EventStreamErrors.cpp @@ -1,6 +1,6 @@ -/** - * 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/core/client/AWSError.h> #include <aws/core/utils/HashingUtils.h> |