File indexing completed on 2025-01-05 03:53:05

 /* ============================================================
  *
  * This file is a part of digiKam project
  * https://www.digikam.org
  *
  * Date        : 2021-07-24
  * Description : a MJPEG Stream server to export items on the network.
  *
  * SPDX-FileCopyrightText: 2021-2024 by Gilles Caulier <caulier dot gilles at gmail dot com>
  *
  * SPDX-License-Identifier: GPL-2.0-or-later
  *
  * ============================================================ */
 
 #include "mjpegserver_p.h"
 
 // Qt includes
 
 #include <QBuffer>
 #include <QByteArray>
 #include <QIODevice>
 #include <QString>
 #include <QMutexLocker>
 
 // Local includes
 
 #include "digikam_debug.h"
 
 namespace DigikamGenericMjpegStreamPlugin
 {
 
 MjpegServer::MjpegServer(const QString& address,
                          int port,
                          QObject* const parent)
     : QObject(parent),
       d      (new Private(parent))
 {
     d->open(address, port);
     d->setMaxClients(10);
 }
 
 MjpegServer::~MjpegServer()
 {
     d->close();
 
     // NOTE: QObject based => self deletion.
 }
 
 bool MjpegServer::setRate(int ra)
 {
     if ((ra < 1) || (ra > 100))
     {
         qCWarning(DIGIKAM_GENERAL_LOG) << "Error: rate value is out of range: " << ra;
         return false;
     }
 
     d->rate  = ra;
     d->delay = (int)(1000000.0 / ra);
     qCDebug(DIGIKAM_GENERAL_LOG) << "MJPEG Server rate       :" << d->rate;
 
     return true;
 }
 
 int MjpegServer::rate() const
 {
     return d->rate;
 }
 
 bool MjpegServer::setMaxClients(int max)
 {
     if ((max < 1) || (max > 30))
     {
         qCWarning(DIGIKAM_GENERAL_LOG) << "Error: max clients value is out of range: " << max;
         return false;
     }
 
     d->setMaxClients(max);
 
     return true;
 }
 
 int MjpegServer::maxClients() const
 {
     return d->maxClients();
 }
 
 void MjpegServer::setBlackList(const QStringList& lst)
 {
     d->blackList = lst;
 }
 
 QStringList MjpegServer::blackList() const
 {
     return d->blackList;
 }
 
 void MjpegServer::slotWriteFrame(const QByteArray& frame)
 {
     d->mutexFrame.lock();
     {
         if (!frame.isNull())
         {
             // Perform a deep-copy of image data.
 
             d->lastFrame = QByteArray(frame.data(), frame.size());
         }
     }
     d->mutexFrame.unlock();
 }
 
 void MjpegServer::start()
 {
     d->start();
 }
 
 void MjpegServer::stop()
 {
     d->stop();
 }
 
 } // namespace DigikamGenericMjpegStreamPlugin
 
 #include "moc_mjpegserver.cpp"