diff --git a/lib/base/tlsstream.cpp b/lib/base/tlsstream.cpp index e8ec0e9d4..4d8883a62 100644 --- a/lib/base/tlsstream.cpp +++ b/lib/base/tlsstream.cpp @@ -20,7 +20,6 @@ #include "base/tlsstream.hpp" #include "base/utility.hpp" #include "base/exception.hpp" -#include "base/objectlock.hpp" #include "base/logger_fwd.hpp" #include #include @@ -184,32 +183,6 @@ size_t TlsStream::Read(void *buffer, size_t count) } void TlsStream::Write(const void *buffer, size_t count) -{ - { - ObjectLock olock(&m_SendQ); - m_SendQ.Write(buffer, count); - } - - Utility::QueueAsyncCallback(boost::bind(&TlsStream::FinishAsyncWrite, this)); -} - -void TlsStream::FinishAsyncWrite(void) -{ - boost::mutex::scoped_lock lock(m_WriteMutex); - - for (;;) { - ObjectLock olock(&m_SendQ); - char buffer[1024]; - size_t count = m_SendQ.Read(buffer, sizeof(buffer)); - - if (count == 0) - break; /* No more data in the sendq */ - - WriteSync(buffer, count); - } -} - -void TlsStream::WriteSync(const void *buffer, size_t count) { size_t left = count; diff --git a/lib/base/tlsstream.hpp b/lib/base/tlsstream.hpp index 647e199b6..0d26656d0 100644 --- a/lib/base/tlsstream.hpp +++ b/lib/base/tlsstream.hpp @@ -23,7 +23,6 @@ #include "base/i2-base.hpp" #include "base/socket.hpp" #include "base/stream.hpp" -#include "base/fifo.hpp" #include "base/tlsutility.hpp" namespace icinga @@ -50,7 +49,6 @@ public: virtual size_t Read(void *buffer, size_t count); virtual void Write(const void *buffer, size_t count); - void WriteSync(const void *buffer, size_t count); virtual bool IsEof(void) const; @@ -58,9 +56,6 @@ private: boost::mutex m_SSLLock; shared_ptr m_SSL; BIO *m_BIO; - - boost::mutex m_WriteMutex; - FIFO m_SendQ; Socket::Ptr m_Socket; ConnectionRole m_Role; @@ -69,8 +64,6 @@ private: static bool m_SSLIndexInitialized; static void NullCertificateDeleter(X509 *certificate); - - void FinishAsyncWrite(void); }; }