blob: 393b5b3579c2b71f1c0adb5a8c593b8a7a3bc9bf [file] [log] [blame]
// Copyright (c) 2012 The Chromium OS 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 "shill/event_dispatcher.h"
#include <stdio.h>
#include <glib.h>
#include <base/callback.h>
#include <base/location.h>
#include <base/message_loop_proxy.h>
#include "shill/glib_io_input_handler.h"
#include "shill/glib_io_ready_handler.h"
using base::Callback;
using base::Closure;
namespace shill {
EventDispatcher::EventDispatcher()
: dont_use_directly_(new MessageLoopForUI),
message_loop_proxy_(base::MessageLoopProxy::current()) {
}
EventDispatcher::~EventDispatcher() {}
void EventDispatcher::DispatchForever() {
MessageLoop::current()->Run();
}
void EventDispatcher::DispatchPendingEvents() {
MessageLoop::current()->RunAllPending();
}
bool EventDispatcher::PostTask(const Closure &task) {
return message_loop_proxy_->PostTask(FROM_HERE, task);
}
bool EventDispatcher::PostDelayedTask(const Closure &task, int64 delay_ms) {
return message_loop_proxy_->PostDelayedTask(FROM_HERE, task, delay_ms);
}
IOHandler *EventDispatcher::CreateInputHandler(
int fd,
const IOHandler::InputCallback &input_callback,
const IOHandler::ErrorCallback &error_callback) {
IOHandler *handler = new GlibIOInputHandler(
fd, input_callback, error_callback);
handler->Start();
return handler;
}
IOHandler *EventDispatcher::CreateReadyHandler(
int fd,
IOHandler::ReadyMode mode,
const Callback<void(int)> &ready_callback) {
IOHandler *handler = new GlibIOReadyHandler(fd, mode, ready_callback);
handler->Start();
return handler;
}
} // namespace shill