| Index: test/cctest/test-circular-queue.cc
|
| diff --git a/test/cctest/test-circular-queue.cc b/test/cctest/test-circular-queue.cc
|
| index 8d0d4f982a0f062f35c9ab4fd56ff2ec82f5c29a..736a9b7c88553ebe18b5911d366f8d62026af580 100644
|
| --- a/test/cctest/test-circular-queue.cc
|
| +++ b/test/cctest/test-circular-queue.cc
|
| @@ -42,51 +42,51 @@ TEST(SamplingCircularQueue) {
|
|
|
| // Check that we are using non-reserved values.
|
| // Fill up the first chunk.
|
| - CHECK(!scq.Peek());
|
| + CHECK_EQ(NULL, scq.Peek());
|
| for (Record i = 1; i < 1 + kMaxRecordsInQueue; ++i) {
|
| Record* rec = reinterpret_cast<Record*>(scq.StartEnqueue());
|
| - CHECK(rec);
|
| + CHECK_NE(NULL, rec);
|
| *rec = i;
|
| scq.FinishEnqueue();
|
| }
|
|
|
| // The queue is full, enqueue is not allowed.
|
| - CHECK(!scq.StartEnqueue());
|
| + CHECK_EQ(NULL, scq.StartEnqueue());
|
|
|
| // Try to enqueue when the the queue is full. Consumption must be available.
|
| - CHECK(scq.Peek());
|
| + CHECK_NE(NULL, scq.Peek());
|
| for (int i = 0; i < 10; ++i) {
|
| Record* rec = reinterpret_cast<Record*>(scq.StartEnqueue());
|
| - CHECK(!rec);
|
| - CHECK(scq.Peek());
|
| + CHECK_EQ(NULL, rec);
|
| + CHECK_NE(NULL, scq.Peek());
|
| }
|
|
|
| // Consume all records.
|
| for (Record i = 1; i < 1 + kMaxRecordsInQueue; ++i) {
|
| Record* rec = reinterpret_cast<Record*>(scq.Peek());
|
| - CHECK(rec);
|
| + CHECK_NE(NULL, rec);
|
| CHECK_EQ(static_cast<int64_t>(i), static_cast<int64_t>(*rec));
|
| CHECK_EQ(rec, reinterpret_cast<Record*>(scq.Peek()));
|
| scq.Remove();
|
| CHECK_NE(rec, reinterpret_cast<Record*>(scq.Peek()));
|
| }
|
| // The queue is empty.
|
| - CHECK(!scq.Peek());
|
| + CHECK_EQ(NULL, scq.Peek());
|
|
|
|
|
| - CHECK(!scq.Peek());
|
| + CHECK_EQ(NULL, scq.Peek());
|
| for (Record i = 0; i < kMaxRecordsInQueue / 2; ++i) {
|
| Record* rec = reinterpret_cast<Record*>(scq.StartEnqueue());
|
| - CHECK(rec);
|
| + CHECK_NE(NULL, rec);
|
| *rec = i;
|
| scq.FinishEnqueue();
|
| }
|
|
|
| // Consume all available kMaxRecordsInQueue / 2 records.
|
| - CHECK(scq.Peek());
|
| + CHECK_NE(NULL, scq.Peek());
|
| for (Record i = 0; i < kMaxRecordsInQueue / 2; ++i) {
|
| Record* rec = reinterpret_cast<Record*>(scq.Peek());
|
| - CHECK(rec);
|
| + CHECK_NE(NULL, rec);
|
| CHECK_EQ(static_cast<int64_t>(i), static_cast<int64_t>(*rec));
|
| CHECK_EQ(rec, reinterpret_cast<Record*>(scq.Peek()));
|
| scq.Remove();
|
| @@ -94,7 +94,7 @@ TEST(SamplingCircularQueue) {
|
| }
|
|
|
| // The queue is empty.
|
| - CHECK(!scq.Peek());
|
| + CHECK_EQ(NULL, scq.Peek());
|
| }
|
|
|
|
|
| @@ -116,7 +116,7 @@ class ProducerThread: public v8::base::Thread {
|
| virtual void Run() {
|
| for (Record i = value_; i < value_ + records_per_chunk_; ++i) {
|
| Record* rec = reinterpret_cast<Record*>(scq_->StartEnqueue());
|
| - CHECK(rec);
|
| + CHECK_NE(NULL, rec);
|
| *rec = i;
|
| scq_->FinishEnqueue();
|
| }
|
| @@ -147,41 +147,41 @@ TEST(SamplingCircularQueueMultithreading) {
|
| ProducerThread producer2(&scq, kRecordsPerChunk, 10, &semaphore);
|
| ProducerThread producer3(&scq, kRecordsPerChunk, 20, &semaphore);
|
|
|
| - CHECK(!scq.Peek());
|
| + CHECK_EQ(NULL, scq.Peek());
|
| producer1.Start();
|
| semaphore.Wait();
|
| for (Record i = 1; i < 1 + kRecordsPerChunk; ++i) {
|
| Record* rec = reinterpret_cast<Record*>(scq.Peek());
|
| - CHECK(rec);
|
| + CHECK_NE(NULL, rec);
|
| CHECK_EQ(static_cast<int64_t>(i), static_cast<int64_t>(*rec));
|
| CHECK_EQ(rec, reinterpret_cast<Record*>(scq.Peek()));
|
| scq.Remove();
|
| CHECK_NE(rec, reinterpret_cast<Record*>(scq.Peek()));
|
| }
|
|
|
| - CHECK(!scq.Peek());
|
| + CHECK_EQ(NULL, scq.Peek());
|
| producer2.Start();
|
| semaphore.Wait();
|
| for (Record i = 10; i < 10 + kRecordsPerChunk; ++i) {
|
| Record* rec = reinterpret_cast<Record*>(scq.Peek());
|
| - CHECK(rec);
|
| + CHECK_NE(NULL, rec);
|
| CHECK_EQ(static_cast<int64_t>(i), static_cast<int64_t>(*rec));
|
| CHECK_EQ(rec, reinterpret_cast<Record*>(scq.Peek()));
|
| scq.Remove();
|
| CHECK_NE(rec, reinterpret_cast<Record*>(scq.Peek()));
|
| }
|
|
|
| - CHECK(!scq.Peek());
|
| + CHECK_EQ(NULL, scq.Peek());
|
| producer3.Start();
|
| semaphore.Wait();
|
| for (Record i = 20; i < 20 + kRecordsPerChunk; ++i) {
|
| Record* rec = reinterpret_cast<Record*>(scq.Peek());
|
| - CHECK(rec);
|
| + CHECK_NE(NULL, rec);
|
| CHECK_EQ(static_cast<int64_t>(i), static_cast<int64_t>(*rec));
|
| CHECK_EQ(rec, reinterpret_cast<Record*>(scq.Peek()));
|
| scq.Remove();
|
| CHECK_NE(rec, reinterpret_cast<Record*>(scq.Peek()));
|
| }
|
|
|
| - CHECK(!scq.Peek());
|
| + CHECK_EQ(NULL, scq.Peek());
|
| }
|
|
|