1/* Copyright (c) 2013 The Chromium Authors. All rights reserved. 2 * Use of this source code is governed by a BSD-style license that can be 3 * found in the LICENSE file. 4 */ 5#include <assert.h> 6 7#include "nacl_io/event_emitter.h" 8#include "nacl_io/event_listener.h" 9 10#include "sdk_util/auto_lock.h" 11 12namespace nacl_io { 13 14bool operator<(const ScopedEventInfo& src_a, const ScopedEventInfo& src_b) { 15 return src_a.get() < src_b.get(); 16} 17 18void EventEmitter::Destroy() { 19 // We can not grab the EmitterLock prior to grabbing the EventListener lock, 20 // however the ref count proves this is the only thread which has a 21 // reference to the emitter at this point so accessing events_ is safe. 22 EventInfoSet_t::iterator it; 23 for (it = events_.begin(); it != events_.end(); it++) { 24 ScopedEventInfo info = *it; 25 info->listener->AbandonedEventInfo(info); 26 } 27} 28 29void EventEmitter::RegisterEventInfo(const ScopedEventInfo& info) { 30 AUTO_LOCK(emitter_lock_); 31 32 events_.insert(info); 33 ChainRegisterEventInfo(info); 34} 35 36void EventEmitter::UnregisterEventInfo(const ScopedEventInfo& info) { 37 AUTO_LOCK(emitter_lock_); 38 39 ChainUnregisterEventInfo(info); 40 events_.erase(info); 41} 42void EventEmitter::RaiseEvent(uint32_t event_bits) { 43 AUTO_LOCK(emitter_lock_); 44 45 EventInfoSet_t::iterator it; 46 for (it = events_.begin(); it != events_.end(); it++) { 47 // If this event is allowed by the filter, signal it 48 ScopedEventInfo info = *it; 49 if (info->filter & event_bits) { 50 info->events |= event_bits & info->filter; 51 info->listener->Signal(info); 52 } 53 } 54} 55 56void EventEmitter::ChainRegisterEventInfo(const ScopedEventInfo& info) {} 57void EventEmitter::ChainUnregisterEventInfo(const ScopedEventInfo& info) {} 58 59} // namespace nacl_io 60