Chromium Code Reviews| Index: base/synchronization/waitable_event_watcher.h |
| diff --git a/base/synchronization/waitable_event_watcher.h b/base/synchronization/waitable_event_watcher.h |
| index f5c1510b8f7ddc8ebcf2e7cbc33e7ca534552145..22016e3b787273129368c1613e3cbf98bb173427 100644 |
| --- a/base/synchronization/waitable_event_watcher.h |
| +++ b/base/synchronization/waitable_event_watcher.h |
| @@ -32,16 +32,19 @@ class WaitableEvent; |
| // |
| // Typical usage: |
| // |
| -// class MyClass : public base::WaitableEventWatcher::Delegate { |
| +// class MyClass { |
| // public: |
| // void DoStuffWhenSignaled(WaitableEvent *waitable_event) { |
| -// watcher_.StartWatching(waitable_event, this); |
| +// watcher_callback_ = |
| +// base::Bind(&MyClass::OnWaitableEventSignaled, this); |
| +// watcher_.StartWatching(waitable_event, &watcher_callback_); |
| // } |
| // virtual void OnWaitableEventSignaled(WaitableEvent* waitable_event) { |
| // // OK, time to do stuff! |
| // } |
| // private: |
| // base::WaitableEventWatcher watcher_; |
| +// base::Callback watcher_callback_; |
| // }; |
| // |
| // In the above example, MyClass wants to "do stuff" when waitable_event |
| @@ -60,45 +63,30 @@ class WaitableEvent; |
| // ----------------------------------------------------------------------------- |
| class BASE_EXPORT WaitableEventWatcher |
| -#if !defined(OS_WIN) |
| - : public MessageLoop::DestructionObserver |
| +#if defined(OS_WIN) |
| + : public win::ObjectWatcher::Delegate { |
| +#else |
| + : public MessageLoop::DestructionObserver { |
| #endif |
| -{ |
| public: |
| WaitableEventWatcher(); |
| virtual ~WaitableEventWatcher(); |
| - class BASE_EXPORT Delegate { |
| - public: |
| - // ------------------------------------------------------------------------- |
| - // This is called on the MessageLoop thread when WaitableEvent has been |
| - // signaled. |
| - // |
| - // Note: the event may not be signaled by the time that this function is |
| - // called. This indicates only that it has been signaled at some point in |
| - // the past. |
| - // ------------------------------------------------------------------------- |
| - virtual void OnWaitableEventSignaled(WaitableEvent* waitable_event) = 0; |
| - |
| - protected: |
| - virtual ~Delegate() { } |
| - }; |
| - |
| // --------------------------------------------------------------------------- |
| - // When @event is signaled, the given delegate is called on the thread of the |
| - // current message loop when StartWatching is called. The delegate is not |
| - // deleted. |
| + // When @event is signaled, the given callback is called on the thread of the |
| + // current message loop when StartWatching is called. |
| // --------------------------------------------------------------------------- |
| - bool StartWatching(WaitableEvent* event, Delegate* delegate); |
| + bool StartWatching(WaitableEvent* event, |
| + Callback<void(WaitableEvent*)>* callback); |
|
dmichael (off chromium)
2013/01/25 21:28:11
const Callback<...>&?
tfarina
2013/01/26 15:24:18
a typedef would be helpful too. It would increase
dmichael (off chromium)
2013/01/28 16:54:11
I personally prefer not using a typedef when it's
teravest
2013/01/28 17:10:55
We'll see what brett has to say. I changed this to
|
| // --------------------------------------------------------------------------- |
| // Cancel the current watch. Must be called from the same thread which |
| // started the watch. |
| // |
| // Does nothing if no event is being watched, nor if the watch has completed. |
| - // The delegate will *not* be called for the current watch after this |
| - // function returns. Since the delegate runs on the same thread as this |
| + // The callback will *not* be called for the current watch after this |
| + // function returns. Since the callback runs on the same thread as this |
| // function, it cannot be called during this function either. |
| // --------------------------------------------------------------------------- |
| void StopWatching(); |
| @@ -110,36 +98,14 @@ class BASE_EXPORT WaitableEventWatcher |
| WaitableEvent* GetWatchedEvent(); |
| // --------------------------------------------------------------------------- |
| - // Return the delegate, or NULL if there is no delegate. |
| + // Return the callback that will be invoked when the event is |
| + // signaled. |
| // --------------------------------------------------------------------------- |
| - Delegate* delegate() { |
| - return delegate_; |
| - } |
| + Callback<void(WaitableEvent*)>* callback() { return callback_; } |
|
dmichael (off chromium)
2013/01/25 21:28:11
I would return by const&
teravest
2013/01/28 17:10:55
Done.
|
| private: |
| #if defined(OS_WIN) |
| - // --------------------------------------------------------------------------- |
| - // The helper class exists because, if WaitableEventWatcher were to inherit |
| - // from ObjectWatcher::Delegate, then it couldn't also have an inner class |
| - // called Delegate (at least on Windows). Thus this object exists to proxy |
| - // the callback function |
| - // --------------------------------------------------------------------------- |
| - class ObjectWatcherHelper : public win::ObjectWatcher::Delegate { |
| - public: |
| - ObjectWatcherHelper(WaitableEventWatcher* watcher); |
| - |
| - // ------------------------------------------------------------------------- |
| - // Implementation of ObjectWatcher::Delegate |
| - // ------------------------------------------------------------------------- |
| - void OnObjectSignaled(HANDLE h); |
| - |
| - private: |
| - WaitableEventWatcher *const watcher_; |
| - }; |
| - |
| - void OnObjectSignaled(); |
| - |
| - ObjectWatcherHelper helper_; |
| + void OnObjectSignaled(HANDLE h); |
|
dmichael (off chromium)
2013/01/25 21:28:11
mark virtual, and OVERRIDE
teravest
2013/01/28 17:10:55
Done.
|
| win::ObjectWatcher watcher_; |
| #else |
| // --------------------------------------------------------------------------- |
| @@ -150,13 +116,12 @@ class BASE_EXPORT WaitableEventWatcher |
| MessageLoop* message_loop_; |
| scoped_refptr<Flag> cancel_flag_; |
| AsyncWaiter* waiter_; |
| - base::Closure callback_; |
| + base::Closure internal_callback_; |
| scoped_refptr<WaitableEvent::WaitableEventKernel> kernel_; |
| #endif |
| WaitableEvent* event_; |
| - |
| - Delegate* delegate_; |
| + Callback<void(WaitableEvent*)>* callback_; |
|
dmichael (off chromium)
2013/01/25 21:28:11
This should probably be by value.
teravest
2013/01/28 17:10:55
Done.
|
| }; |
| } // namespace base |