1 files changed, 42 insertions, 0 deletions
diff --git a/chrome/browser/sync/notifier/base/task_pump.cc b/chrome/browser/sync/notifier/base/task_pump.cc
new file mode 100644
index 0000000..7e99fc1
--- /dev/null
+++ b/chrome/browser/sync/notifier/base/task_pump.cc
@@ -0,0 +1,42 @@
+// 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;
+  int initial_count = timeout_change_count_;
+
+  // 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