1231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block/* 2231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * Copyright (C) 2009 Maxime Simon <simon.maxime@gmail.com> 3231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * 4231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * Redistribution and use in source and binary forms, with or without 5231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * modification, are permitted provided that the following conditions 6231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * are met: 7231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * 1. Redistributions of source code must retain the above copyright 8231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * notice, this list of conditions and the following disclaimer. 9231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * 2. Redistributions in binary form must reproduce the above copyright 10231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * notice, this list of conditions and the following disclaimer in the 11231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * documentation and/or other materials provided with the distribution. 12231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * 13231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * THIS SOFTWARE IS PROVIDED BY APPLE COMPUTER, INC. ``AS IS'' AND ANY 14231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT LIMITED TO, THE 15231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR A PARTICULAR 16231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL APPLE COMPUTER, INC. OR 17231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, SPECIAL, 18231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT LIMITED TO, 19231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, DATA, OR 20231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY THEORY 21231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT 22231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE 23231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block * OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. 24231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block */ 25231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 26231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block#include "config.h" 27231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block#include "SharedTimer.h" 28231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 29231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block#include <MessageFilter.h> 30231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block#include <MessageRunner.h> 31231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block#include <Looper.h> 32231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block#include <support/Locker.h> 33231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block#include <support/Autolock.h> 34231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block#include <wtf/CurrentTime.h> 35231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 36231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block#define FIRE_MESSAGE 'fire' 37231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 38231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 39231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Blocknamespace WebCore { 40231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 41231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Blockclass SharedTimerHaiku: public BMessageFilter { 42231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block friend void setSharedTimerFiredFunction(void (*f)()); 43231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Blockpublic: 44231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block static SharedTimerHaiku* instance(); 45231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 46231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block void start(double); 47231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block void stop(); 48231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 49231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Blockprotected: 50231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block virtual filter_result Filter(BMessage*, BHandler**); 51231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 52231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Blockprivate: 53231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block SharedTimerHaiku(); 54231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block ~SharedTimerHaiku(); 55231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 56231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block void (*m_timerFunction)(); 57231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block bool m_shouldRun; 58231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block}; 59231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 60231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve BlockSharedTimerHaiku::SharedTimerHaiku() 61231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block : BMessageFilter(FIRE_MESSAGE) 62231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block , m_timerFunction(0) 63231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block , m_shouldRun(false) 64231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block{ 65231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block} 66231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 67231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve BlockSharedTimerHaiku::~SharedTimerHaiku() 68231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block{ 69231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block} 70231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 71231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve BlockSharedTimerHaiku* SharedTimerHaiku::instance() 72231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block{ 73231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block BLooper* looper = BLooper::LooperForThread(find_thread(0)); 74231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block static SharedTimerHaiku* timer; 75231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 76231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block if (!timer) { 77231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block BAutolock lock(looper); 78231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block timer = new SharedTimerHaiku(); 79231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block looper->AddCommonFilter(timer); 80231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block } 81231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 82231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block return timer; 83231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block} 84231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 85231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Blockvoid SharedTimerHaiku::start(double fireTime) 86231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block{ 87231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block m_shouldRun = true; 88231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 89231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block double intervalInSeconds = fireTime - currentTime(); 90231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block bigtime_t intervalInMicroSeconds = intervalInSeconds < 0 ? 0 : intervalInSeconds * 1000000; 91231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 92231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block BMessageRunner::StartSending(Looper(), new BMessage(FIRE_MESSAGE), intervalInMicroSeconds, 1); 93231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block} 94231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 95231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Blockvoid SharedTimerHaiku::stop() 96231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block{ 97231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block m_shouldRun = false; 98231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block} 99231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 100231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Blockfilter_result SharedTimerHaiku::Filter(BMessage*, BHandler**) 101231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block{ 102231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block if (m_shouldRun && m_timerFunction) 103231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block m_timerFunction(); 104231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 105231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block return B_SKIP_MESSAGE; 106231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block} 107231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 108231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block// WebCore functions 109231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Blockvoid setSharedTimerFiredFunction(void (*f)()) 110231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block{ 111231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block SharedTimerHaiku::instance()->m_timerFunction = f; 112231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block} 113231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 114231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Blockvoid setSharedTimerFireTime(double fireTime) 115231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block{ 116231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block SharedTimerHaiku::instance()->start(fireTime); 117231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block} 118231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 119231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Blockvoid stopSharedTimer() 120231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block{ 121231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block SharedTimerHaiku::instance()->stop(); 122231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block} 123231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block 124231d4e3152a9c27a73b6ac7badbe6be673aa3ddfSteve Block} // namespace WebCore 125