aboutsummaryrefslogtreecommitdiffstats
path: root/contrib/libs/poco/Crypto/src/CryptoStream.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/poco/Crypto/src/CryptoStream.cpp
parent718c552901d703c502ccbefdfc3c9028d608b947 (diff)
downloadydb-2d37894b1b037cf24231090eda8589bbb44fb6fc.tar.gz
Restoring authorship annotation for <orivej@yandex-team.ru>. Commit 2 of 2.
Diffstat (limited to 'contrib/libs/poco/Crypto/src/CryptoStream.cpp')
-rw-r--r--contrib/libs/poco/Crypto/src/CryptoStream.cpp710
1 files changed, 355 insertions, 355 deletions
diff --git a/contrib/libs/poco/Crypto/src/CryptoStream.cpp b/contrib/libs/poco/Crypto/src/CryptoStream.cpp
index a0427686b2..6b29b7f077 100644
--- a/contrib/libs/poco/Crypto/src/CryptoStream.cpp
+++ b/contrib/libs/poco/Crypto/src/CryptoStream.cpp
@@ -1,355 +1,355 @@
-//
-// CryptoStream.cpp
-//
-// Library: Crypto
-// Package: Cipher
-// Module: CryptoStream
-//
-// Copyright (c) 2008, Applied Informatics Software Engineering GmbH.
-// and Contributors.
-//
-// SPDX-License-Identifier: BSL-1.0
-//
-
-
-#include "Poco/Crypto/CryptoStream.h"
-#include "Poco/Crypto/CryptoTransform.h"
-#include "Poco/Crypto/Cipher.h"
-#include "Poco/Exception.h"
-#include <algorithm>
-
-
-#undef min
-#undef max
-
-
-namespace Poco {
-namespace Crypto {
-
-
-//
-// CryptoStreamBuf
-//
-
-
-CryptoStreamBuf::CryptoStreamBuf(std::istream& istr, CryptoTransform* pTransform, std::streamsize bufferSize):
- Poco::BufferedStreamBuf(bufferSize, std::ios::in),
- _pTransform(pTransform),
- _pIstr(&istr),
- _pOstr(0),
- _eof(false),
- _buffer(static_cast<std::size_t>(bufferSize))
-{
- poco_check_ptr (pTransform);
- poco_assert (bufferSize > 2 * pTransform->blockSize());
-}
-
-
-CryptoStreamBuf::CryptoStreamBuf(std::ostream& ostr, CryptoTransform* pTransform, std::streamsize bufferSize):
- Poco::BufferedStreamBuf(bufferSize, std::ios::out),
- _pTransform(pTransform),
- _pIstr(0),
- _pOstr(&ostr),
- _eof(false),
- _buffer(static_cast<std::size_t>(bufferSize))
-{
- poco_check_ptr (pTransform);
- poco_assert (bufferSize > 2 * pTransform->blockSize());
-}
-
-
-CryptoStreamBuf::~CryptoStreamBuf()
-{
- try
- {
- close();
- }
- catch (...)
- {
- }
- delete _pTransform;
-}
-
-
-void CryptoStreamBuf::close()
-{
- sync();
-
- if (_pIstr)
- {
- _pIstr = 0;
- }
- else if (_pOstr)
- {
- // Close can be called multiple times. By zeroing the pointer we make
- // sure that we call finalize() only once, even if an exception is
- // thrown.
- std::ostream* pOstr = _pOstr;
- _pOstr = 0;
-
- // Finalize transformation.
- std::streamsize n = _pTransform->finalize(_buffer.begin(), static_cast<std::streamsize>(_buffer.size()));
-
- if (n > 0)
- {
- pOstr->write(reinterpret_cast<char*>(_buffer.begin()), n);
- if (!pOstr->good())
- throw Poco::IOException("Output stream failure");
- }
- }
-}
-
-
-int CryptoStreamBuf::readFromDevice(char* buffer, std::streamsize length)
-{
- if (!_pIstr)
- return 0;
-
- int count = 0;
-
- while (!_eof)
- {
- int m = (static_cast<int>(length) - count)/2 - static_cast<int>(_pTransform->blockSize());
-
- // Make sure we can read at least one more block. Explicitely check
- // for m < 0 since blockSize() returns an unsigned int and the
- // comparison might give false results for m < 0.
- if (m <= 0)
- break;
-
- int n = 0;
-
- if (_pIstr->good())
- {
- _pIstr->read(reinterpret_cast<char*>(_buffer.begin()), m);
- n = static_cast<int>(_pIstr->gcount());
- }
-
- if (n == 0)
- {
- _eof = true;
-
- // No more data, finalize transformation
- count += static_cast<int>(_pTransform->finalize(
- reinterpret_cast<unsigned char*>(buffer + count),
- static_cast<int>(length) - count));
- }
- else
- {
- // Transform next chunk of data
- count += static_cast<int>(_pTransform->transform(
- _buffer.begin(),
- n,
- reinterpret_cast<unsigned char*>(buffer + count),
- static_cast<int>(length) - count));
- }
- }
-
- return count;
-}
-
-
-int CryptoStreamBuf::writeToDevice(const char* buffer, std::streamsize length)
-{
- if (!_pOstr)
- return 0;
-
- std::size_t maxChunkSize = _buffer.size()/2;
- std::size_t count = 0;
-
- while (count < length)
- {
- // Truncate chunk size so that the maximum output fits into _buffer.
- std::size_t n = static_cast<std::size_t>(length) - count;
- if (n > maxChunkSize)
- n = maxChunkSize;
-
- // Transform next chunk of data
- std::streamsize k = _pTransform->transform(
- reinterpret_cast<const unsigned char*>(buffer + count),
- static_cast<std::streamsize>(n),
- _buffer.begin(),
- static_cast<std::streamsize>(_buffer.size()));
-
- // Attention: (n != k) might be true. In count, we have to track how
- // many bytes from buffer have been consumed, not how many bytes have
- // been written to _pOstr!
- count += n;
-
- if (k > 0)
- {
- _pOstr->write(reinterpret_cast<const char*>(_buffer.begin()), k);
- if (!_pOstr->good())
- throw Poco::IOException("Output stream failure");
- }
- }
-
- return static_cast<int>(count);
-}
-
-
-//
-// CryptoIOS
-//
-
-
-CryptoIOS::CryptoIOS(std::istream& istr, CryptoTransform* pTransform, std::streamsize bufferSize):
- _buf(istr, pTransform, bufferSize)
-{
- poco_ios_init(&_buf);
-}
-
-
-CryptoIOS::CryptoIOS(std::ostream& ostr, CryptoTransform* pTransform, std::streamsize bufferSize):
- _buf(ostr, pTransform, bufferSize)
-{
- poco_ios_init(&_buf);
-}
-
-
-CryptoIOS::~CryptoIOS()
-{
-}
-
-
-CryptoStreamBuf* CryptoIOS::rdbuf()
-{
- return &_buf;
-}
-
-
-//
-// CryptoInputStream
-//
-
-
-CryptoInputStream::CryptoInputStream(std::istream& istr, CryptoTransform* pTransform, std::streamsize bufferSize):
- CryptoIOS(istr, pTransform, bufferSize),
- std::istream(&_buf)
-{
-}
-
-
-CryptoInputStream::CryptoInputStream(std::istream& istr, Cipher& cipher, std::streamsize bufferSize):
- CryptoIOS(istr, cipher.createEncryptor(), bufferSize),
- std::istream(&_buf)
-{
-}
-
-
-CryptoInputStream::~CryptoInputStream()
-{
-}
-
-
-//
-// CryptoOutputStream
-//
-
-
-CryptoOutputStream::CryptoOutputStream(std::ostream& ostr, CryptoTransform* pTransform, std::streamsize bufferSize):
- CryptoIOS(ostr, pTransform, bufferSize),
- std::ostream(&_buf)
-{
-}
-
-
-CryptoOutputStream::CryptoOutputStream(std::ostream& ostr, Cipher& cipher, std::streamsize bufferSize):
- CryptoIOS(ostr, cipher.createDecryptor(), bufferSize),
- std::ostream(&_buf)
-{
-}
-
-
-CryptoOutputStream::~CryptoOutputStream()
-{
-}
-
-
-void CryptoOutputStream::close()
-{
- _buf.close();
-}
-
-
-//
-// EncryptingInputStream
-//
-
-
-EncryptingInputStream::EncryptingInputStream(std::istream& istr, Cipher& cipher, std::streamsize bufferSize):
- CryptoIOS(istr, cipher.createEncryptor(), bufferSize),
- std::istream(&_buf)
-{
-}
-
-
-EncryptingInputStream::~EncryptingInputStream()
-{
-}
-
-
-//
-// EncryptingOuputStream
-//
-
-
-EncryptingOutputStream::EncryptingOutputStream(std::ostream& ostr, Cipher& cipher, std::streamsize bufferSize):
- CryptoIOS(ostr, cipher.createEncryptor(), bufferSize),
- std::ostream(&_buf)
-{
-}
-
-
-EncryptingOutputStream::~EncryptingOutputStream()
-{
-}
-
-
-void EncryptingOutputStream::close()
-{
- _buf.close();
-}
-
-
-//
-// DecryptingInputStream
-//
-
-
-DecryptingInputStream::DecryptingInputStream(std::istream& istr, Cipher& cipher, std::streamsize bufferSize):
- CryptoIOS(istr, cipher.createDecryptor(), bufferSize),
- std::istream(&_buf)
-{
-}
-
-
-DecryptingInputStream::~DecryptingInputStream()
-{
-}
-
-
-//
-// DecryptingOuputStream
-//
-
-
-DecryptingOutputStream::DecryptingOutputStream(std::ostream& ostr, Cipher& cipher, std::streamsize bufferSize):
- CryptoIOS(ostr, cipher.createDecryptor(), bufferSize),
- std::ostream(&_buf)
-{
-}
-
-
-DecryptingOutputStream::~DecryptingOutputStream()
-{
-}
-
-
-void DecryptingOutputStream::close()
-{
- _buf.close();
-}
-
-
-} } // namespace Poco::Crypto
+//
+// CryptoStream.cpp
+//
+// Library: Crypto
+// Package: Cipher
+// Module: CryptoStream
+//
+// Copyright (c) 2008, Applied Informatics Software Engineering GmbH.
+// and Contributors.
+//
+// SPDX-License-Identifier: BSL-1.0
+//
+
+
+#include "Poco/Crypto/CryptoStream.h"
+#include "Poco/Crypto/CryptoTransform.h"
+#include "Poco/Crypto/Cipher.h"
+#include "Poco/Exception.h"
+#include <algorithm>
+
+
+#undef min
+#undef max
+
+
+namespace Poco {
+namespace Crypto {
+
+
+//
+// CryptoStreamBuf
+//
+
+
+CryptoStreamBuf::CryptoStreamBuf(std::istream& istr, CryptoTransform* pTransform, std::streamsize bufferSize):
+ Poco::BufferedStreamBuf(bufferSize, std::ios::in),
+ _pTransform(pTransform),
+ _pIstr(&istr),
+ _pOstr(0),
+ _eof(false),
+ _buffer(static_cast<std::size_t>(bufferSize))
+{
+ poco_check_ptr (pTransform);
+ poco_assert (bufferSize > 2 * pTransform->blockSize());
+}
+
+
+CryptoStreamBuf::CryptoStreamBuf(std::ostream& ostr, CryptoTransform* pTransform, std::streamsize bufferSize):
+ Poco::BufferedStreamBuf(bufferSize, std::ios::out),
+ _pTransform(pTransform),
+ _pIstr(0),
+ _pOstr(&ostr),
+ _eof(false),
+ _buffer(static_cast<std::size_t>(bufferSize))
+{
+ poco_check_ptr (pTransform);
+ poco_assert (bufferSize > 2 * pTransform->blockSize());
+}
+
+
+CryptoStreamBuf::~CryptoStreamBuf()
+{
+ try
+ {
+ close();
+ }
+ catch (...)
+ {
+ }
+ delete _pTransform;
+}
+
+
+void CryptoStreamBuf::close()
+{
+ sync();
+
+ if (_pIstr)
+ {
+ _pIstr = 0;
+ }
+ else if (_pOstr)
+ {
+ // Close can be called multiple times. By zeroing the pointer we make
+ // sure that we call finalize() only once, even if an exception is
+ // thrown.
+ std::ostream* pOstr = _pOstr;
+ _pOstr = 0;
+
+ // Finalize transformation.
+ std::streamsize n = _pTransform->finalize(_buffer.begin(), static_cast<std::streamsize>(_buffer.size()));
+
+ if (n > 0)
+ {
+ pOstr->write(reinterpret_cast<char*>(_buffer.begin()), n);
+ if (!pOstr->good())
+ throw Poco::IOException("Output stream failure");
+ }
+ }
+}
+
+
+int CryptoStreamBuf::readFromDevice(char* buffer, std::streamsize length)
+{
+ if (!_pIstr)
+ return 0;
+
+ int count = 0;
+
+ while (!_eof)
+ {
+ int m = (static_cast<int>(length) - count)/2 - static_cast<int>(_pTransform->blockSize());
+
+ // Make sure we can read at least one more block. Explicitely check
+ // for m < 0 since blockSize() returns an unsigned int and the
+ // comparison might give false results for m < 0.
+ if (m <= 0)
+ break;
+
+ int n = 0;
+
+ if (_pIstr->good())
+ {
+ _pIstr->read(reinterpret_cast<char*>(_buffer.begin()), m);
+ n = static_cast<int>(_pIstr->gcount());
+ }
+
+ if (n == 0)
+ {
+ _eof = true;
+
+ // No more data, finalize transformation
+ count += static_cast<int>(_pTransform->finalize(
+ reinterpret_cast<unsigned char*>(buffer + count),
+ static_cast<int>(length) - count));
+ }
+ else
+ {
+ // Transform next chunk of data
+ count += static_cast<int>(_pTransform->transform(
+ _buffer.begin(),
+ n,
+ reinterpret_cast<unsigned char*>(buffer + count),
+ static_cast<int>(length) - count));
+ }
+ }
+
+ return count;
+}
+
+
+int CryptoStreamBuf::writeToDevice(const char* buffer, std::streamsize length)
+{
+ if (!_pOstr)
+ return 0;
+
+ std::size_t maxChunkSize = _buffer.size()/2;
+ std::size_t count = 0;
+
+ while (count < length)
+ {
+ // Truncate chunk size so that the maximum output fits into _buffer.
+ std::size_t n = static_cast<std::size_t>(length) - count;
+ if (n > maxChunkSize)
+ n = maxChunkSize;
+
+ // Transform next chunk of data
+ std::streamsize k = _pTransform->transform(
+ reinterpret_cast<const unsigned char*>(buffer + count),
+ static_cast<std::streamsize>(n),
+ _buffer.begin(),
+ static_cast<std::streamsize>(_buffer.size()));
+
+ // Attention: (n != k) might be true. In count, we have to track how
+ // many bytes from buffer have been consumed, not how many bytes have
+ // been written to _pOstr!
+ count += n;
+
+ if (k > 0)
+ {
+ _pOstr->write(reinterpret_cast<const char*>(_buffer.begin()), k);
+ if (!_pOstr->good())
+ throw Poco::IOException("Output stream failure");
+ }
+ }
+
+ return static_cast<int>(count);
+}
+
+
+//
+// CryptoIOS
+//
+
+
+CryptoIOS::CryptoIOS(std::istream& istr, CryptoTransform* pTransform, std::streamsize bufferSize):
+ _buf(istr, pTransform, bufferSize)
+{
+ poco_ios_init(&_buf);
+}
+
+
+CryptoIOS::CryptoIOS(std::ostream& ostr, CryptoTransform* pTransform, std::streamsize bufferSize):
+ _buf(ostr, pTransform, bufferSize)
+{
+ poco_ios_init(&_buf);
+}
+
+
+CryptoIOS::~CryptoIOS()
+{
+}
+
+
+CryptoStreamBuf* CryptoIOS::rdbuf()
+{
+ return &_buf;
+}
+
+
+//
+// CryptoInputStream
+//
+
+
+CryptoInputStream::CryptoInputStream(std::istream& istr, CryptoTransform* pTransform, std::streamsize bufferSize):
+ CryptoIOS(istr, pTransform, bufferSize),
+ std::istream(&_buf)
+{
+}
+
+
+CryptoInputStream::CryptoInputStream(std::istream& istr, Cipher& cipher, std::streamsize bufferSize):
+ CryptoIOS(istr, cipher.createEncryptor(), bufferSize),
+ std::istream(&_buf)
+{
+}
+
+
+CryptoInputStream::~CryptoInputStream()
+{
+}
+
+
+//
+// CryptoOutputStream
+//
+
+
+CryptoOutputStream::CryptoOutputStream(std::ostream& ostr, CryptoTransform* pTransform, std::streamsize bufferSize):
+ CryptoIOS(ostr, pTransform, bufferSize),
+ std::ostream(&_buf)
+{
+}
+
+
+CryptoOutputStream::CryptoOutputStream(std::ostream& ostr, Cipher& cipher, std::streamsize bufferSize):
+ CryptoIOS(ostr, cipher.createDecryptor(), bufferSize),
+ std::ostream(&_buf)
+{
+}
+
+
+CryptoOutputStream::~CryptoOutputStream()
+{
+}
+
+
+void CryptoOutputStream::close()
+{
+ _buf.close();
+}
+
+
+//
+// EncryptingInputStream
+//
+
+
+EncryptingInputStream::EncryptingInputStream(std::istream& istr, Cipher& cipher, std::streamsize bufferSize):
+ CryptoIOS(istr, cipher.createEncryptor(), bufferSize),
+ std::istream(&_buf)
+{
+}
+
+
+EncryptingInputStream::~EncryptingInputStream()
+{
+}
+
+
+//
+// EncryptingOuputStream
+//
+
+
+EncryptingOutputStream::EncryptingOutputStream(std::ostream& ostr, Cipher& cipher, std::streamsize bufferSize):
+ CryptoIOS(ostr, cipher.createEncryptor(), bufferSize),
+ std::ostream(&_buf)
+{
+}
+
+
+EncryptingOutputStream::~EncryptingOutputStream()
+{
+}
+
+
+void EncryptingOutputStream::close()
+{
+ _buf.close();
+}
+
+
+//
+// DecryptingInputStream
+//
+
+
+DecryptingInputStream::DecryptingInputStream(std::istream& istr, Cipher& cipher, std::streamsize bufferSize):
+ CryptoIOS(istr, cipher.createDecryptor(), bufferSize),
+ std::istream(&_buf)
+{
+}
+
+
+DecryptingInputStream::~DecryptingInputStream()
+{
+}
+
+
+//
+// DecryptingOuputStream
+//
+
+
+DecryptingOutputStream::DecryptingOutputStream(std::ostream& ostr, Cipher& cipher, std::streamsize bufferSize):
+ CryptoIOS(ostr, cipher.createDecryptor(), bufferSize),
+ std::ostream(&_buf)
+{
+}
+
+
+DecryptingOutputStream::~DecryptingOutputStream()
+{
+}
+
+
+void DecryptingOutputStream::close()
+{
+ _buf.close();
+}
+
+
+} } // namespace Poco::Crypto