15821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Copyright (c) 2006-2008 The Chromium Authors. All rights reserved. 25821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// Use of this source code is governed by a BSD-style license that can be 35821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)// found in the LICENSE file. 45821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 57d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles)#include "base/message_loop/message_pump_default.h" 65821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 75821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/logging.h" 82a99a7e74a7f215066514fe81d2bfa6639d9edddTorne (Richard Coles)#include "base/threading/thread_restrictions.h" 95821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 105821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#if defined(OS_MACOSX) 115821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#include "base/mac/scoped_nsautorelease_pool.h" 125821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#endif 135821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 145821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)namespace base { 155821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 165821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)MessagePumpDefault::MessagePumpDefault() 175821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) : keep_running_(true), 185821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) event_(false, false) { 195821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 205821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 21ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben MurdochMessagePumpDefault::~MessagePumpDefault() { 22ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch} 23ca12bfac764ba476d6cd062bf1dde12cc64c3f40Ben Murdoch 245821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void MessagePumpDefault::Run(Delegate* delegate) { 255821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) DCHECK(keep_running_) << "Quit must have been called outside of Run!"; 265821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 275821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) for (;;) { 285821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#if defined(OS_MACOSX) 295821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) mac::ScopedNSAutoreleasePool autorelease_pool; 305821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)#endif 315821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 325821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) bool did_work = delegate->DoWork(); 335821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!keep_running_) 345821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 355821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 365821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) did_work |= delegate->DoDelayedWork(&delayed_work_time_); 375821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!keep_running_) 385821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 395821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 405821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (did_work) 415821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) continue; 425821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 435821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) did_work = delegate->DoIdleWork(); 445821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (!keep_running_) 455821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) break; 465821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 475821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (did_work) 485821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) continue; 495821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 507d4cd473f85ac64c3747c96c277f9e506a0d2246Torne (Richard Coles) ThreadRestrictions::ScopedAllowWait allow_wait; 515821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (delayed_work_time_.is_null()) { 525821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) event_.Wait(); 535821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 545821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) TimeDelta delay = delayed_work_time_ - TimeTicks::Now(); 555821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) if (delay > TimeDelta()) { 565821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) event_.TimedWait(delay); 575821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } else { 585821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // It looks like delayed_work_time_ indicates a time in the past, so we 595821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // need to call DoDelayedWork now. 605821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) delayed_work_time_ = TimeTicks(); 615821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 625821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 635821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Since event_ is auto-reset, we don't need to do anything special here 645821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // other than service each delegate method. 655821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) } 665821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 675821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) keep_running_ = true; 685821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 695821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 705821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void MessagePumpDefault::Quit() { 715821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) keep_running_ = false; 725821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 735821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 745821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void MessagePumpDefault::ScheduleWork() { 755821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // Since this can be called on any thread, we need to ensure that our Run 765821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // loop wakes up. 775821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) event_.Signal(); 785821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 795821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 805821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)void MessagePumpDefault::ScheduleDelayedWork( 815821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) const TimeTicks& delayed_work_time) { 825821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // We know that we can't be blocked on Wait right now since this method can 835821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // only be called on the same thread as Run, so we only need to update our 845821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) // record of how long to sleep when we do sleep. 855821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) delayed_work_time_ = delayed_work_time; 865821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} 875821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles) 885821806d5e7f356e8fa4b058a389a808ea183019Torne (Richard Coles)} // namespace base 89