Restoring authorship annotation for <unril@yandex-team.ru>. Commit 1 of 2.

3 files changed, 116 insertions, 116 deletions

diff --git a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/stream/ConcurrentStreamBuf.cpp b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/stream/ConcurrentStreamBuf.cpp
index 3f59dbe96d..0ba47bd92c 100644
--- a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/stream/ConcurrentStreamBuf.cpp
+++ b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/stream/ConcurrentStreamBuf.cpp
@@ -1,109 +1,109 @@
 /**
  * Copyright Amazon.com, Inc. or its affiliates. All Rights Reserved.
  * SPDX-License-Identifier: Apache-2.0.
- */
-#include <aws/core/utils/stream/ConcurrentStreamBuf.h>
-#include <aws/core/utils/logging/LogMacros.h>
-#include <cstdint>
-#include <cassert>
-
-namespace Aws
-{
-    namespace Utils
-    {
-        namespace Stream
-        {
-            const char TAG[] = "ConcurrentStreamBuf";
-            ConcurrentStreamBuf::ConcurrentStreamBuf(size_t bufferLength) :
-                m_putArea(bufferLength), // we access [0] of the put area below so we must initialize it.
-                m_eof(false)
-            {
-                m_getArea.reserve(bufferLength);
-                m_backbuf.reserve(bufferLength);
-
-                char* pbegin = reinterpret_cast<char*>(&m_putArea[0]);
-                setp(pbegin, pbegin + bufferLength);
-            }
-
-            void ConcurrentStreamBuf::SetEof()
-            {
-                {
-                    std::unique_lock<std::mutex> lock(m_lock);
-                    m_eof = true;
-                }
-                m_signal.notify_all();
-            }
-
-            void ConcurrentStreamBuf::FlushPutArea()
-            {
-                const size_t bitslen = pptr() - pbase();
-                if (bitslen)
-                {
-                    // scope the lock
-                    {
-                        std::unique_lock<std::mutex> lock(m_lock);
+ */ 
+#include <aws/core/utils/stream/ConcurrentStreamBuf.h> 
+#include <aws/core/utils/logging/LogMacros.h> 
+#include <cstdint> 
+#include <cassert> 
+ 
+namespace Aws 
+{ 
+    namespace Utils 
+    { 
+        namespace Stream 
+        { 
+            const char TAG[] = "ConcurrentStreamBuf"; 
+            ConcurrentStreamBuf::ConcurrentStreamBuf(size_t bufferLength) : 
+                m_putArea(bufferLength), // we access [0] of the put area below so we must initialize it. 
+                m_eof(false) 
+            { 
+                m_getArea.reserve(bufferLength); 
+                m_backbuf.reserve(bufferLength); 
+ 
+                char* pbegin = reinterpret_cast<char*>(&m_putArea[0]); 
+                setp(pbegin, pbegin + bufferLength); 
+            } 
+ 
+            void ConcurrentStreamBuf::SetEof() 
+            { 
+                { 
+                    std::unique_lock<std::mutex> lock(m_lock); 
+                    m_eof = true; 
+                } 
+                m_signal.notify_all(); 
+            } 
+ 
+            void ConcurrentStreamBuf::FlushPutArea() 
+            { 
+                const size_t bitslen = pptr() - pbase(); 
+                if (bitslen) 
+                { 
+                    // scope the lock 
+                    { 
+                        std::unique_lock<std::mutex> lock(m_lock); 
                         m_signal.wait(lock, [this, bitslen]{ return m_eof || bitslen <= (m_backbuf.capacity() - m_backbuf.size()); });
                         if (m_eof)
                         {
                             return;
                         }
-                        std::copy(pbase(), pptr(), std::back_inserter(m_backbuf));
-                    }
-                    m_signal.notify_one();
-                    char* pbegin = reinterpret_cast<char*>(&m_putArea[0]);
-                    setp(pbegin, pbegin + m_putArea.size());
-                }
-            }
-
-            std::streampos ConcurrentStreamBuf::seekoff(std::streamoff, std::ios_base::seekdir, std::ios_base::openmode)
-            {
-                return std::streamoff(-1); // Seeking is not supported.
-            }
-
-            std::streampos ConcurrentStreamBuf::seekpos(std::streampos, std::ios_base::openmode)
-            {
-                return std::streamoff(-1); // Seeking is not supported.
-            }
-
-            int ConcurrentStreamBuf::underflow()
-            {
-                {
-                    std::unique_lock<std::mutex> lock(m_lock);
-                    m_signal.wait(lock, [this]{ return m_backbuf.empty() == false || m_eof; });
-
-                    if (m_eof && m_backbuf.empty())
-                    {
-                        return std::char_traits<char>::eof();
-                    }
-
-                    m_getArea.clear(); // keep the get-area from growing unbounded.
-                    std::copy(m_backbuf.begin(), m_backbuf.end(), std::back_inserter(m_getArea));
-                    m_backbuf.clear();
-                }
-                m_signal.notify_one();
-                char* gbegin = reinterpret_cast<char*>(&m_getArea[0]);
-                setg(gbegin, gbegin, gbegin + m_getArea.size());
-                return std::char_traits<char>::to_int_type(*gptr());
-            }
-
-            std::streamsize ConcurrentStreamBuf::showmanyc()
-            {
-                std::unique_lock<std::mutex> lock(m_lock);
-                AWS_LOGSTREAM_TRACE(TAG, "stream how many character? " << m_backbuf.size());
-                return m_backbuf.size();
-            }
-
-            int ConcurrentStreamBuf::overflow(int ch)
-            {
-                const auto eof = std::char_traits<char>::eof();
-
-                if (ch == eof)
-                {
-                    FlushPutArea();
-                    return eof;
-                }
-
-                FlushPutArea();
+                        std::copy(pbase(), pptr(), std::back_inserter(m_backbuf)); 
+                    } 
+                    m_signal.notify_one(); 
+                    char* pbegin = reinterpret_cast<char*>(&m_putArea[0]); 
+                    setp(pbegin, pbegin + m_putArea.size()); 
+                } 
+            } 
+ 
+            std::streampos ConcurrentStreamBuf::seekoff(std::streamoff, std::ios_base::seekdir, std::ios_base::openmode) 
+            { 
+                return std::streamoff(-1); // Seeking is not supported. 
+            } 
+ 
+            std::streampos ConcurrentStreamBuf::seekpos(std::streampos, std::ios_base::openmode) 
+            { 
+                return std::streamoff(-1); // Seeking is not supported. 
+            } 
+ 
+            int ConcurrentStreamBuf::underflow() 
+            { 
+                { 
+                    std::unique_lock<std::mutex> lock(m_lock); 
+                    m_signal.wait(lock, [this]{ return m_backbuf.empty() == false || m_eof; }); 
+ 
+                    if (m_eof && m_backbuf.empty()) 
+                    { 
+                        return std::char_traits<char>::eof(); 
+                    } 
+ 
+                    m_getArea.clear(); // keep the get-area from growing unbounded. 
+                    std::copy(m_backbuf.begin(), m_backbuf.end(), std::back_inserter(m_getArea)); 
+                    m_backbuf.clear(); 
+                } 
+                m_signal.notify_one(); 
+                char* gbegin = reinterpret_cast<char*>(&m_getArea[0]); 
+                setg(gbegin, gbegin, gbegin + m_getArea.size()); 
+                return std::char_traits<char>::to_int_type(*gptr()); 
+            } 
+ 
+            std::streamsize ConcurrentStreamBuf::showmanyc() 
+            { 
+                std::unique_lock<std::mutex> lock(m_lock); 
+                AWS_LOGSTREAM_TRACE(TAG, "stream how many character? " << m_backbuf.size()); 
+                return m_backbuf.size(); 
+            } 
+ 
+            int ConcurrentStreamBuf::overflow(int ch) 
+            { 
+                const auto eof = std::char_traits<char>::eof(); 
+ 
+                if (ch == eof) 
+                { 
+                    FlushPutArea(); 
+                    return eof; 
+                } 
+ 
+                FlushPutArea(); 
                 {
                     std::unique_lock<std::mutex> lock(m_lock);
                     if (m_eof)
@@ -114,13 +114,13 @@ namespace Aws
                     pbump(1);
                     return ch;
                 }
-            }
-
-            int ConcurrentStreamBuf::sync()
-            {
-                FlushPutArea();
-                return 0;
-            }
-        }
-    }
-}
+            } 
+ 
+            int ConcurrentStreamBuf::sync() 
+            { 
+                FlushPutArea(); 
+                return 0; 
+            } 
+        } 
+    } 
+} 
diff --git a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/stream/PreallocatedStreamBuf.cpp b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/stream/PreallocatedStreamBuf.cpp
index f656fc8613..7aaf9c82f3 100644
--- a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/stream/PreallocatedStreamBuf.cpp
+++ b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/stream/PreallocatedStreamBuf.cpp
@@ -16,8 +16,8 @@ namespace Aws
             PreallocatedStreamBuf::PreallocatedStreamBuf(unsigned char* buffer, uint64_t lengthToRead) :
                 m_underlyingBuffer(buffer), m_lengthToRead(lengthToRead)
             {
-                char* end = reinterpret_cast<char*>(m_underlyingBuffer + m_lengthToRead);
-                char* begin = reinterpret_cast<char*>(m_underlyingBuffer);
+                char* end = reinterpret_cast<char*>(m_underlyingBuffer + m_lengthToRead); 
+                char* begin = reinterpret_cast<char*>(m_underlyingBuffer); 
                 setp(begin, end);
                 setg(begin, begin, end);
             }
