We are currently indexing your data, so search results may be incomplete until we finish.
|
|
// Copyright (C) 2009 Benjamin Pollack
// Copyright (C) 2009 Adrian Buehlmann
//
// 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, see <http://www.gnu.org/licenses/>.
#include "stdafx.h"
#include "Dirstatecache.h"
#include "dirstate.h"
#include "Winstat64.h"
#include "Thgstatus.h"
std::list<Dirstatecache::E>& Dirstatecache::cache()
{
static std::list<Dirstatecache::E> c;
return c;
}
Dirstate* Dirstatecache::get(
const std::string& hgroot, const std::string& cwd, bool& unset,
bool usekbfiles)
{
unset = false;
typedef std::list<E>::iterator Iter;
Iter iter = cache().begin();
for (;iter != cache().end(); ++iter)
{
if (hgroot == iter->hgroot && usekbfiles == iter->usekbfiles)
break;
}
Winstat64 stat;
std::string path = hgroot + (usekbfiles ? "\\.hg\\kilnbfiles\\dirstate"
: "\\.hg\\dirstate");
unsigned tc = GetTickCount();
bool new_stat = false;
if (iter == cache().end())
{
if (stat.lstat(path.c_str()) != 0)
{
TDEBUG_TRACE("Dirstatecache::get: lstat(" << path <<") failed");
return 0;
}
TDEBUG_TRACE("Dirstatecache::get: lstat(" << path <<") ok ");
new_stat = true;
if (cache().size() >= 10)
{
TDEBUG_TRACE("Dirstatecache::get: dropping "
<< cache().back().hgroot);
delete cache().back().dstate;
cache().back().dstate = 0;
cache().pop_back();
}
E e;
e.hgroot = hgroot;
e.usekbfiles = usekbfiles;
cache().push_front(e);
iter = cache().begin();
iter->tickcount = tc;
}
if (!new_stat && tc - iter->tickcount > 500)
{
if (0 != stat.lstat(path.c_str()))
{
TDEBUG_TRACE("Dirstatecache::get: lstat(" << path <<") failed");
TDEBUG_TRACE("Dirstatecache::get: dropping " << iter->hgroot);
delete iter->dstate;
iter->dstate = 0;
cache().erase(iter);
return 0;
}
iter->tickcount = tc;
TDEBUG_TRACE("Dirstatecache::get: lstat(" << path <<") ok ");
new_stat = true;
}
if (iter->dstate)
{
unset = iter->unset;
if (!new_stat)
return iter->dstate;
if (iter->dstate_mtime == stat.mtime
&& iter->dstate_size == stat.size)
{
return iter->dstate;
}
TDEBUG_TRACE("Dirstatecache::get: refreshing " << hgroot);
}
else
{
TDEBUG_TRACE("Dirstatecache::get: reading " << hgroot);
}
unset = false;
unsigned tc0 = GetTickCount();
std::auto_ptr<Dirstate> ds = Dirstate::read(path, unset);
unsigned tc1 = GetTickCount();
bool request_thgstatus_update = true;
if (unset)
{
if (iter->unset)
{
TDEBUG_TRACE(
"Dirstatecache::get: **** old and new have unset entries");
request_thgstatus_update = false;
}
else
{
TDEBUG_TRACE("Dirstatecache::get: new has unset entries");
}
}
iter->unset = unset;
delete iter->dstate;
iter->dstate = ds.release();
unsigned delta = tc1 - tc0;
TDEBUG_TRACE("Dirstatecache::get: read done in " << delta << " ticks, "
<< cache().size() << " repos in cache");
iter->dstate_mtime = stat.mtime;
iter->dstate_size = stat.size;
if (request_thgstatus_update)
{
TDEBUG_TRACE("Dirstatecache::get: calling Thgstatus::update");
Thgstatus::update(cwd);
}
else
{
TDEBUG_TRACE("Dirstatecache::get: omitting Thgstatus::update");
}
return iter->dstate;
}
void Dirstatecache::invalidate(const std::string& hgroot, bool usekbfiles)
{
typedef std::list<E>::iterator Iter;
if (hgroot.empty())
return;
for (Iter i = cache().begin(); i != cache().end(); ++i)
{
if (hgroot == i->hgroot && usekbfiles == i->usekbfiles)
{
delete i->dstate;
i->dstate = 0;
cache().erase(i);
TDEBUG_TRACE("Dirstatecache::invalidate(" << hgroot << ")");
break;
}
}
}
|
Loading...