Chromium Code Reviews| OLD | NEW |
|---|---|
| 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2012 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #include <stddef.h> | 5 #include <stddef.h> |
| 6 | 6 |
| 7 #include <algorithm> | 7 #include <algorithm> |
| 8 #include <vector> | 8 #include <vector> |
| 9 | 9 |
| 10 #include "base/logging.h" | 10 #include "base/logging.h" |
| (...skipping 21 matching lines...) Expand all Loading... | |
| 32 // the wait-list of many events. An event passes a pointer to itself when | 32 // the wait-list of many events. An event passes a pointer to itself when |
| 33 // firing a waiter and so we can store that pointer to find out which event | 33 // firing a waiter and so we can store that pointer to find out which event |
| 34 // triggered. | 34 // triggered. |
| 35 // ----------------------------------------------------------------------------- | 35 // ----------------------------------------------------------------------------- |
| 36 | 36 |
| 37 namespace base { | 37 namespace base { |
| 38 | 38 |
| 39 // ----------------------------------------------------------------------------- | 39 // ----------------------------------------------------------------------------- |
| 40 // This is just an abstract base class for waking the two types of waiters | 40 // This is just an abstract base class for waking the two types of waiters |
| 41 // ----------------------------------------------------------------------------- | 41 // ----------------------------------------------------------------------------- |
| 42 WaitableEvent::WaitableEvent(bool manual_reset, bool initially_signaled) | |
| 43 : kernel_(new WaitableEventKernel(manual_reset, initially_signaled)) { | |
| 44 } | |
| 45 | |
| 46 WaitableEvent::WaitableEvent(ResetPolicy reset_policy, | 42 WaitableEvent::WaitableEvent(ResetPolicy reset_policy, |
| 47 InitialState initial_state) | 43 InitialState initial_state) |
| 48 : WaitableEvent(reset_policy == ResetPolicy::MANUAL, | 44 : kernel_(new WaitableEventKernel(reset_policy, initial_state)) {} |
| 49 initial_state == InitialState::SIGNALED) {} | |
| 50 | 45 |
| 51 WaitableEvent::~WaitableEvent() { | 46 WaitableEvent::~WaitableEvent() = default; |
|
danakj
2016/06/09 18:25:45
thanks :)
| |
| 52 } | |
| 53 | 47 |
| 54 void WaitableEvent::Reset() { | 48 void WaitableEvent::Reset() { |
| 55 base::AutoLock locked(kernel_->lock_); | 49 base::AutoLock locked(kernel_->lock_); |
| 56 kernel_->signaled_ = false; | 50 kernel_->signaled_ = false; |
| 57 } | 51 } |
| 58 | 52 |
| 59 void WaitableEvent::Signal() { | 53 void WaitableEvent::Signal() { |
| 60 base::AutoLock locked(kernel_->lock_); | 54 base::AutoLock locked(kernel_->lock_); |
| 61 | 55 |
| 62 if (kernel_->signaled_) | 56 if (kernel_->signaled_) |
| (...skipping 283 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 346 | 340 |
| 347 return r; | 341 return r; |
| 348 } | 342 } |
| 349 | 343 |
| 350 // ----------------------------------------------------------------------------- | 344 // ----------------------------------------------------------------------------- |
| 351 | 345 |
| 352 | 346 |
| 353 // ----------------------------------------------------------------------------- | 347 // ----------------------------------------------------------------------------- |
| 354 // Private functions... | 348 // Private functions... |
| 355 | 349 |
| 356 WaitableEvent::WaitableEventKernel::WaitableEventKernel(bool manual_reset, | 350 WaitableEvent::WaitableEventKernel::WaitableEventKernel( |
| 357 bool initially_signaled) | 351 ResetPolicy reset_policy, |
| 358 : manual_reset_(manual_reset), | 352 InitialState initial_state) |
| 359 signaled_(initially_signaled) { | 353 : manual_reset_(reset_policy == ResetPolicy::MANUAL), |
| 360 } | 354 signaled_(initial_state == InitialState::SIGNALED) {} |
| 361 | 355 |
| 362 WaitableEvent::WaitableEventKernel::~WaitableEventKernel() { | 356 WaitableEvent::WaitableEventKernel::~WaitableEventKernel() = default; |
| 363 } | |
| 364 | 357 |
| 365 // ----------------------------------------------------------------------------- | 358 // ----------------------------------------------------------------------------- |
| 366 // Wake all waiting waiters. Called with lock held. | 359 // Wake all waiting waiters. Called with lock held. |
| 367 // ----------------------------------------------------------------------------- | 360 // ----------------------------------------------------------------------------- |
| 368 bool WaitableEvent::SignalAll() { | 361 bool WaitableEvent::SignalAll() { |
| 369 bool signaled_at_least_one = false; | 362 bool signaled_at_least_one = false; |
| 370 | 363 |
| 371 for (std::list<Waiter*>::iterator | 364 for (std::list<Waiter*>::iterator |
| 372 i = kernel_->waiters_.begin(); i != kernel_->waiters_.end(); ++i) { | 365 i = kernel_->waiters_.begin(); i != kernel_->waiters_.end(); ++i) { |
| 373 if ((*i)->Fire(this)) | 366 if ((*i)->Fire(this)) |
| (...skipping 39 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... | |
| 413 return true; | 406 return true; |
| 414 } | 407 } |
| 415 } | 408 } |
| 416 | 409 |
| 417 return false; | 410 return false; |
| 418 } | 411 } |
| 419 | 412 |
| 420 // ----------------------------------------------------------------------------- | 413 // ----------------------------------------------------------------------------- |
| 421 | 414 |
| 422 } // namespace base | 415 } // namespace base |
| OLD | NEW |