GCActivityCallback.cpp [plain text]
#include "config.h"
#include "GCActivityCallback.h"
#include "APIShims.h"
#include "Heap.h"
#include "VM.h"
#include "JSLock.h"
#include "JSObject.h"
#include <wtf/RetainPtr.h>
#include <wtf/WTFThreadData.h>
#if PLATFORM(EFL)
#include <wtf/MainThread.h>
#endif
namespace JSC {
#if USE(CF) || PLATFORM(QT) || PLATFORM(EFL)
const double gcTimeSlicePerMB = 0.01; const double maxGCTimeSlice = 0.05; const double timerSlop = 2.0; const double pagingTimeOut = 0.1; const double hour = 60 * 60;
#if USE(CF)
DefaultGCActivityCallback::DefaultGCActivityCallback(Heap* heap)
: GCActivityCallback(heap->vm(), CFRunLoopGetCurrent())
, m_delay(s_decade)
{
}
DefaultGCActivityCallback::DefaultGCActivityCallback(Heap* heap, CFRunLoopRef runLoop)
: GCActivityCallback(heap->vm(), runLoop)
, m_delay(s_decade)
{
}
#elif PLATFORM(QT)
DefaultGCActivityCallback::DefaultGCActivityCallback(Heap* heap)
: GCActivityCallback(heap->vm())
, m_delay(hour)
{
}
#elif PLATFORM(EFL)
DefaultGCActivityCallback::DefaultGCActivityCallback(Heap* heap)
: GCActivityCallback(heap->vm(), WTF::isMainThread())
, m_delay(hour)
{
}
#endif
void DefaultGCActivityCallback::doWork()
{
Heap* heap = &m_vm->heap;
if (!isEnabled())
return;
APIEntryShim shim(m_vm);
#if !PLATFORM(IOS)
double startTime = WTF::monotonicallyIncreasingTime();
if (heap->isPagedOut(startTime + pagingTimeOut)) {
heap->activityCallback()->cancel();
heap->increaseLastGCLength(pagingTimeOut);
return;
}
#endif
heap->collect(Heap::DoNotSweep);
}
#if USE(CF)
void DefaultGCActivityCallback::scheduleTimer(double newDelay)
{
if (newDelay * timerSlop > m_delay)
return;
double delta = m_delay - newDelay;
m_delay = newDelay;
CFRunLoopTimerSetNextFireDate(m_timer.get(), CFRunLoopTimerGetNextFireDate(m_timer.get()) - delta);
}
void DefaultGCActivityCallback::cancelTimer()
{
m_delay = s_decade;
CFRunLoopTimerSetNextFireDate(m_timer.get(), CFAbsoluteTimeGetCurrent() + s_decade);
}
#elif PLATFORM(QT)
void DefaultGCActivityCallback::scheduleTimer(double newDelay)
{
if (newDelay * timerSlop > m_delay)
return;
m_delay = newDelay;
m_timer.start(newDelay * 1000, this);
}
void DefaultGCActivityCallback::cancelTimer()
{
m_delay = hour;
m_timer.stop();
}
#elif PLATFORM(EFL)
void DefaultGCActivityCallback::scheduleTimer(double newDelay)
{
if (newDelay * timerSlop > m_delay)
return;
stop();
m_delay = newDelay;
ASSERT(!m_timer);
m_timer = add(newDelay, this);
}
void DefaultGCActivityCallback::cancelTimer()
{
m_delay = hour;
stop();
}
#endif
void DefaultGCActivityCallback::didAllocate(size_t bytes)
{
#if PLATFORM(EFL)
if (!isEnabled())
return;
ASSERT(WTF::isMainThread());
#endif
if (!bytes)
bytes = 1;
Heap* heap = static_cast<Heap*>(&m_vm->heap);
double gcTimeSlice = std::min((static_cast<double>(bytes) / MB) * gcTimeSlicePerMB, maxGCTimeSlice);
double newDelay = heap->lastGCLength() / gcTimeSlice;
scheduleTimer(newDelay);
}
void DefaultGCActivityCallback::willCollect()
{
cancelTimer();
}
void DefaultGCActivityCallback::cancel()
{
cancelTimer();
}
#else
DefaultGCActivityCallback::DefaultGCActivityCallback(Heap* heap)
: GCActivityCallback(heap->vm())
{
}
void DefaultGCActivityCallback::doWork()
{
}
void DefaultGCActivityCallback::didAllocate(size_t)
{
}
void DefaultGCActivityCallback::willCollect()
{
}
void DefaultGCActivityCallback::cancel()
{
}
#endif
}