qsctpserver.cpp

Go to the documentation of this file.

// Copyright (C) 2016 Alex Trotsenko <alex1973tr@gmail.com>
// SPDX-License-Identifier: LicenseRef-Qt-Commercial OR LGPL-3.0-only OR GPL-2.0-only OR GPL-3.0-only
 
//#define QSCTPSERVER_DEBUG
 
#include "qsctpserver.h"
#include "qsctpserver_p.h"
 
#include "qsctpsocket.h"
#include "qabstractsocketengine_p.h"
 
#ifdef QSCTPSERVER_DEBUG
#include <qdebug.h>
#endif
 
QT_BEGIN_NAMESPACE
 
QSctpServerPrivate::QSctpServerPrivate()
    : maximumChannelCount(0)
{
}
 
QSctpServerPrivate::~QSctpServerPrivate()
{
}
 
void QSctpServerPrivate::configureCreatedSocket()
{
    QTcpServerPrivate::configureCreatedSocket();
    if (socketEngine)
        socketEngine->setOption(QAbstractSocketEngine::MaxStreamsSocketOption,
                                maximumChannelCount == -1 ? 1 : maximumChannelCount);
}
 
QSctpServer::QSctpServer(QObject *parent)
    : QTcpServer(QAbstractSocket::SctpSocket, *new QSctpServerPrivate, parent)
{
#if defined(QSCTPSERVER_DEBUG)
    qDebug("QSctpServer::QSctpServer()");
#endif
}
 
QSctpServer::~QSctpServer()
{
#if defined(QSCTPSERVER_DEBUG)
    qDebug("QSctpServer::~QSctpServer()");
#endif
}
 
void QSctpServer::setMaximumChannelCount(int count)
{
    Q_D(QSctpServer);
    if (d->state != QAbstractSocket::UnconnectedState) {
        qWarning("QSctpServer::setMaximumChannelCount() is only allowed in UnconnectedState");
        return;
    }
#if defined(QSCTPSERVER_DEBUG)
    qDebug("QSctpServer::setMaximumChannelCount(%i)", count);
#endif
    d->maximumChannelCount = count;
}
 
int QSctpServer::maximumChannelCount() const
{
    return d_func()->maximumChannelCount;
}
 
void QSctpServer::incomingConnection(qintptr socketDescriptor)
{
#if defined (QSCTPSERVER_DEBUG)
    qDebug("QSctpServer::incomingConnection(%i)", socketDescriptor);
#endif
 
    QSctpSocket *socket = new QSctpSocket(this);
    socket->setMaximumChannelCount(d_func()->maximumChannelCount);
    socket->setSocketDescriptor(socketDescriptor);
    addPendingConnection(socket);
}
 
QSctpSocket *QSctpServer::nextPendingDatagramConnection()
{
    Q_D(QSctpServer);
 
    for (auto it = d->pendingConnections.begin(), end = d->pendingConnections.end(); it != end; ++it) {
        QSctpSocket *socket = qobject_cast<QSctpSocket *>(*it);
        Q_ASSERT(socket);
 
        if (socket->isInDatagramMode()) {
            d->pendingConnections.erase(it);
            Q_ASSERT(d->socketEngine);
            d->socketEngine->setReadNotificationEnabled(true);
            return socket;
        }
    }
 
    return nullptr;
}
 
QT_END_NAMESPACE
 
#include "moc_qsctpserver.cpp"