| OLD | NEW |
| 1 // Copyright 2010 the V8 project authors. All rights reserved. | 1 // Copyright 2010 the V8 project authors. All rights reserved. |
| 2 // Redistribution and use in source and binary forms, with or without | 2 // Redistribution and use in source and binary forms, with or without |
| 3 // modification, are permitted provided that the following conditions are | 3 // modification, are permitted provided that the following conditions are |
| 4 // met: | 4 // met: |
| 5 // | 5 // |
| 6 // * Redistributions of source code must retain the above copyright | 6 // * Redistributions of source code must retain the above copyright |
| 7 // notice, this list of conditions and the following disclaimer. | 7 // notice, this list of conditions and the following disclaimer. |
| 8 // * Redistributions in binary form must reproduce the above | 8 // * Redistributions in binary form must reproduce the above |
| 9 // copyright notice, this list of conditions and the following | 9 // copyright notice, this list of conditions and the following |
| 10 // disclaimer in the documentation and/or other materials provided | 10 // disclaimer in the documentation and/or other materials provided |
| (...skipping 15 matching lines...) Expand all Loading... |
| 26 // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. | 26 // OF THIS SOFTWARE, EVEN IF ADVISED OF THE POSSIBILITY OF SUCH DAMAGE. |
| 27 | 27 |
| 28 #include "v8.h" | 28 #include "v8.h" |
| 29 | 29 |
| 30 #include "circular-queue-inl.h" | 30 #include "circular-queue-inl.h" |
| 31 | 31 |
| 32 namespace v8 { | 32 namespace v8 { |
| 33 namespace internal { | 33 namespace internal { |
| 34 | 34 |
| 35 | 35 |
| 36 SamplingCircularQueue::SamplingCircularQueue( | 36 SamplingCircularQueue::SamplingCircularQueue(int record_size_in_bytes, |
| 37 int record_size_in_bytes, | 37 int desired_chunk_size_in_bytes, |
| 38 int desired_chunk_size_in_bytes, | 38 int buffer_size_in_chunks) |
| 39 int buffer_size_in_chunks, | |
| 40 bool keep_producer_consumer_distance) | |
| 41 : record_size_(record_size_in_bytes / sizeof(Cell)), | 39 : record_size_(record_size_in_bytes / sizeof(Cell)), |
| 42 chunk_size_in_bytes_(desired_chunk_size_in_bytes / record_size_in_bytes * | 40 chunk_size_in_bytes_(desired_chunk_size_in_bytes / record_size_in_bytes * |
| 43 record_size_in_bytes), | 41 record_size_in_bytes), |
| 44 chunk_size_(chunk_size_in_bytes_ / sizeof(Cell)), | 42 chunk_size_(chunk_size_in_bytes_ / sizeof(Cell)), |
| 45 buffer_size_(chunk_size_ * buffer_size_in_chunks), | 43 buffer_size_(chunk_size_ * buffer_size_in_chunks), |
| 44 // The distance ensures that producer and consumer never step on |
| 45 // each other's chunks and helps eviction of produced data from |
| 46 // the CPU cache (having that chunk size is bigger than the cache.) |
| 47 producer_consumer_distance_(2 * chunk_size_), |
| 46 buffer_(NewArray<Cell>(buffer_size_ + 1)) { | 48 buffer_(NewArray<Cell>(buffer_size_ + 1)) { |
| 47 ASSERT(buffer_size_in_chunks > 2); | 49 ASSERT(buffer_size_in_chunks > 2); |
| 48 // Clean up the whole buffer to avoid encountering a random kEnd | 50 // Clean up the whole buffer to avoid encountering a random kEnd |
| 49 // while enqueuing. | 51 // while enqueuing. |
| 50 for (int i = 0; i < buffer_size_; ++i) { | 52 for (int i = 0; i < buffer_size_; ++i) { |
| 51 buffer_[i] = kClear; | 53 buffer_[i] = kClear; |
| 52 } | 54 } |
| 53 buffer_[buffer_size_] = kEnd; | 55 buffer_[buffer_size_] = kEnd; |
| 54 | 56 |
| 55 // Layout producer and consumer position pointers each on their own | 57 // Layout producer and consumer position pointers each on their own |
| 56 // cache lines to avoid cache lines thrashing due to simultaneous | 58 // cache lines to avoid cache lines thrashing due to simultaneous |
| 57 // updates of positions by different processor cores. | 59 // updates of positions by different processor cores. |
| 58 const int positions_size = | 60 const int positions_size = |
| 59 RoundUp(1, kProcessorCacheLineSize) + | 61 RoundUp(1, kProcessorCacheLineSize) + |
| 60 RoundUp(static_cast<int>(sizeof(ProducerPosition)), | 62 RoundUp(static_cast<int>(sizeof(ProducerPosition)), |
| 61 kProcessorCacheLineSize) + | 63 kProcessorCacheLineSize) + |
| 62 RoundUp(static_cast<int>(sizeof(ConsumerPosition)), | 64 RoundUp(static_cast<int>(sizeof(ConsumerPosition)), |
| 63 kProcessorCacheLineSize); | 65 kProcessorCacheLineSize); |
| 64 positions_ = NewArray<byte>(positions_size); | 66 positions_ = NewArray<byte>(positions_size); |
| 65 | 67 |
| 66 producer_pos_ = reinterpret_cast<ProducerPosition*>( | 68 producer_pos_ = reinterpret_cast<ProducerPosition*>( |
| 67 RoundUp(positions_, kProcessorCacheLineSize)); | 69 RoundUp(positions_, kProcessorCacheLineSize)); |
| 68 producer_pos_->enqueue_pos = buffer_; | 70 producer_pos_->enqueue_pos = buffer_; |
| 69 | 71 |
| 70 consumer_pos_ = reinterpret_cast<ConsumerPosition*>( | 72 consumer_pos_ = reinterpret_cast<ConsumerPosition*>( |
| 71 reinterpret_cast<byte*>(producer_pos_) + kProcessorCacheLineSize); | 73 reinterpret_cast<byte*>(producer_pos_) + kProcessorCacheLineSize); |
| 72 ASSERT(reinterpret_cast<byte*>(consumer_pos_ + 1) <= | 74 ASSERT(reinterpret_cast<byte*>(consumer_pos_ + 1) <= |
| 73 positions_ + positions_size); | 75 positions_ + positions_size); |
| 74 consumer_pos_->dequeue_chunk_pos = buffer_; | 76 consumer_pos_->dequeue_chunk_pos = buffer_; |
| 75 consumer_pos_->dequeue_chunk_poll_pos = buffer_; | 77 consumer_pos_->dequeue_chunk_poll_pos = buffer_ + producer_consumer_distance_; |
| 76 // The distance ensures that producer and consumer never step on | |
| 77 // each other's chunks and helps eviction of produced data from | |
| 78 // the CPU cache (having that chunk size is bigger than the cache.) | |
| 79 if (keep_producer_consumer_distance) { | |
| 80 consumer_pos_->dequeue_chunk_poll_pos += 2 * chunk_size_; | |
| 81 } | |
| 82 consumer_pos_->dequeue_pos = NULL; | 78 consumer_pos_->dequeue_pos = NULL; |
| 83 } | 79 } |
| 84 | 80 |
| 85 | 81 |
| 86 SamplingCircularQueue::~SamplingCircularQueue() { | 82 SamplingCircularQueue::~SamplingCircularQueue() { |
| 87 DeleteArray(positions_); | 83 DeleteArray(positions_); |
| 88 DeleteArray(buffer_); | 84 DeleteArray(buffer_); |
| 89 } | 85 } |
| 90 | 86 |
| 91 | 87 |
| (...skipping 25 matching lines...) Expand all Loading... |
| 117 } | 113 } |
| 118 | 114 |
| 119 | 115 |
| 120 void SamplingCircularQueue::FlushResidualRecords() { | 116 void SamplingCircularQueue::FlushResidualRecords() { |
| 121 // Eliminate producer / consumer distance. | 117 // Eliminate producer / consumer distance. |
| 122 consumer_pos_->dequeue_chunk_poll_pos = consumer_pos_->dequeue_chunk_pos; | 118 consumer_pos_->dequeue_chunk_poll_pos = consumer_pos_->dequeue_chunk_pos; |
| 123 } | 119 } |
| 124 | 120 |
| 125 | 121 |
| 126 } } // namespace v8::internal | 122 } } // namespace v8::internal |
| OLD | NEW |