Logo Search packages:      
Sourcecode: chromium-browser version File versions  Download package

task_pump.cc

// Copyright (c) 2009 The Chromium Authors. All rights reserved.
// Use of this source code is governed by a BSD-style license that can be
// found in the LICENSE file.

#include "chrome/browser/sync/notifier/base/task_pump.h"
#include "chrome/browser/sync/notifier/base/time.h"
#include "talk/base/common.h"
#include "talk/base/thread.h"

namespace notifier {

// Don't add any messages because there are cleared and thrown away.
enum { MSG_WAKE_UP = 1, MSG_TIMED_WAKE_UP };

TaskPump::TaskPump() : timeout_change_count_(0), posted_(false) {
}

void TaskPump::OnMessage(talk_base::Message* msg) {
  posted_ = false;

  // If a task timed out, ensure that it is not blocked, so it will be deleted.
  // This may result in a WakeTasks if a task is timed out.
  PollTasks();

  // Run tasks and handle timeouts.
  RunTasks();
}

void TaskPump::WakeTasks() {
  if (!posted_) {
    // Do the requested wake up.
    talk_base::Thread::Current()->Post(this, MSG_WAKE_UP);
    posted_ = true;
  }
}

int64 TaskPump::CurrentTime() {
  return GetCurrent100NSTime();
}

}  // namespace notifier

Generated by  Doxygen 1.6.0   Back to index