shell/language.cpp

   1 /***************************************************************************
   2  *   Copyright 2006 Hamish Rodda <rodda@kde.org>                       *
   3  *   Copyright 2007 Alexander Dymo <adymo@kdevelop.org>             *
   4  *                                                                         *
   5  *   This program is free software; you can redistribute it and/or modify  *
   6  *   it under the terms of the GNU Library General Public License as       *
   7  *   published by the Free Software Foundation; either version 2 of the    *
   8  *   License, or (at your option) any later version.                       *
   9  *                                                                         *
  10  *   This program is distributed in the hope that it will be useful,       *
  11  *   but WITHOUT ANY WARRANTY; without even the implied warranty of        *
  12  *   MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the         *
  13  *   GNU General Public License for more details.                          *
  14  *                                                                         *
  15  *   You should have received a copy of the GNU Library General Public     *
  16  *   License along with this program; if not, write to the                 *
  17  *   Free Software Foundation, Inc.,                                       *
  18  *   51 Franklin Street, Fifth Floor, Boston, MA  02110-1301, USA.         *
  19  ***************************************************************************/
  20 #include "language.h"
  21
  22 #include <QHash>
  23 #include <QMutex>
  24 #include <QThread>
  25
  26 #include <kdebug.h>
  27
  28 #include <language/interfaces/ilanguagesupport.h>
  29
  30 namespace KDevelop {
  31
  32 struct LanguagePrivate {
  33     ILanguageSupport *support;
  34
  35     mutable QHash<QThread*, QMutex*> parseMutexes;
  36     QMutex mutexMutex;
  37 };
  38
  39 Language::Language(ILanguageSupport *support, QObject *parent)
  40     : ILanguage(support->name(), parent)
  41 {
  42     kDebug() << "creating language" << support->name();
  43
  44     d = new LanguagePrivate;
  45     d->support = support;
  46 }
  47
  48 Language::~Language()
  49 {
  50     delete d;
  51 }
  52
  53 void Language::deactivate()
  54 {
  55     kDebug() << "deactivating language" << name();
  56 }
  57
  58 void Language::activate()
  59 {
  60     kDebug() << "activating language" << name();
  61 }
  62
  63 ILanguageSupport *Language::languageSupport()
  64 {
  65     return d->support;
  66 }
  67
  68 QMutex *Language::parseMutex(QThread *thread) const
  69 {
  70     Q_ASSERT(thread);
  71
  72     QMutexLocker lock(&d->mutexMutex);
  73
  74     if (!d->parseMutexes.contains(thread)) {
  75         connect(thread, SIGNAL(finished()), SLOT(threadFinished()));
  76         d->parseMutexes.insert(thread, new QMutex(QMutex::Recursive));
  77     }
  78
  79     return d->parseMutexes[thread];
  80 }
  81
  82 void Language::lockAllParseMutexes()
  83 {
  84     QMutexLocker lock(&d->mutexMutex);
  85
  86     QList<QMutex*> waitForLock;
  87
  88     // Grab the easy pickings first
  89     QHashIterator<QThread*, QMutex*> it = d->parseMutexes;
  90     while (it.hasNext()) {
  91         it.next();
  92         if (!it.value()->tryLock())
  93         waitForLock.append(it.value());
  94     }
  95
  96     lock.unlock();
  97     // Work through the stragglers. mutexMutex must be unlocked, else we deadlock.
  98     foreach (QMutex* mutex, waitForLock)
  99         mutex->lock();
 100 }
 101
 102 void Language::unlockAllParseMutexes()
 103 {
 104     QMutexLocker lock(&d->mutexMutex);
 105
 106     foreach(QMutex* mutex, d->parseMutexes)
 107         mutex->unlock();
 108 }
 109
 110 void Language::threadFinished()
 111 {
 112     Q_ASSERT(sender());
 113
 114     QMutexLocker lock(&d->mutexMutex);
 115
 116     QThread* thread = static_cast<QThread*>(sender());
 117
 118     Q_ASSERT(d->parseMutexes.contains(thread));
 119
 120     QMutex* mutex = d->parseMutexes[thread];
 121     mutex->unlock();
 122     delete mutex;
 123     d->parseMutexes.remove(thread);
 124 }
 125
 126 }
 127
 128 #include "language.moc"
 129