@@ -55,12 +55,12 @@ namespace Aws
                     return pos_type(off_type(-1));
                 }
 
-                char* end = reinterpret_cast<char*>(m_underlyingBuffer + m_lengthToRead);
-                char* begin = reinterpret_cast<char*>(m_underlyingBuffer);
+                char* end = reinterpret_cast<char*>(m_underlyingBuffer + m_lengthToRead); 
+                char* begin = reinterpret_cast<char*>(m_underlyingBuffer); 
 
                 if (which == std::ios_base::in)
                 {
-                    setg(begin, begin + static_cast<size_t>(pos), end);
+                    setg(begin, begin + static_cast<size_t>(pos), end); 
                 }
 
                 if (which == std::ios_base::out)
@@ -72,4 +72,4 @@ namespace Aws
             }
         }
     }
-}
+} 
diff --git a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/stream/SimpleStreamBuf.cpp b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/stream/SimpleStreamBuf.cpp
index 6e42994744..91064590a8 100644
--- a/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/stream/SimpleStreamBuf.cpp
+++ b/contrib/libs/aws-sdk-cpp/aws-cpp-sdk-core/source/utils/stream/SimpleStreamBuf.cpp
@@ -201,7 +201,7 @@ std::streamsize SimpleStreamBuf::xsputn(const char* s, std::streamsize n)
     return writeCount;
 }
 
-Aws::String SimpleStreamBuf::str() const
+Aws::String SimpleStreamBuf::str() const 
 {
     return Aws::String(m_buffer, pptr());
 }
@@ -236,4 +236,4 @@ void SimpleStreamBuf::str(const Aws::String& value)
 
 }
 }
-}
+}