From 2dbe488dff8d19b3fda93502de92ce985dba3707 Mon Sep 17 00:00:00 2001 From: Ivailo Monev Date: Tue, 31 Mar 2020 10:02:13 +0000 Subject: [PATCH] use QT_BUFFSIZE as block size for QRingBuffer Signed-off-by: Ivailo Monev --- src/core/io/qfile.cpp | 3 +-- src/core/tools/qringbuffer_p.h | 17 ++++++++--------- src/network/socket/qabstractsocket.cpp | 5 ----- 3 files changed, 9 insertions(+), 16 deletions(-) diff --git a/src/core/io/qfile.cpp b/src/core/io/qfile.cpp index 1461831d1..391400cef 100644 --- a/src/core/io/qfile.cpp +++ b/src/core/io/qfile.cpp @@ -50,8 +50,7 @@ QT_BEGIN_NAMESPACE //************* QFilePrivate QFilePrivate::QFilePrivate() : fileEngine(0), lastWasWrite(false), - writeBuffer(QT_BUFFSIZE), error(QFile::NoError), - cachedSize(0) + error(QFile::NoError), cachedSize(0) { } diff --git a/src/core/tools/qringbuffer_p.h b/src/core/tools/qringbuffer_p.h index dd91126ea..09e7427c3 100644 --- a/src/core/tools/qringbuffer_p.h +++ b/src/core/tools/qringbuffer_p.h @@ -53,7 +53,7 @@ QT_BEGIN_NAMESPACE class QRingBuffer { public: - inline QRingBuffer(int growth = QT_BUFFSIZE) : basicBlockSize(growth) { + inline QRingBuffer() { buffers << QByteArray(); clear(); } @@ -128,8 +128,8 @@ public: bytes -= nextBlockSize; if (buffers.count() == 1) { - if (buffers.at(0).size() != basicBlockSize) - buffers[0].resize(basicBlockSize); + if (buffers.at(0).size() != QT_BUFFSIZE) + buffers[0].resize(QT_BUFFSIZE); head = tail = 0; tailBuffer = 0; break; @@ -147,7 +147,7 @@ public: inline char *reserve(int bytes) { // if this is a fresh empty QRingBuffer if (bufferSize == 0) { - buffers[0].resize(qMax(basicBlockSize, bytes)); + buffers[0].resize(qMax(QT_BUFFSIZE, bytes)); bufferSize += bytes; tail = bytes; return buffers[tailBuffer].data(); @@ -176,7 +176,7 @@ public: // create a new QByteArray with the right size buffers << QByteArray(); ++tailBuffer; - buffers[tailBuffer].resize(qMax(basicBlockSize, bytes)); + buffers[tailBuffer].resize(qMax(QT_BUFFSIZE, bytes)); tail = bytes; return buffers[tailBuffer].data(); } @@ -237,8 +237,8 @@ public: --head; if (head < 0) { buffers.prepend(QByteArray()); - buffers[0].resize(basicBlockSize); - head = basicBlockSize - 1; + buffers[0].resize(QT_BUFFSIZE); + head = QT_BUFFSIZE - 1; ++tailBuffer; } buffers[0][head] = c; @@ -354,7 +354,7 @@ public: } // Bad case: We have to memcpy. - // We can avoid by initializing the QRingBuffer with basicBlockSize of 0 + // We can avoid by initializing the QRingBuffer with QT_BUFFSIZE of 0 // and only using this read() function. QByteArray qba(readPointer(), nextDataBlockSize()); buffers.removeFirst(); @@ -442,7 +442,6 @@ private: QList buffers; int head, tail; int tailBuffer; // always buffers.size() - 1 - int basicBlockSize; int bufferSize; }; diff --git a/src/network/socket/qabstractsocket.cpp b/src/network/socket/qabstractsocket.cpp index e6b258f85..a4e2b0f6f 100644 --- a/src/network/socket/qabstractsocket.cpp +++ b/src/network/socket/qabstractsocket.cpp @@ -386,9 +386,6 @@ return returnValue; \ } } while (0) -#ifndef QABSTRACTSOCKET_BUFFERSIZE -#define QABSTRACTSOCKET_BUFFERSIZE 32768 -#endif #define QT_CONNECT_TIMEOUT 30000 #define QT_TRANSFER_TIMEOUT 120000 @@ -464,8 +461,6 @@ QAbstractSocketPrivate::QAbstractSocketPrivate() socketEngine(0), cachedSocketDescriptor(-1), readBufferMaxSize(0), - readBuffer(QABSTRACTSOCKET_BUFFERSIZE), - writeBuffer(QABSTRACTSOCKET_BUFFERSIZE), isBuffered(false), blockingTimeout(30000), connectTimer(0), -- 2.11.0