1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. 2 // Use of this source code is governed by a BSD-style license that can be 3 // found in the LICENSE file. 4 5 #include "base/bind.h" 6 #include "base/message_loop/message_loop.h" 7 #include "jingle/glue/task_pump.h" 8 9 namespace jingle_glue { 10 TaskPump()11TaskPump::TaskPump() 12 : posted_wake_(false), 13 stopped_(false), 14 weak_factory_(this) { 15 } 16 ~TaskPump()17TaskPump::~TaskPump() { 18 DCHECK(CalledOnValidThread()); 19 } 20 WakeTasks()21void TaskPump::WakeTasks() { 22 DCHECK(CalledOnValidThread()); 23 if (!stopped_ && !posted_wake_) { 24 base::MessageLoop* current_message_loop = base::MessageLoop::current(); 25 CHECK(current_message_loop); 26 // Do the requested wake up. 27 current_message_loop->PostTask( 28 FROM_HERE, 29 base::Bind(&TaskPump::CheckAndRunTasks, weak_factory_.GetWeakPtr())); 30 posted_wake_ = true; 31 } 32 } 33 CurrentTime()34int64 TaskPump::CurrentTime() { 35 DCHECK(CalledOnValidThread()); 36 // Only timeout tasks rely on this function. Since we're not using 37 // libjingle tasks for timeout, it's safe to return 0 here. 38 return 0; 39 } 40 Stop()41void TaskPump::Stop() { 42 stopped_ = true; 43 } 44 CheckAndRunTasks()45void TaskPump::CheckAndRunTasks() { 46 DCHECK(CalledOnValidThread()); 47 if (stopped_) { 48 return; 49 } 50 posted_wake_ = false; 51 // We shouldn't be using libjingle for timeout tasks, so we should 52 // have no timeout tasks at all. 53 54 // TODO(akalin): Add HasTimeoutTask() back in TaskRunner class and 55 // uncomment this check. 56 // DCHECK(!HasTimeoutTask()) 57 RunTasks(); 58 } 59 60 } // namespace jingle_glue 61