aboutsummaryrefslogtreecommitdiffstats
path: root/src/net/smtp/SMTPChunkingOutputStreamAdapter.cpp
diff options
context:
space:
mode:
authorVincent Richard <[email protected]>2013-12-29 10:02:12 +0100
committerVincent Richard <[email protected]>2013-12-29 10:02:12 +0100
commit152c6bed75598a6ca5efb7914701157270155833 (patch)
tree8faced1d75a45c819630323da256248415992ed0 /src/net/smtp/SMTPChunkingOutputStreamAdapter.cpp
parentMerge branch 'master' of https://github.com/kisli/vmime (diff)
downloadvmime-152c6bed75598a6ca5efb7914701157270155833.tar.gz
vmime-152c6bed75598a6ca5efb7914701157270155833.zip
Merged source and header files in directory structure. Got rid of SConstruct build.
Diffstat (limited to 'src/net/smtp/SMTPChunkingOutputStreamAdapter.cpp')
-rw-r--r--src/net/smtp/SMTPChunkingOutputStreamAdapter.cpp145
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