StreamBuffer.cpp

   1 #include "StreamBuffer.h"
   2
   3
   4 StreamBuffer::StreamBuffer(QObject *parent) : QTemporaryFile(parent)
   5 {
   6         //
   7 }
   8
   9
  10 StreamBuffer::~StreamBuffer()
  11 {
  12         //
  13 }
  14
  15 bool
  16 StreamBuffer::open()
  17 {
  18     setAutoRemove(false);
  19     return QTemporaryFile::open(QIODevice::WriteOnly);
  20 }
  21
  22
  23 qint64 StreamBuffer::appendBuffer(const char *data, qint64 len)
  24 {
  25     qint64 _pos = pos();
  26
  27
  28     m_mutex.lock();
  29     m_rwLock.lockForRead();
  30
  31     seek(size());
  32
  33     qint64 _out = write(data, len);
  34
  35     flush();
  36
  37     seek(_pos);
  38
  39     m_rwLock.unlock();
  40     m_mutex.unlock();
  41
  42     return _out;
  43 }
  44
  45 bool StreamBuffer::isSequential () const
  46 {
  47     return true;
  48
  49 }