12 static const int kDelayMicros = 100000;
24 static void SetBool(
void* ptr) {
25 reinterpret_cast<port::AtomicPointer*
>(ptr)->NoBarrier_Store(ptr);
44 static void Run(
void* v) {
45 CB* cb =
reinterpret_cast<CB*
>(v);
46 void* cur = cb->last_id_ptr->NoBarrier_Load();
47 ASSERT_EQ(cb->id-1, reinterpret_cast<uintptr_t>(cur));
48 cb->last_id_ptr->Release_Store(reinterpret_cast<void*>(cb->id));
64 ASSERT_EQ(4, reinterpret_cast<uintptr_t>(cur));
73 static void ThreadBody(
void*
arg) {
85 for (
int i = 0; i < 3; i++) {
102 int main(
int argc,
char** argv) {
void * Acquire_Load() const
int main(int argc, char **argv)
void * NoBarrier_Load() const
virtual void SleepForMicroseconds(int micros)=0
TEST(CorruptionTest, Recovery)
virtual void Schedule(void(*function)(void *arg), void *arg)=0
virtual void StartThread(void(*function)(void *arg), void *arg)=0