SqlQueryWatcher.cpp

/*
    Copyright (C) 2011-2013 Klarälvdalens Datakonsult AB,
        a KDAB Group company, info@kdab.net,
        author Andras Mantia <andras.mantia@kdab.com>

    This library is free software; you can redistribute it and/or modify it
    under the terms of the GNU Library General Public License as published by
    the Free Software Foundation; either version 2 of the License, or (at your
    option) any later version.

    This library 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 Library General Public
    License for more details.

    You should have received a copy of the GNU Library General Public License
    along with this library; see the file COPYING.LIB.  If not, write to the
    Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor, Boston, MA
    02110-1301, USA.
*/

#include "SqlQueryWatcher.h"

#include <QDebug>
#include <QTimer>
#include <QEventLoop>
#include <QProcess>
#include <QMutex>

#ifdef Q_OS_WIN
#include <process.h>
#else
#include <unistd.h>
#endif

#define SQL_NETWORK_TIMEOUT 30 //define how many seconds do we wait for a query finishes until the network error dialog is shown

QMutex mutex;
static bool s_dialogVisible = false;

SqlQueryWatcherHelper::SqlQueryWatcherHelper(QObject* runner):QObject(0)
{
//     qDebug() << Q_FUNC_INFO << this;
    m_process = 0;
    m_timer = new QTimer();
    m_timer->setSingleShot(true);
    connect( m_timer, SIGNAL(timeout()), SLOT(timerExpired()) );
    m_timer->start( SQL_NETWORK_TIMEOUT*1000 );
}

SqlQueryWatcherHelper::~SqlQueryWatcherHelper()
{
//     qDebug() << Q_FUNC_INFO << this;
    delete m_timer;
    if ( m_process ) {
        m_process->terminate();
        m_process->kill();
        m_process->waitForFinished();
    }
    emit endWatcher();
}

void SqlQueryWatcherHelper::dialogHidden()
{
    QMutexLocker locker(&mutex);
    s_dialogVisible = false;
}


void SqlQueryWatcherHelper::timerExpired()
{
    QMutexLocker locker(&mutex);
    if ( s_dialogVisible )
        return;
    s_dialogVisible = true;
    qDebug() << Q_FUNC_INFO << this;
    m_process = new QProcess(this);
    connect( m_process, SIGNAL(finished(int)), this, SLOT(dialogHidden()) );
    QStringList args;
    args << QLatin1String("-pid");
#ifdef Q_OS_WIN
    args << QString::number( _getpid() );
#else
    args << QString::number( ::getpid() );
#endif

    m_process->start( QLatin1String("queryWatcherHelper"), args );
    m_process->waitForStarted();
    if ( m_process->state() != QProcess::Running ) { //try to start from the build dir
        m_process->start( QLatin1String("src/helpers/queryWatcherHelper"), args );
        m_process->waitForStarted();
        if ( m_process->state() != QProcess::Running ) { //try to start from the build dir
            qWarning() << "Timer expired, query was too slow! Possible network error detected.";
        }
    }
}


void SqlQueryWatcherHelper::quit()
{
//     qDebug() << Q_FUNC_INFO;
    thread()->quit();
//     metaObject()->invokeMethod(thread(), "quit", Qt::DirectConnection);
}

#include "moc_SqlQueryWatcher.cpp"