diff options
author | jeremy@chromium.org <jeremy@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2008-12-15 22:02:17 +0000 |
---|---|---|
committer | jeremy@chromium.org <jeremy@chromium.org@0039d316-1c4b-4281-b951-d872f2087c98> | 2008-12-15 22:02:17 +0000 |
commit | e45e6c09f752dd23b2560cc64d990e6c03082083 (patch) | |
tree | 13b0e19b53b60f01e3528b20f74bf8173b4e4d7b /base/message_loop.cc | |
parent | bf54f6c60220a24ef1230f7c18153f2b077f5125 (diff) | |
download | chromium_src-e45e6c09f752dd23b2560cc64d990e6c03082083.zip chromium_src-e45e6c09f752dd23b2560cc64d990e6c03082083.tar.gz chromium_src-e45e6c09f752dd23b2560cc64d990e6c03082083.tar.bz2 |
message_pump_libevent refactor:
* Unify WatchSocket & WatchFileHandle.
* Better encapsulate libevent.
* Fix a bug with blocking writes in ipc_posix.cc
Review URL: http://codereview.chromium.org/13757
git-svn-id: svn://svn.chromium.org/chrome/trunk/src@7010 0039d316-1c4b-4281-b951-d872f2087c98
Diffstat (limited to 'base/message_loop.cc')
-rw-r--r-- | base/message_loop.cc | 27 |
1 files changed, 11 insertions, 16 deletions
diff --git a/base/message_loop.cc b/base/message_loop.cc index 898fbfa..12ad3fa 100644 --- a/base/message_loop.cc +++ b/base/message_loop.cc @@ -593,22 +593,17 @@ bool MessageLoopForIO::WaitForIOCompletion(DWORD timeout, IOHandler* filter) { #elif defined(OS_POSIX) -void MessageLoopForIO::WatchSocket(int socket, short interest_mask, - struct event* e, Watcher* watcher) { - pump_libevent()->WatchSocket(socket, interest_mask, e, watcher); +bool MessageLoopForIO::WatchFileDescriptor(int fd, + bool persistent, + Mode mode, + FileDescriptorWatcher *controller, + Watcher *delegate) { + return pump_libevent()->WatchFileDescriptor( + fd, + persistent, + static_cast<base::MessagePumpLibevent::Mode>(mode), + controller, + delegate); } -void MessageLoopForIO::WatchFileHandle(int fd, short interest_mask, - struct event* e, FileWatcher* watcher) { - pump_libevent()->WatchFileHandle(fd, interest_mask, e, watcher); -} - - -void MessageLoopForIO::UnwatchSocket(struct event* e) { - pump_libevent()->UnwatchSocket(e); -} - -void MessageLoopForIO::UnwatchFileHandle(struct event* e) { - pump_libevent()->UnwatchFileHandle(e); -} #endif |