| // Copyright 2017 The Chromium Authors |
| // Use of this source code is governed by a BSD-style license that can be |
| // found in the LICENSE file. |
| |
| #ifndef MOJO_PUBLIC_CPP_BINDINGS_SYNC_EVENT_WATCHER_H_ |
| #define MOJO_PUBLIC_CPP_BINDINGS_SYNC_EVENT_WATCHER_H_ |
| |
| #include <stddef.h> |
| |
| #include "base/component_export.h" |
| #include "base/functional/callback.h" |
| #include "base/memory/raw_ptr.h" |
| #include "base/memory/ref_counted.h" |
| #include "base/sequence_checker.h" |
| #include "base/synchronization/waitable_event.h" |
| #include "mojo/public/cpp/bindings/sync_handle_registry.h" |
| |
| namespace mojo { |
| |
| // SyncEventWatcher supports waiting on a base::WaitableEvent to signal while |
| // also allowing other SyncEventWatchers and SyncHandleWatchers on the same |
| // sequence to wake up as needed. |
| // |
| // This class is not thread safe. |
| class COMPONENT_EXPORT(MOJO_CPP_BINDINGS) SyncEventWatcher { |
| public: |
| SyncEventWatcher(base::WaitableEvent* event, base::RepeatingClosure callback); |
| |
| SyncEventWatcher(const SyncEventWatcher&) = delete; |
| SyncEventWatcher& operator=(const SyncEventWatcher&) = delete; |
| |
| ~SyncEventWatcher(); |
| |
| // Registers |event_| with SyncHandleRegistry, so that when others perform |
| // sync watching on the same sequence, |event_| will be watched along with |
| // them. |
| void AllowWokenUpBySyncWatchOnSameThread(); |
| |
| // Waits on |event_| plus all other events and handles registered with this |
| // sequence's SyncHandleRegistry, running callbacks synchronously for any |
| // ready events and handles. |
| // |
| // |stop_flags| is treated as an array of |const bool*| with |num_stop_flags| |
| // entries. |
| // |
| // This method: |
| // - returns true when any flag in |stop_flags| is set to |true|. |
| // - return false when any error occurs, including this object being |
| // destroyed during a callback. |
| bool SyncWatch(const bool** stop_flags, size_t num_stop_flags); |
| |
| private: |
| void IncrementRegisterCount(); |
| void DecrementRegisterCount(); |
| |
| const raw_ptr<base::WaitableEvent> event_; |
| const base::RepeatingClosure callback_; |
| |
| // Must outlive (and thus be declared before) |subscription_|, since |
| // it subscribes to a callback list stored in the registry. |
| scoped_refptr<SyncHandleRegistry> registry_; |
| |
| SyncHandleRegistry::EventCallbackSubscription subscription_; |
| |
| // If non-zero, |event_| should be registered with SyncHandleRegistry. |
| size_t register_request_count_ = 0; |
| |
| scoped_refptr<base::RefCountedData<bool>> destroyed_; |
| |
| SEQUENCE_CHECKER(sequence_checker_); |
| }; |
| |
| } // namespace mojo |
| |
| #endif // MOJO_PUBLIC_CPP_BINDINGS_SYNC_EVENT_WATCHER_H_ |