diff options
Diffstat (limited to 'chromium/v8/src/sweeper-thread.cc')
-rw-r--r-- | chromium/v8/src/sweeper-thread.cc | 82 |
1 files changed, 25 insertions, 57 deletions
diff --git a/chromium/v8/src/sweeper-thread.cc b/chromium/v8/src/sweeper-thread.cc index 6f3baed11f8..ea2553dfaa4 100644 --- a/chromium/v8/src/sweeper-thread.cc +++ b/chromium/v8/src/sweeper-thread.cc @@ -1,36 +1,13 @@ // Copyright 2012 the V8 project authors. All rights reserved. -// Redistribution and use in source and binary forms, with or without -// modification, are permitted provided that the following conditions are -// met: -// -// * Redistributions of source code must retain the above copyright -// notice, this list of conditions and the following disclaimer. -// * Redistributions in binary form must reproduce the above -// copyright notice, this list of conditions and the following -// disclaimer in the documentation and/or other materials provided -// with the distribution. -// * Neither the name of Google Inc. nor the names of its -// contributors may be used to endorse or promote products derived -// from this software without specific prior written permission. -// -// THIS SOFTWARE IS PROVIDED BY THE COPYRIGHT HOLDERS AND CONTRIBUTORS -// "AS IS" AND ANY EXPRESS OR IMPLIED WARRANTIES, INCLUDING, BUT NOT -// LIMITED TO, THE IMPLIED WARRANTIES OF MERCHANTABILITY AND FITNESS FOR -// A PARTICULAR PURPOSE ARE DISCLAIMED. IN NO EVENT SHALL THE COPYRIGHT -// OWNER OR CONTRIBUTORS BE LIABLE FOR ANY DIRECT, INDIRECT, INCIDENTAL, -// SPECIAL, EXEMPLARY, OR CONSEQUENTIAL DAMAGES (INCLUDING, BUT NOT -// LIMITED TO, PROCUREMENT OF SUBSTITUTE GOODS OR SERVICES; LOSS OF USE, -// DATA, OR PROFITS; OR BUSINESS INTERRUPTION) HOWEVER CAUSED AND ON ANY -// THEORY OF LIABILITY, WHETHER IN CONTRACT, STRICT LIABILITY, OR TORT -// (INCLUDING NEGLIGENCE OR OTHERWISE) ARISING IN ANY WAY OUT OF THE USE -// OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. - -#include "sweeper-thread.h" - -#include "v8.h" - -#include "isolate.h" -#include "v8threads.h" +// Use of this source code is governed by a BSD-style license that can be +// found in the LICENSE file. + +#include "src/sweeper-thread.h" + +#include "src/v8.h" + +#include "src/isolate.h" +#include "src/v8threads.h" namespace v8 { namespace internal { @@ -44,13 +21,9 @@ SweeperThread::SweeperThread(Isolate* isolate) collector_(heap_->mark_compact_collector()), start_sweeping_semaphore_(0), end_sweeping_semaphore_(0), - stop_semaphore_(0), - free_list_old_data_space_(heap_->paged_space(OLD_DATA_SPACE)), - free_list_old_pointer_space_(heap_->paged_space(OLD_POINTER_SPACE)), - private_free_list_old_data_space_(heap_->paged_space(OLD_DATA_SPACE)), - private_free_list_old_pointer_space_( - heap_->paged_space(OLD_POINTER_SPACE)) { - NoBarrier_Store(&stop_thread_, static_cast<AtomicWord>(false)); + stop_semaphore_(0) { + ASSERT(!FLAG_job_based_sweeping); + base::NoBarrier_Store(&stop_thread_, static_cast<base::AtomicWord>(false)); } @@ -63,34 +36,20 @@ void SweeperThread::Run() { while (true) { start_sweeping_semaphore_.Wait(); - if (Acquire_Load(&stop_thread_)) { + if (base::Acquire_Load(&stop_thread_)) { stop_semaphore_.Signal(); return; } - collector_->SweepInParallel(heap_->old_data_space(), - &private_free_list_old_data_space_, - &free_list_old_data_space_); - collector_->SweepInParallel(heap_->old_pointer_space(), - &private_free_list_old_pointer_space_, - &free_list_old_pointer_space_); + collector_->SweepInParallel(heap_->old_data_space()); + collector_->SweepInParallel(heap_->old_pointer_space()); end_sweeping_semaphore_.Signal(); } } -intptr_t SweeperThread::StealMemory(PagedSpace* space) { - if (space->identity() == OLD_POINTER_SPACE) { - return space->free_list()->Concatenate(&free_list_old_pointer_space_); - } else if (space->identity() == OLD_DATA_SPACE) { - return space->free_list()->Concatenate(&free_list_old_data_space_); - } - return 0; -} - - void SweeperThread::Stop() { - Release_Store(&stop_thread_, static_cast<AtomicWord>(true)); + base::Release_Store(&stop_thread_, static_cast<base::AtomicWord>(true)); start_sweeping_semaphore_.Signal(); stop_semaphore_.Wait(); Join(); @@ -107,6 +66,15 @@ void SweeperThread::WaitForSweeperThread() { } +bool SweeperThread::SweepingCompleted() { + bool value = end_sweeping_semaphore_.WaitFor(TimeDelta::FromSeconds(0)); + if (value) { + end_sweeping_semaphore_.Signal(); + } + return value; +} + + int SweeperThread::NumberOfThreads(int max_available) { if (!FLAG_concurrent_sweeping && !FLAG_parallel_sweeping) return 0; if (FLAG_sweeper_threads > 0) return FLAG_sweeper_threads; |