| OLD | NEW |
| 1 // Copyright (c) 2011 The Chromium Authors. All rights reserved. | 1 // Copyright (c) 2011 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 // This file contains intentional memory errors, some of which may lead to | 5 // This file contains intentional memory errors, some of which may lead to |
| 6 // crashes if the test is ran without special memory testing tools. We use these | 6 // crashes if the test is ran without special memory testing tools. We use these |
| 7 // errors to verify the sanity of the tools. | 7 // errors to verify the sanity of the tools. |
| 8 | 8 |
| 9 #include "base/atomicops.h" | 9 #include "base/atomicops.h" |
| 10 #include "base/message_loop.h" | 10 #include "base/message_loop.h" |
| (...skipping 152 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 163 class TOOLS_SANITY_TEST_CONCURRENT_THREAD : public PlatformThread::Delegate { | 163 class TOOLS_SANITY_TEST_CONCURRENT_THREAD : public PlatformThread::Delegate { |
| 164 public: | 164 public: |
| 165 explicit TOOLS_SANITY_TEST_CONCURRENT_THREAD(bool *value) : value_(value) {} | 165 explicit TOOLS_SANITY_TEST_CONCURRENT_THREAD(bool *value) : value_(value) {} |
| 166 ~TOOLS_SANITY_TEST_CONCURRENT_THREAD() {} | 166 ~TOOLS_SANITY_TEST_CONCURRENT_THREAD() {} |
| 167 void ThreadMain() { | 167 void ThreadMain() { |
| 168 *value_ = true; | 168 *value_ = true; |
| 169 | 169 |
| 170 // Sleep for a few milliseconds so the two threads are more likely to live | 170 // Sleep for a few milliseconds so the two threads are more likely to live |
| 171 // simultaneously. Otherwise we may miss the report due to mutex | 171 // simultaneously. Otherwise we may miss the report due to mutex |
| 172 // lock/unlock's inside thread creation code in pure-happens-before mode... | 172 // lock/unlock's inside thread creation code in pure-happens-before mode... |
| 173 PlatformThread::Sleep(100); | 173 PlatformThread::Sleep(TimeDelta::FromMilliseconds(100)); |
| 174 } | 174 } |
| 175 private: | 175 private: |
| 176 bool *value_; | 176 bool *value_; |
| 177 }; | 177 }; |
| 178 | 178 |
| 179 class ReleaseStoreThread : public PlatformThread::Delegate { | 179 class ReleaseStoreThread : public PlatformThread::Delegate { |
| 180 public: | 180 public: |
| 181 explicit ReleaseStoreThread(base::subtle::Atomic32 *value) : value_(value) {} | 181 explicit ReleaseStoreThread(base::subtle::Atomic32 *value) : value_(value) {} |
| 182 ~ReleaseStoreThread() {} | 182 ~ReleaseStoreThread() {} |
| 183 void ThreadMain() { | 183 void ThreadMain() { |
| 184 base::subtle::Release_Store(value_, kMagicValue); | 184 base::subtle::Release_Store(value_, kMagicValue); |
| 185 | 185 |
| 186 // Sleep for a few milliseconds so the two threads are more likely to live | 186 // Sleep for a few milliseconds so the two threads are more likely to live |
| 187 // simultaneously. Otherwise we may miss the report due to mutex | 187 // simultaneously. Otherwise we may miss the report due to mutex |
| 188 // lock/unlock's inside thread creation code in pure-happens-before mode... | 188 // lock/unlock's inside thread creation code in pure-happens-before mode... |
| 189 PlatformThread::Sleep(100); | 189 PlatformThread::Sleep(TimeDelta::FromMilliseconds(100)); |
| 190 } | 190 } |
| 191 private: | 191 private: |
| 192 base::subtle::Atomic32 *value_; | 192 base::subtle::Atomic32 *value_; |
| 193 }; | 193 }; |
| 194 | 194 |
| 195 class AcquireLoadThread : public PlatformThread::Delegate { | 195 class AcquireLoadThread : public PlatformThread::Delegate { |
| 196 public: | 196 public: |
| 197 explicit AcquireLoadThread(base::subtle::Atomic32 *value) : value_(value) {} | 197 explicit AcquireLoadThread(base::subtle::Atomic32 *value) : value_(value) {} |
| 198 ~AcquireLoadThread() {} | 198 ~AcquireLoadThread() {} |
| 199 void ThreadMain() { | 199 void ThreadMain() { |
| 200 // Wait for the other thread to make Release_Store | 200 // Wait for the other thread to make Release_Store |
| 201 PlatformThread::Sleep(100); | 201 PlatformThread::Sleep(TimeDelta::FromMilliseconds(100)); |
| 202 base::subtle::Acquire_Load(value_); | 202 base::subtle::Acquire_Load(value_); |
| 203 } | 203 } |
| 204 private: | 204 private: |
| 205 base::subtle::Atomic32 *value_; | 205 base::subtle::Atomic32 *value_; |
| 206 }; | 206 }; |
| 207 | 207 |
| 208 void RunInParallel(PlatformThread::Delegate *d1, PlatformThread::Delegate *d2) { | 208 void RunInParallel(PlatformThread::Delegate *d1, PlatformThread::Delegate *d2) { |
| 209 PlatformThreadHandle a; | 209 PlatformThreadHandle a; |
| 210 PlatformThreadHandle b; | 210 PlatformThreadHandle b; |
| 211 PlatformThread::Create(0, d1, &a); | 211 PlatformThread::Create(0, d1, &a); |
| (...skipping 22 matching lines...) Expand all Loading... |
| 234 | 234 |
| 235 TEST(ToolsSanityTest, AtomicsAreIgnored) { | 235 TEST(ToolsSanityTest, AtomicsAreIgnored) { |
| 236 base::subtle::Atomic32 shared = 0; | 236 base::subtle::Atomic32 shared = 0; |
| 237 ReleaseStoreThread thread1(&shared); | 237 ReleaseStoreThread thread1(&shared); |
| 238 AcquireLoadThread thread2(&shared); | 238 AcquireLoadThread thread2(&shared); |
| 239 RunInParallel(&thread1, &thread2); | 239 RunInParallel(&thread1, &thread2); |
| 240 EXPECT_EQ(kMagicValue, shared); | 240 EXPECT_EQ(kMagicValue, shared); |
| 241 } | 241 } |
| 242 | 242 |
| 243 } // namespace base | 243 } // namespace base |
| OLD | NEW |