Add cork

diff --git a/lib/base/stream.cpp b/lib/base/stream.cpp
index 72ca82c1a021dc67b878a508cb5089bb61ace30f..3048f096c137a1f3242a1011b5f5a233fded9bba 100644 (file)
--- a/lib/base/stream.cpp
+++ b/lib/base/stream.cpp
@@ -91,6 +91,16 @@ bool Stream::WaitForData(int timeout)
        return IsDataAvailable() || IsEof();
 }
 
+void Stream::SetCorked(bool corked)
+{
+       m_Corked = corked;
+}
+
+bool Stream::IsCorked() const
+{
+       return m_Corked;
+}
+
 static void StreamDummyCallback()
 { }
 

diff --git a/lib/base/stream.hpp b/lib/base/stream.hpp
index 8a140a58607395c74d318aae6ffa53d2a72af497..bb41291387ee6b64ce5b0325150b3255f480c23b 100644 (file)
--- a/lib/base/stream.hpp
+++ b/lib/base/stream.hpp
@@ -127,6 +127,9 @@ public:
        bool WaitForData();
        bool WaitForData(int timeout);
 
+       virtual void SetCorked(bool corked);
+       bool IsCorked() const;
+
        virtual bool SupportsWaiting() const;
 
        virtual bool IsDataAvailable() const;
@@ -143,6 +146,8 @@ private:
 
        boost::mutex m_Mutex;
        boost::condition_variable m_CV;
+
+       bool m_Corked{false};
 };
 
 }