jingle/glue/task_pump.cc

   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
  11 TaskPump::TaskPump()
  12     : weak_factory_(this),
  13       posted_wake_(false),
  14       stopped_(false) {}
  15
  16 TaskPump::~TaskPump() {
  17   DCHECK(CalledOnValidThread());
  18 }
  19
  20 void TaskPump::WakeTasks() {
  21   DCHECK(CalledOnValidThread());
  22   if (!stopped_ && !posted_wake_) {
  23     base::MessageLoop* current_message_loop = base::MessageLoop::current();
  24     CHECK(current_message_loop);
  25     // Do the requested wake up.
  26     current_message_loop->PostTask(
  27         FROM_HERE,
  28         base::Bind(&TaskPump::CheckAndRunTasks, weak_factory_.GetWeakPtr()));
  29     posted_wake_ = true;
  30   }
  31 }
  32
  33 int64 TaskPump::CurrentTime() {
  34   DCHECK(CalledOnValidThread());
  35   // Only timeout tasks rely on this function.  Since we're not using
  36   // libjingle tasks for timeout, it's safe to return 0 here.
  37   return 0;
  38 }
  39
  40 void TaskPump::Stop() {
  41   stopped_ = true;
  42 }
  43
  44 void TaskPump::CheckAndRunTasks() {
  45   DCHECK(CalledOnValidThread());
  46   if (stopped_) {
  47     return;
  48   }
  49   posted_wake_ = false;
  50   // We shouldn't be using libjingle for timeout tasks, so we should
  51   // have no timeout tasks at all.
  52
  53   // TODO(akalin): Add HasTimeoutTask() back in TaskRunner class and
  54   // uncomment this check.
  55   // DCHECK(!HasTimeoutTask())
  56   RunTasks();
  57 }
  58
  59 }  // namespace jingle_glue