| 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 "base/threading/sequenced_worker_pool.h" | 5 #include "base/threading/sequenced_worker_pool.h" |
| 6 | 6 |
| 7 #include <stdint.h> | 7 #include <stdint.h> |
| 8 | 8 |
| 9 #include <list> | 9 #include <list> |
| 10 #include <map> | 10 #include <map> |
| (...skipping 679 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 690 return SequenceToken(LockedGetNamedTokenID(name)); | 690 return SequenceToken(LockedGetNamedTokenID(name)); |
| 691 } | 691 } |
| 692 | 692 |
| 693 bool SequencedWorkerPool::Inner::PostTask( | 693 bool SequencedWorkerPool::Inner::PostTask( |
| 694 const std::string* optional_token_name, | 694 const std::string* optional_token_name, |
| 695 SequenceToken sequence_token, | 695 SequenceToken sequence_token, |
| 696 WorkerShutdown shutdown_behavior, | 696 WorkerShutdown shutdown_behavior, |
| 697 const tracked_objects::Location& from_here, | 697 const tracked_objects::Location& from_here, |
| 698 OnceClosure task, | 698 OnceClosure task, |
| 699 TimeDelta delay) { | 699 TimeDelta delay) { |
| 700 DCHECK(task); | 700 // Use CHECK instead of DCHECK to crash earlier. See http://crbug.com/711167 |
| 701 // for details. |
| 702 CHECK(task); |
| 701 | 703 |
| 702 // TODO(fdoray): Uncomment this DCHECK. It is initially commented to avoid a | 704 // TODO(fdoray): Uncomment this DCHECK. It is initially commented to avoid a |
| 703 // revert of the CL that adds debug::DumpWithoutCrashing() if it fails on the | 705 // revert of the CL that adds debug::DumpWithoutCrashing() if it fails on the |
| 704 // waterfall. https://crbug.com/622400 | 706 // waterfall. https://crbug.com/622400 |
| 705 // DCHECK_NE(AllPoolsState::POST_TASK_DISABLED, g_all_pools_state); | 707 // DCHECK_NE(AllPoolsState::POST_TASK_DISABLED, g_all_pools_state); |
| 706 if (g_all_pools_state == AllPoolsState::POST_TASK_DISABLED) | 708 if (g_all_pools_state == AllPoolsState::POST_TASK_DISABLED) |
| 707 debug::DumpWithoutCrashing(); | 709 debug::DumpWithoutCrashing(); |
| 708 | 710 |
| 709 DCHECK(delay.is_zero() || shutdown_behavior == SKIP_ON_SHUTDOWN); | 711 DCHECK(delay.is_zero() || shutdown_behavior == SKIP_ON_SHUTDOWN); |
| 710 SequencedTask sequenced(from_here); | 712 SequencedTask sequenced(from_here); |
| (...skipping 931 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 1642 bool SequencedWorkerPool::IsShutdownInProgress() { | 1644 bool SequencedWorkerPool::IsShutdownInProgress() { |
| 1643 return inner_->IsShutdownInProgress(); | 1645 return inner_->IsShutdownInProgress(); |
| 1644 } | 1646 } |
| 1645 | 1647 |
| 1646 bool SequencedWorkerPool::IsRunningSequenceOnCurrentThread( | 1648 bool SequencedWorkerPool::IsRunningSequenceOnCurrentThread( |
| 1647 SequenceToken sequence_token) const { | 1649 SequenceToken sequence_token) const { |
| 1648 return inner_->IsRunningSequenceOnCurrentThread(sequence_token); | 1650 return inner_->IsRunningSequenceOnCurrentThread(sequence_token); |
| 1649 } | 1651 } |
| 1650 | 1652 |
| 1651 } // namespace base | 1653 } // namespace base |
| OLD | NEW |