diff options
Diffstat (limited to 'src/svnfrontend/fillcachethread.cpp')
| -rw-r--r-- | src/svnfrontend/fillcachethread.cpp | 123 |
1 files changed, 123 insertions, 0 deletions
diff --git a/src/svnfrontend/fillcachethread.cpp b/src/svnfrontend/fillcachethread.cpp new file mode 100644 index 0000000..ddaa934 --- /dev/null +++ b/src/svnfrontend/fillcachethread.cpp @@ -0,0 +1,123 @@ +/*************************************************************************** + * Copyright (C) 2006-2007 by Rajko Albrecht * + * ral@alwins-world.de * + * * + * This program is free software; you can redistribute it and/or modify * + * it under the terms of the GNU General Public License as published by * + * the Free Software Foundation; either version 2 of the License, or * + * (at your option) any later version. * + * * + * This program 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 General Public License for more details. * + * * + * You should have received a copy of the GNU General Public License * + * along with this program; if not, write to the * + * Free Software Foundation, Inc., * + * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301, USA. * + ***************************************************************************/ +#include "fillcachethread.h" +#include "tcontextlistener.h" + +#include "src/svnqt/cache/LogCache.hpp" +#include "src/svnqt/cache/ReposLog.hpp" +#include "src/svnqt/cache/DatabaseException.hpp" +#include "src/kdesvn_events.h" + +#include <qobject.h> +#include <kdebug.h> +#include <kapplication.h> +#include <klocale.h> + +FillCacheThread::FillCacheThread(QObject*_parent,const QString&reposRoot) + : QThread(),mutex(),m_SvnContextListener(0) +{ + m_Parent = _parent; + m_CurrentContext = new svn::Context(); + + m_SvnContextListener = new ThreadContextListener(m_Parent); + QObject::connect(m_SvnContextListener,SIGNAL(sendNotify(const QString&)),m_Parent,SLOT(slotNotifyMessage(const QString&))); + + m_CurrentContext->setListener(m_SvnContextListener); + m_what = reposRoot; + m_Svnclient = svn::Client::getobject(m_CurrentContext,0); +} + +FillCacheThread::~FillCacheThread() +{ + m_CurrentContext->setListener(0); + delete m_Svnclient; + m_SvnContextListener=0; +} + +const QString&FillCacheThread::reposRoot()const +{ + return m_what; +} + +void FillCacheThread::cancelMe() +{ + // method is threadsafe! + m_SvnContextListener->setCanceled(true); +} + +void FillCacheThread::run() +{ + svn::Revision where = svn::Revision::HEAD; + QString ex; + svn::cache::ReposLog rl(m_Svnclient,m_what); + bool breakit=false; + KApplication*k = KApplication::kApplication(); + try { + svn::Revision latestCache = rl.latestCachedRev(); + svn::Revision Head = rl.latestHeadRev(); + Q_LLONG i = latestCache.revnum(); + if (i<0) { + i=0; + } + Q_LLONG j = Head.revnum(); + + Q_LLONG _max=j-i; + Q_LLONG _cur=0; + + FillCacheStatusEvent*fev; + if (k) { + fev = new FillCacheStatusEvent(_cur,_max); + k->postEvent(m_Parent,fev); + } + + if (i<j) { + for (;i<j;i+=200) { + _cur+=200; + rl.fillCache(i); + + if (m_SvnContextListener->contextCancel()) { + m_SvnContextListener->contextNotify(i18n("Filling cache canceled.")); + breakit=true; + break; + } + if (latestCache==rl.latestCachedRev()) { + break; + } + if (k) { + fev = new FillCacheStatusEvent(_cur>_max?_max:_cur,_max); + k->postEvent(m_Parent,fev); + } + latestCache=rl.latestCachedRev(); + } + if (latestCache.revnum()<Head.revnum()) { + rl.fillCache(Head.revnum()); + } + i=Head.revnum(); + m_SvnContextListener->contextNotify(i18n("Cache filled up to revision %1").arg(i)); + } + } catch (const svn::Exception&e) { + m_SvnContextListener->contextNotify(e.msg()); + } + if (k && !breakit) { + QCustomEvent*ev = new QCustomEvent(EVENT_LOGCACHE_FINISHED); + ev->setData((void*)this); + k->postEvent(m_Parent,ev); + } +} |