orK/src/srcp_socket.cpp

Go to the documentation of this file.

#include "srcp_socket.h"

//
// SrcpThread :
//

SrcpThread::SrcpThread( QObject* parent ) : QThread( parent )
{
        _stopFlag = TRUE ;
        _infoSocket = static_cast<SrcpSocket*>( parent ) ;
}

SrcpThread::~SrcpThread()
{
        stop() ;
}

void SrcpThread::run()
{
        _stopFlag = FALSE ;
        QString info ;
        
        while( ! _stopFlag ) // The flag can be changed by calling stop()
        {
                info = _infoSocket->srcpReadLine() ;
                if ( ! info.isEmpty() )
                        emit infoReceived( info );
        }
        
        _infoSocket->disconnectFromHost() ;
}

void SrcpThread::stop()
{
        _stopFlag = TRUE ;
}


//
// SrcpSocket :
//

SrcpSocket::SrcpSocket( const QString &type, QObject* parent ) : QTcpSocket( parent )
{
        _type = type ;
        _internThread = 0 ; // Lazy object
}

SrcpSocket::~SrcpSocket()
{
        threadSafeDisconnectFromHost() ;
}

QString SrcpSocket::type()
{
        return _type ;
}

void SrcpSocket::start()
{
        if ( _internThread == 0 ) // Create and connect lazy object if needed
        {
                _internThread = new SrcpThread( this ) ;
                connect( _internThread, SIGNAL( infoReceived( QString ) ),
                                        this, SIGNAL( infoReceived( QString ) ) ) ;
        }
        _internThread->start() ;
}

void SrcpSocket::threadSafeDisconnectFromHost()
{
        if ( _internThread != 0 && _internThread->isRunning() )
                _internThread->stop() ;
        else
                disconnectFromHost() ;
}

bool SrcpSocket::sendMsg( QString msg )
{
        if ( state() != QAbstractSocket::ConnectedState )
                return FALSE ;
                
qDebug() << type() << " Srcp 0.8.3 sent : " << msg ;
        
        msg += "\n" ; // mandatory for srcp (end of message)
        
        if ( write( msg.toAscii () ) == -1 ) // send message and check for socketError
        {
                emit errorOccured( trUtf8( "Impossible to send the message to the server") );
                return FALSE ;
        }

        return TRUE ;
}

QString SrcpSocket::srcpReadLine()
{
        if ( state() != QAbstractSocket::ConnectedState )
        {
                emit errorOccured( trUtf8( "Impossible to read : not connected") );
                return QString() ;
        }
                
        char buf[1000]; // max allowed length of SRCP reply line
        
        if ( atEnd() && ! waitForReadyRead( 1000 ) ) // [msec] return false if timedout
        {
                emit errorOccured( trUtf8( "Impossible to read : no data or timedout") );
                return QString() ;
        }
        
        if ( readLine( buf, sizeof( buf ) ) == -1) // read the server reply and check for socketError
        {
                emit errorOccured( trUtf8( "Impossible to read the reply of the server") );
                return QString();
        }
        
        QString reply = QString( buf ).trimmed() ; // whitespace removed from the start and the end
        if ( reply.endsWith("\\") ) // check if reply is spread over many lines
        {
                reply = reply.replace( "\\", "" ) ; // clean string
                reply  += srcpReadLine() ;
        }
        
qDebug() << type() << " SRCP 0.8.3 received : " << reply ;
        
        return reply ;
}

/*
void ::handleSocketError( QAbstractSocket::SocketError socketError )
{
        switch( socketError )
        {
                case QAbstractSocket::RemoteHostClosedError :

                        break ;

                case QAbstractSocket::HostNotFoundError :

                        QMessageBox::information( 0, tr ( "orK network error" ), tr ( "The host was not found. Please check the host name and port settings." ) ) ;
                        break ;

                case QAbstractSocket::ConnectionRefusedError :

                        QMessageBox::information( 0, tr ( "orK network error" ), tr("The connection was refused by the peer. Make sure the SRCP server is running, and check that the host name and port settings are correct." ) ) ;
                        break ;

                default :

                        QMessageBox::information( 0, tr ( "orK network error" ),tr ( "Unreach error. %1" ).arg ( _socket->errorString () ) ) ;
        }
}
*/

---