#include "IsoHeapImpl.h"
#include "AllIsoHeaps.h"
#include "PerProcess.h"
#include <climits>
namespace bmalloc {
IsoHeapImplBase::IsoHeapImplBase()
{
}
IsoHeapImplBase::~IsoHeapImplBase()
{
}
void IsoHeapImplBase::addToAllIsoHeaps()
{
PerProcess<AllIsoHeaps>::get()->add(this);
}
void IsoHeapImplBase::scavengeNow()
{
Vector<DeferredDecommit> deferredDecommits;
scavenge(deferredDecommits);
finishScavenging(deferredDecommits);
}
void IsoHeapImplBase::finishScavenging(Vector<DeferredDecommit>& deferredDecommits)
{
std::sort(
deferredDecommits.begin(), deferredDecommits.end(),
[&] (const DeferredDecommit& a, const DeferredDecommit& b) -> bool {
return a.page < b.page;
});
unsigned runStartIndex = UINT_MAX;
char* run = nullptr;
size_t size = 0;
auto resetRun = [&] (unsigned endIndex) {
if (!run) {
RELEASE_BASSERT(!size);
RELEASE_BASSERT(runStartIndex == UINT_MAX);
return;
}
RELEASE_BASSERT(size);
RELEASE_BASSERT(runStartIndex != UINT_MAX);
vmDeallocatePhysicalPages(run, size);
for (unsigned i = runStartIndex; i < endIndex; ++i) {
const DeferredDecommit& value = deferredDecommits[i];
value.directory->didDecommit(value.pageIndex);
}
run = nullptr;
size = 0;
runStartIndex = UINT_MAX;
};
for (unsigned i = 0; i < deferredDecommits.size(); ++i) {
const DeferredDecommit& value = deferredDecommits[i];
char* page = reinterpret_cast<char*>(value.page);
RELEASE_BASSERT(page >= run + size);
if (page != run + size) {
resetRun(i);
runStartIndex = i;
run = page;
}
size += IsoPageBase::pageSize;
}
resetRun(deferredDecommits.size());
}
}