From 75a9bd2a4f637fb8e8e3dc4609a7045547119e80 Mon Sep 17 00:00:00 2001 From: Alex Trotsenko Date: Wed, 24 Sep 2014 17:31:33 +0300 Subject: Introduce SCTP sockets support Add protocol-specific code and the QSctpServer, QSctpSocket classes. Change-Id: Ie9a1d87bd1fda866a2405043d1c15c12ded5a96e Reviewed-by: Thiago Macieira --- src/corelib/io/qiodevice.cpp | 12 ++++++++++++ src/corelib/io/qiodevice_p.h | 2 ++ 2 files changed, 14 insertions(+) (limited to 'src/corelib/io') diff --git a/src/corelib/io/qiodevice.cpp b/src/corelib/io/qiodevice.cpp index 94fb68450c..fbee1a223f 100644 --- a/src/corelib/io/qiodevice.cpp +++ b/src/corelib/io/qiodevice.cpp @@ -738,6 +738,18 @@ void QIODevicePrivate::setWriteChannelCount(int count) setCurrentWriteChannel(currentWriteChannel); } +/*! + \internal +*/ +bool QIODevicePrivate::allWriteBuffersEmpty() const +{ + for (const QRingBuffer &ringBuffer : writeBuffers) { + if (!ringBuffer.isEmpty()) + return false; + } + return true; +} + /*! Opens the device and sets its OpenMode to \a mode. Returns \c true if successful; otherwise returns \c false. This function should be called from any diff --git a/src/corelib/io/qiodevice_p.h b/src/corelib/io/qiodevice_p.h index eed98a8fe3..76bec89ef2 100644 --- a/src/corelib/io/qiodevice_p.h +++ b/src/corelib/io/qiodevice_p.h @@ -154,6 +154,8 @@ public: return buffer.isEmpty() || (transactionStarted && isSequential() && transactionPos == buffer.size()); } + bool allWriteBuffersEmpty() const; + void seekBuffer(qint64 newPos); inline void setCurrentReadChannel(int channel) -- cgit v1.2.3