diff options
Diffstat (limited to 'src/net/smtp/SMTPChunkingOutputStreamAdapter.cpp')
| -rw-r--r-- | src/net/smtp/SMTPChunkingOutputStreamAdapter.cpp | 145 |
1 files changed, 0 insertions, 145 deletions
diff --git a/src/net/smtp/SMTPChunkingOutputStreamAdapter.cpp b/src/net/smtp/SMTPChunkingOutputStreamAdapter.cpp deleted file mode 100644 index 69f63bc9..00000000 --- a/src/net/smtp/SMTPChunkingOutputStreamAdapter.cpp +++ /dev/null @@ -1,145 +0,0 @@ -// -// VMime library (http://www.vmime.org) -// Copyright (C) 2002-2013 Vincent Richard <[email protected]> -// -// This program is free software; you can redistribute it and/or -// modify it under the terms of the GNU General Public License as -// published by the Free Software Foundation; either version 3 of -// the License, or (at your option) any later version. -// -// This program is distributed in the hope that it will be useful, -// but WITHOUT ANY WARRANTY; without even the implied warranty of -// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the GNU -// General Public License for more details. -// -// You should have received a copy of the GNU General Public License along -// with this program; if not, write to the Free Software Foundation, Inc., -// 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. -// -// Linking this library statically or dynamically with other modules is making -// a combined work based on this library. Thus, the terms and conditions of -// the GNU General Public License cover the whole combination. -// - -#include "vmime/config.hpp" - - -#if VMIME_HAVE_MESSAGING_FEATURES && VMIME_HAVE_MESSAGING_PROTO_SMTP - - -#include "vmime/net/smtp/SMTPChunkingOutputStreamAdapter.hpp" - -#include "vmime/net/smtp/SMTPConnection.hpp" -#include "vmime/net/smtp/SMTPTransport.hpp" - -#include <algorithm> - - -namespace vmime { -namespace net { -namespace smtp { - - -SMTPChunkingOutputStreamAdapter::SMTPChunkingOutputStreamAdapter(shared_ptr <SMTPConnection> conn) - : m_connection(conn), m_bufferSize(0), m_chunkCount(0) -{ -} - - -void SMTPChunkingOutputStreamAdapter::sendChunk - (const byte_t* const data, const size_t count, const bool last) -{ - if (count == 0 && !last) - { - // Nothing to send - return; - } - - // Send this chunk - m_connection->sendRequest(SMTPCommand::BDAT(count, last)); - m_connection->getSocket()->sendRaw(data, count); - - ++m_chunkCount; - - // If PIPELINING is not supported, read one response for this BDAT command - if (!m_connection->hasExtension("PIPELINING")) - { - shared_ptr <SMTPResponse> resp = m_connection->readResponse(); - - if (resp->getCode() != 250) - { - m_connection->getTransport()->disconnect(); - throw exceptions::command_error("BDAT", resp->getText()); - } - } - // If PIPELINING is supported, read one response for each chunk (ie. number - // of BDAT commands issued) after the last chunk has been sent - else if (last) - { - bool invalidReply = false; - shared_ptr <SMTPResponse> resp; - - for (unsigned int i = 0 ; i < m_chunkCount ; ++i) - { - resp = m_connection->readResponse(); - - if (resp->getCode() != 250) - invalidReply = true; - } - - if (invalidReply) - { - m_connection->getTransport()->disconnect(); - throw exceptions::command_error("BDAT", resp->getText()); - } - } -} - - -void SMTPChunkingOutputStreamAdapter::writeImpl - (const byte_t* const data, const size_t count) -{ - const byte_t* curData = data; - size_t curCount = count; - - while (curCount != 0) - { - // Fill the buffer - const size_t remaining = sizeof(m_buffer) - m_bufferSize; - const size_t bytesToCopy = std::min(remaining, curCount); - - std::copy(data, data + bytesToCopy, m_buffer + m_bufferSize); - - m_bufferSize += bytesToCopy; - curData += bytesToCopy; - curCount -= bytesToCopy; - - // If the buffer is full, send this chunk - if (m_bufferSize >= sizeof(m_buffer)) - { - sendChunk(m_buffer, m_bufferSize, /* last */ false); - m_bufferSize = 0; - } - } -} - - -void SMTPChunkingOutputStreamAdapter::flush() -{ - sendChunk(m_buffer, m_bufferSize, /* last */ true); - m_bufferSize = 0; -} - - -size_t SMTPChunkingOutputStreamAdapter::getBlockSize() -{ - return sizeof(m_buffer); -} - - -} // smtp -} // net -} // vmime - - -#endif // VMIME_HAVE_MESSAGING_FEATURES && VMIME_HAVE_MESSAGING_PROTO_SMTP |