File indexing completed on 2024-05-12 17:16:00

 /***************************************************************************
  *   Copyright (C) 2006-2009 by Rajko Albrecht                             *
  *   ral@alwins-world.de                                                   *
  *                                                                         *
  *   This program is free software; you can redistribute it and/or modify  *
  *   it under the terms of the GNU General Public License as published by  *
  *   the Free Software Foundation; either version 2 of the License, or     *
  *   (at your option) any later version.                                   *
  *                                                                         *
  *   This program is distributed in the hope that it will be useful,       *
  *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
  *   GNU General Public License for more details.                          *
  *                                                                         *
  *   You should have received a copy of the GNU General Public License     *
  *   along with this program; if not, write to the                         *
  *   Free Software Foundation, Inc.,                                       *
  *   51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.         *
  ***************************************************************************/
 #include "kiobytestream.h"
 
 #include <QMimeDatabase>
 
 KioByteStream::KioByteStream(StreamWrittenCb *aCb, const QString &filename)
     : svn::stream::SvnStream(false, true, nullptr),
       m_Cb(aCb), m_Written(0),
       m_mimeSend(false), m_Filename(filename)
 {
     m_MessageTick.start();
 }
 
 KioByteStream::~KioByteStream()
 {
 }
 
 bool KioByteStream::isOk() const
 {
     return m_Cb != nullptr;
 }
 
 long KioByteStream::write(const char *data, const unsigned long max)
 {
     bool forceInfo = !m_mimeSend;
     if (m_Cb) {
         if (!m_mimeSend) {
             m_mimeSend = true;
             array = QByteArray::fromRawData(data, max);
             QMimeDatabase db;
             QMimeType result = db.mimeTypeForFileNameAndData(m_Filename, array);
             m_Cb->streamSendMime(result);
             array.clear();
         }
         array = QByteArray::fromRawData(data, max);
         m_Cb->streamPushData(array);
         array.clear();
         m_Written += max;
         if (m_MessageTick.elapsed() >= 100 || forceInfo) {
             m_Cb->streamWritten(m_Written);
             m_MessageTick.restart();
         }
         return max;
     }
     return -1;
 }