#include "mojo/system/waiter.h"
-#include "base/basictypes.h"
-#include "base/compiler_specific.h"
+#include <stdint.h>
+
+#include "base/macros.h"
#include "base/synchronization/lock.h"
#include "base/threading/platform_thread.h" // For |Sleep()|.
#include "base/threading/simple_thread.h"
waiter_.Init();
}
- virtual ~WaitingThread() {
- Join();
- }
+ virtual ~WaitingThread() { Join(); }
void WaitUntilDone(MojoResult* result,
uint32_t* context,
thread.WaitUntilDone(&result, &context, &elapsed);
EXPECT_EQ(1, result);
EXPECT_EQ(3u, context);
- EXPECT_GT(elapsed, (2-1) * test::EpsilonTimeout());
- EXPECT_LT(elapsed, (2+1) * test::EpsilonTimeout());
+ EXPECT_GT(elapsed, (2 - 1) * test::EpsilonTimeout());
+ EXPECT_LT(elapsed, (2 + 1) * test::EpsilonTimeout());
}
// Awake some longer time after thread start.
thread.WaitUntilDone(&result, &context, &elapsed);
EXPECT_EQ(2, result);
EXPECT_EQ(4u, context);
- EXPECT_GT(elapsed, (5-1) * test::EpsilonTimeout());
- EXPECT_LT(elapsed, (5+1) * test::EpsilonTimeout());
+ EXPECT_GT(elapsed, (5 - 1) * test::EpsilonTimeout());
+ EXPECT_LT(elapsed, (5 + 1) * test::EpsilonTimeout());
}
// Don't awake -- time out (on another thread).
thread.WaitUntilDone(&result, &context, &elapsed);
EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED, result);
EXPECT_EQ(static_cast<uint32_t>(-1), context);
- EXPECT_GT(elapsed, (2-1) * test::EpsilonTimeout());
- EXPECT_LT(elapsed, (2+1) * test::EpsilonTimeout());
+ EXPECT_GT(elapsed, (2 - 1) * test::EpsilonTimeout());
+ EXPECT_LT(elapsed, (2 + 1) * test::EpsilonTimeout());
}
// No (indefinite) deadline.
thread.WaitUntilDone(&result, &context, &elapsed);
EXPECT_EQ(1, result);
EXPECT_EQ(7u, context);
- EXPECT_GT(elapsed, (2-1) * test::EpsilonTimeout());
- EXPECT_LT(elapsed, (2+1) * test::EpsilonTimeout());
+ EXPECT_GT(elapsed, (2 - 1) * test::EpsilonTimeout());
+ EXPECT_LT(elapsed, (2 + 1) * test::EpsilonTimeout());
}
// Awake some longer time after thread start.
thread.WaitUntilDone(&result, &context, &elapsed);
EXPECT_EQ(2, result);
EXPECT_EQ(8u, context);
- EXPECT_GT(elapsed, (5-1) * test::EpsilonTimeout());
- EXPECT_LT(elapsed, (5+1) * test::EpsilonTimeout());
+ EXPECT_GT(elapsed, (5 - 1) * test::EpsilonTimeout());
+ EXPECT_LT(elapsed, (5 + 1) * test::EpsilonTimeout());
}
}
EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED,
waiter.Wait(2 * test::EpsilonTimeout().InMicroseconds(), &context));
elapsed = stopwatch.Elapsed();
- EXPECT_GT(elapsed, (2-1) * test::EpsilonTimeout());
- EXPECT_LT(elapsed, (2+1) * test::EpsilonTimeout());
+ EXPECT_GT(elapsed, (2 - 1) * test::EpsilonTimeout());
+ EXPECT_LT(elapsed, (2 + 1) * test::EpsilonTimeout());
EXPECT_EQ(123u, context);
waiter.Init();
EXPECT_EQ(MOJO_RESULT_DEADLINE_EXCEEDED,
waiter.Wait(5 * test::EpsilonTimeout().InMicroseconds(), &context));
elapsed = stopwatch.Elapsed();
- EXPECT_GT(elapsed, (5-1) * test::EpsilonTimeout());
- EXPECT_LT(elapsed, (5+1) * test::EpsilonTimeout());
+ EXPECT_GT(elapsed, (5 - 1) * test::EpsilonTimeout());
+ EXPECT_LT(elapsed, (5 + 1) * test::EpsilonTimeout());
EXPECT_EQ(123u, context);
}
thread.WaitUntilDone(&result, &context, &elapsed);
EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, result);
EXPECT_EQ(7u, context);
- EXPECT_GT(elapsed, (1-1) * test::EpsilonTimeout());
- EXPECT_LT(elapsed, (1+1) * test::EpsilonTimeout());
+ EXPECT_GT(elapsed, (1 - 1) * test::EpsilonTimeout());
+ EXPECT_LT(elapsed, (1 + 1) * test::EpsilonTimeout());
}
}