Page MenuHomePhorge
Files F117885954

commitqueue.cpp
No OneTemporary
Actions

Authored By
Unknown
Size
2 KB
Referenced Files
None
Subscribers
None

commitqueue.cpp
View Options

/*
* This file is part of the KDE Baloo Project
* Copyright (C) 2013 Vishesh Handa <me@vhanda.in>
*
* This library is free software; you can redistribute it and/or
* modify it under the terms of the GNU Lesser General Public
* License as published by the Free Software Foundation; either
* version 2.1 of the License, or (at your option) version 3, or any
* later version accepted by the membership of KDE e.V. (or its
* successor approved by the membership of KDE e.V.), which shall
* act as a proxy defined in Section 6 of version 3 of the license.
*
* 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
* Lesser General Public License for more details.
*
* You should have received a copy of the GNU Lesser General Public
* License along with this library. If not, see <http://www.gnu.org/licenses/>.
*
*/
#include "commitqueue.h"
#include "database.h"
#include <KDebug>
#include <KDiskFreeSpaceInfo>
#include <QCoreApplication>
#include "xapiandocument.h"
Baloo::CommitQueue::CommitQueue(Database* db, QObject* parent)
: QObject(parent)
, m_db(db)
{
m_smallTimer.setSingleShot(true);
m_smallTimer.setInterval(200);
connect(&m_smallTimer, SIGNAL(timeout()), this, SLOT(commit()));
m_largeTimer.setSingleShot(true);
m_largeTimer.setInterval(10000);
connect(&m_largeTimer, SIGNAL(timeout()), this, SLOT(commit()));
}
Baloo::CommitQueue::~CommitQueue()
{
commit();
}
void Baloo::CommitQueue::add(unsigned id, Xapian::Document doc)
{
m_db->xapianDatabase()->replaceDocument(id, doc);
startTimers();
}
void Baloo::CommitQueue::remove(unsigned int docid)
{
m_db->xapianDatabase()->deleteDocument(docid);
startTimers();
}
void Baloo::CommitQueue::startTimers()
{
m_smallTimer.start();
if (!m_largeTimer.isActive()) {
m_largeTimer.start();
}
}
void Baloo::CommitQueue::commit()
{
// The 200 mb is arbitrary
KDiskFreeSpaceInfo info = KDiskFreeSpaceInfo::freeSpaceInfo(m_db->path());
if (info.isValid() && info.available() <= 200 * 1024 * 1024) {
kError() << "Low disk space. Aborting!!";
QCoreApplication::instance()->quit();
return;
}
m_db->sqlDatabase().commit();
m_db->sqlDatabase().transaction();
kDebug() << "SQL Committed";
m_db->xapianDatabase()->commit();
m_smallTimer.stop();
m_largeTimer.stop();
Q_EMIT committed();
}

File Metadata

Mime Type
text/x-c
Expires
Mon, Apr 6, 2:18 AM (1 w, 3 d ago)
Storage Engine
local-disk
Storage Format
Raw Data
Storage Handle
5c/4b/20950bf44e266474902ab18e7501
Default Alt Text
commitqueue.cpp (2 KB)

Event Timeline