mirror of
https://bitbucket.org/smil3y/katie.git
synced 2025-02-25 03:12:56 +00:00
use QT_BUFFSIZE as block size for QRingBuffer
Signed-off-by: Ivailo Monev <xakepa10@laimg.moc>
This commit is contained in:
parent
fe4603dc8f
commit
2dbe488dff
3 changed files with 9 additions and 16 deletions
|
@ -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)
|
||||
{
|
||||
}
|
||||
|
||||
|
|
|
@ -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<QByteArray> buffers;
|
||||
int head, tail;
|
||||
int tailBuffer; // always buffers.size() - 1
|
||||
int basicBlockSize;
|
||||
int bufferSize;
|
||||
};
|
||||
|
||||
|
|
|
@ -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),
|
||||
|
|
Loading…
Add table
Reference in a new issue