← Back to branch summary

~ubuntu-branches/ubuntu/quantal/kde-runtime/quantal

« back to all changes in this revision

Viewing changes to nepomuk/services/storage/lib/kdbusconnectionpool.cpp

  • Committer: Package Import Robot
  • Author(s): Philip Muškovac
  • Date: 2012-06-03 21:50:00 UTC
  • mto: This revision was merged to the branch mainline in revision 21.
  • Revision ID: package-import@ubuntu.com-20120603215000-vn7oarsq0ynrydj5
Tags: upstream-4.8.80
Import upstream version 4.8.80

Show diffs side-by-side

added added

removed removed

Lines of Context:
nepomuk/services/storage/lib/kdbusconnectionpool.cpp
1
 
/*
2
 
 * This file is part of the Nepomuk KDE project.
3
 
 * Copyright (C) 2010 Sebastian Trueg <trueg@kde.org>
4
 
 * Copyright (C) 2010 David Faure <faure@kde.org>
5
 
 *
6
 
 * This library is free software; you can redistribute it and/or
7
 
 * modify it under the terms of the GNU Library General Public
8
 
 * License as published by the Free Software Foundation; either
9
 
 * version 2 of the License, or (at your option) any later version.
10
 
 *
11
 
 * This library is distributed in the hope that it will be useful,
12
 
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
13
 
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the GNU
14
 
 * Library General Public License for more details.
15
 
 *
16
 
 * You should have received a copy of the GNU Library General Public License
17
 
 * along with this library; see the file COPYING.LIB.  If not, write to
18
 
 * the Free Software Foundation, Inc., 51 Franklin Street, Fifth Floor,
19
 
 * Boston, MA 02110-1301, USA.
20
 
 */
21
 
 
22
 
#include "kdbusconnectionpool.h"
23
 
#include <QThreadStorage>
24
 
 
25
 
namespace {
26
 
QAtomicInt s_connectionCounter;
27
 
 
28
 
class KDBusConnectionPoolPrivate
29
 
{
30
 
public:
31
 
    KDBusConnectionPoolPrivate()
32
 
        : m_connection( QDBusConnection::connectToBus(
33
 
                            QDBusConnection::SessionBus,
34
 
                            QString::fromLatin1("NepomukQueryServiceConnection%1").arg(newNumber()) ) )
35
 
    {
36
 
    }
37
 
 
38
 
    ~KDBusConnectionPoolPrivate()
39
 
    {
40
 
        QDBusConnection::disconnectFromBus( m_connection.name() );
41
 
    }
42
 
 
43
 
    QDBusConnection connection() const
44
 
    {
45
 
        return m_connection;
46
 
    }
47
 
 
48
 
private:
49
 
    static int newNumber()
50
 
    {
51
 
        return s_connectionCounter.fetchAndAddAcquire(1);
52
 
    }
53
 
 
54
 
    QDBusConnection m_connection;
55
 
};
56
 
} // namespace
57
 
 
58
 
QThreadStorage<KDBusConnectionPoolPrivate *> s_perThreadConnection;
59
 
 
60
 
QDBusConnection KDBusConnectionPool::threadConnection()
61
 
{
62
 
    if (!s_perThreadConnection.hasLocalData()) {
63
 
        s_perThreadConnection.setLocalData(new KDBusConnectionPoolPrivate);
64
 
    }
65
 
 
66
 
    return s_perThreadConnection.localData()->connection();
67
 
}
68