CMultiThreadServer.h

// SPDX-License-Identifier: LGPL-2.1-or-later OR GPL-2.0-or-later OR GPL-3.0-or-later OR LicenseRef-ImtCore-Commercial
#pragma once
 
 
// Qt includes
#include <QtCore/QReadWriteLock>
 
#if QT_VERSION >= 0x060400
#include <QtNetwork/QSslServer>
#endif
#include <QtNetwork/QSslConfiguration>
 
// ImtCore  includes
#include <imtrest/CTcpServerComp.h>
#include <imtrest/IResponseDispatcher.h>
#include <imtrest/CSocketThread.h>
 
 
namespace imtrest
{
 
 
class CMultiThreadServer :
#if QT_VERSION >= 0x060400
              public QSslServer,
#else
              public QTcpServer,
#endif
                     virtual public ilog::CLoggerBase,
                     virtual public IResponseDispatcher
{
       Q_OBJECT
public:
#if QT_VERSION >= 0x060400
       typedef QSslServer BaseClass;
#else
       typedef QTcpServer BaseClass;
#endif
       typedef ilog::CLoggerBase BaseClass2;
 
       explicit CMultiThreadServer(CTcpServerComp* rootServer);
       virtual ~CMultiThreadServer();
 
       imtrest::IRequestServlet* GetRequestServlet();
       imtrest::IProtocolEngine* GetProtocolEngine();
 
       [[nodiscard]] bool IsSecureConnection() const;
       void EnableSecureConnection(bool isSecureConnection = true);
 
       void SetSslConfiguration(const QSslConfiguration& sslConfiguration);
 
       // reimplemented (imtrest::IResponseDispatcher)
       virtual bool SendResponse(const QByteArray& requestId, ConstResponsePtr& response) const override;
       virtual bool SendRequest(const QByteArray& requestId, ConstRequestPtr& request) const override;
 
Q_SIGNALS:
       void NewThreadConnection(const IRequest* request, const QByteArray& subCommandId);
 
public Q_SLOTS:
       void Disconnected(QByteArray requestId);
 
protected Q_SLOTS:
       void ShutdownServer();
 
protected:
       void AddSocketDescriptor(qintptr socketDescriptor);
       qintptr PopSocketDescriptor();
 
       // reimplemented (QTcpServer)
       virtual void incomingConnection(qintptr socketDescriptor) override;
 
protected:
       QList<QPointer<CSocketThread>> m_threadSocketList;
       CTcpServerComp& m_rootServer;
       mutable QList<qintptr> m_descriptorList;
       mutable QMutex m_descriptorListMutex;
       mutable QReadWriteLock m_threadSocketListGuard;
       bool m_isActive;
       bool m_isSecureConnection;
       QSslConfiguration m_sslConfiguration;
};
 
 
} // namespace imtrest