mjpegserver_p.h

Go to the documentation of this file.

/* ============================================================
 *
 * 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.
 *
 * Copyright (C) 2021-2022 by Gilles Caulier <caulier dot gilles at gmail dot com>
 *
 * 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, 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.
 *
 * ============================================================ */
 
#ifndef DIGIKAM_MJPEG_SERVER_P_H
#define DIGIKAM_MJPEG_SERVER_P_H
 
// Qt includes
 
#include <QList>
#include <QStringList>
#include <QFuture>
#include <QMutex>
#include <QTcpSocket>
#include <QTcpServer>
#include <QByteArray>
 
// Local includes
 
#include "mjpegserver.h"
#include "digikam_debug.h"
 
namespace DigikamGenericMjpegStreamPlugin
{
 
class Q_DECL_HIDDEN MjpegServer::Private : public QObject
{
    Q_OBJECT
 
public:
 
    explicit Private(QObject* const parent);
    ~Private();
 
    void setMaxClients(int);
    int  maxClients() const;
 
    int writeInSocket(int sock, const QByteArray& data) const;
 
    QString clientDescription(QTcpSocket* const client) const;
 
    bool isOpened() const;
 
    bool open(const QString& address, int port);
 
    void start();
 
    void stop();
 
    void close();
 
public:
 
    QTcpServer*        server;       
    int                rate;         
    int                delay;        
    QList<QTcpSocket*> clients;      
    QByteArray         lastFrame;    
    QFuture<void>      srvTask;      
    QMutex             mutexClients; 
    QMutex             mutexFrame;   
    QStringList        blackList;    
 
private Q_SLOTS:
 
    void slotNewConnection();
 
    void slotClientDisconnected();
 
private:
 
    void writerThread();
 
    void clientWriteMultithreaded(int client, const QByteArray& data);
};
 
} // namespace DigikamGenericMjpegStreamPlugin
 
#endif // DIGIKAM_MJPEG_SERVER_P_H