Index: mojo/system/local_data_pipe_unittest.cc |
diff --git a/mojo/system/local_data_pipe_unittest.cc b/mojo/system/local_data_pipe_unittest.cc |
index 1dc34885e9d043ca136172852017246a904e129a..48cc4d6f8d76c16dcf6aa54d5d81ea698a4a523b 100644 |
--- a/mojo/system/local_data_pipe_unittest.cc |
+++ b/mojo/system/local_data_pipe_unittest.cc |
@@ -270,7 +270,8 @@ TEST(LocalDataPipeTest, BasicProducerWaiting) { |
const void* read_buffer = NULL; |
num_bytes = 0u; |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_buffer, &num_bytes, false)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer), |
+ MakeUserPointer(&num_bytes), false)); |
EXPECT_TRUE(read_buffer != NULL); |
// Since we only read one element (after having written three in all), the |
// two-phase read should only allow us to read one. This checks an |
@@ -442,7 +443,8 @@ TEST(LocalDataPipeTest, BasicConsumerWaiting) { |
const void* read_buffer = NULL; |
num_bytes = static_cast<uint32_t>(2u * sizeof(elements[0])); |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_buffer, &num_bytes, true)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer), |
+ MakeUserPointer(&num_bytes), true)); |
EXPECT_TRUE(read_buffer != NULL); |
EXPECT_EQ(static_cast<uint32_t>(2u * sizeof(elements[0])), num_bytes); |
const int32_t* read_elements = static_cast<const int32_t*>(read_buffer); |
@@ -461,7 +463,8 @@ TEST(LocalDataPipeTest, BasicConsumerWaiting) { |
read_buffer = NULL; |
num_bytes = static_cast<uint32_t>(3u * sizeof(elements[0])); |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_buffer, &num_bytes, false)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer), |
+ MakeUserPointer(&num_bytes), false)); |
EXPECT_TRUE(read_buffer != NULL); |
EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(elements[0])), num_bytes); |
read_elements = static_cast<const int32_t*>(read_buffer); |
@@ -566,7 +569,8 @@ TEST(LocalDataPipeTest, BasicTwoPhaseWaiting) { |
num_bytes = static_cast<uint32_t>(1u * sizeof(int32_t)); |
const void* read_ptr = NULL; |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_ptr, &num_bytes, false)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_ptr), |
+ MakeUserPointer(&num_bytes), false)); |
EXPECT_TRUE(read_ptr != NULL); |
EXPECT_EQ(static_cast<uint32_t>(1u * sizeof(int32_t)), num_bytes); |
@@ -1122,7 +1126,8 @@ TEST(LocalDataPipeTest, TwoPhaseAllOrNone) { |
num_bytes = 20u * sizeof(int32_t); |
const void* read_ptr = NULL; |
EXPECT_EQ(MOJO_RESULT_OUT_OF_RANGE, |
- dp->ConsumerBeginReadData(&read_ptr, &num_bytes, true)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_ptr), |
+ MakeUserPointer(&num_bytes), true)); |
// Write half (two-phase). |
num_bytes = 5u * sizeof(int32_t); |
@@ -1141,13 +1146,15 @@ TEST(LocalDataPipeTest, TwoPhaseAllOrNone) { |
num_bytes = 1u; |
read_ptr = NULL; |
EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
- dp->ConsumerBeginReadData(&read_ptr, &num_bytes, true)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_ptr), |
+ MakeUserPointer(&num_bytes), true)); |
// Read one (two-phase). |
num_bytes = 1u * sizeof(int32_t); |
read_ptr = NULL; |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_ptr, &num_bytes, true)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_ptr), |
+ MakeUserPointer(&num_bytes), true)); |
EXPECT_GE(num_bytes, 1u * sizeof(int32_t)); |
EXPECT_EQ(0, static_cast<const int32_t*>(read_ptr)[0]); |
EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(1u * sizeof(int32_t))); |
@@ -1181,7 +1188,8 @@ TEST(LocalDataPipeTest, TwoPhaseAllOrNone) { |
num_bytes = 10u * sizeof(int32_t); |
read_ptr = NULL; |
EXPECT_EQ(MOJO_RESULT_OUT_OF_RANGE, |
- dp->ConsumerBeginReadData(&read_ptr, &num_bytes, true)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_ptr), |
+ MakeUserPointer(&num_bytes), true)); |
// Close the producer. |
dp->ProducerClose(); |
@@ -1190,7 +1198,8 @@ TEST(LocalDataPipeTest, TwoPhaseAllOrNone) { |
num_bytes = 9u * sizeof(int32_t); |
read_ptr = NULL; |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_ptr, &num_bytes, true)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_ptr), |
+ MakeUserPointer(&num_bytes), true)); |
EXPECT_GE(num_bytes, 9u * sizeof(int32_t)); |
EXPECT_EQ(1, static_cast<const int32_t*>(read_ptr)[0]); |
EXPECT_EQ(2, static_cast<const int32_t*>(read_ptr)[1]); |
@@ -1207,7 +1216,8 @@ TEST(LocalDataPipeTest, TwoPhaseAllOrNone) { |
num_bytes = 2u * sizeof(int32_t); |
read_ptr = NULL; |
EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
- dp->ConsumerBeginReadData(&read_ptr, &num_bytes, true)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_ptr), |
+ MakeUserPointer(&num_bytes), true)); |
dp->ConsumerClose(); |
} |
@@ -1275,7 +1285,8 @@ TEST(LocalDataPipeTest, WrapAround) { |
const void* read_buffer_ptr = NULL; |
num_bytes = 0u; |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_buffer_ptr, &num_bytes, false)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), |
+ MakeUserPointer(&num_bytes), false)); |
EXPECT_TRUE(read_buffer_ptr != NULL); |
EXPECT_EQ(90u, num_bytes); |
EXPECT_EQ(MOJO_RESULT_OK, dp->ConsumerEndReadData(0u)); |
@@ -1339,7 +1350,8 @@ TEST(LocalDataPipeTest, CloseWriteRead) { |
const void* read_buffer_ptr = NULL; |
num_bytes = 0u; |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_buffer_ptr, &num_bytes, false)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), |
+ MakeUserPointer(&num_bytes), false)); |
EXPECT_TRUE(read_buffer_ptr != NULL); |
EXPECT_EQ(2u * kTestDataSize, num_bytes); |
@@ -1354,7 +1366,8 @@ TEST(LocalDataPipeTest, CloseWriteRead) { |
read_buffer_ptr = NULL; |
num_bytes = 0u; |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_buffer_ptr, &num_bytes, false)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), |
+ MakeUserPointer(&num_bytes), false)); |
EXPECT_TRUE(read_buffer_ptr != NULL); |
EXPECT_EQ(kTestDataSize, num_bytes); |
@@ -1385,7 +1398,8 @@ TEST(LocalDataPipeTest, CloseWriteRead) { |
const void* read_buffer_ptr = NULL; |
num_bytes = 0u; |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_buffer_ptr, &num_bytes, false)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), |
+ MakeUserPointer(&num_bytes), false)); |
EXPECT_TRUE(read_buffer_ptr != NULL); |
EXPECT_EQ(kTestDataSize, num_bytes); |
@@ -1462,7 +1476,8 @@ TEST(LocalDataPipeTest, CloseWriteRead) { |
const void* read_buffer_ptr = NULL; |
num_bytes = 0u; |
EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
- dp->ConsumerBeginReadData(&read_buffer_ptr, &num_bytes, false)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_buffer_ptr), |
+ MakeUserPointer(&num_bytes), false)); |
// Ditto for discard. |
num_bytes = 10u; |
@@ -1559,7 +1574,8 @@ TEST(LocalDataPipeTest, TwoPhaseMoreInvalidArguments) { |
num_bytes = 0u; |
const void* read_ptr = NULL; |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_ptr, &num_bytes, false)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_ptr), |
+ MakeUserPointer(&num_bytes), false)); |
EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, |
dp->ConsumerEndReadData( |
num_bytes + static_cast<uint32_t>(sizeof(int32_t)))); |
@@ -1574,7 +1590,8 @@ TEST(LocalDataPipeTest, TwoPhaseMoreInvalidArguments) { |
num_bytes = 0u; |
read_ptr = NULL; |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_ptr, &num_bytes, false)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_ptr), |
+ MakeUserPointer(&num_bytes), false)); |
EXPECT_EQ(1u * sizeof(int32_t), num_bytes); |
EXPECT_EQ(123, static_cast<const int32_t*>(read_ptr)[0]); |
EXPECT_EQ(MOJO_RESULT_INVALID_ARGUMENT, dp->ConsumerEndReadData(1u)); |
@@ -1618,7 +1635,8 @@ TEST(LocalDataPipeTest, DISABLED_MayDiscardTwoPhaseConsistent) { |
const void* read_ptr = NULL; |
num_bytes = 2u; |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_ptr, &num_bytes, false)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_ptr), |
+ MakeUserPointer(&num_bytes), false)); |
EXPECT_EQ(2u, num_bytes); |
EXPECT_EQ('a', static_cast<const char*>(read_ptr)[0]); |
EXPECT_EQ('b', static_cast<const char*>(read_ptr)[1]); |
@@ -1648,7 +1666,8 @@ TEST(LocalDataPipeTest, DISABLED_MayDiscardTwoPhaseConsistent) { |
read_ptr = NULL; |
num_bytes = 2u; |
EXPECT_EQ(MOJO_RESULT_OK, |
- dp->ConsumerBeginReadData(&read_ptr, &num_bytes, false)); |
+ dp->ConsumerBeginReadData(MakeUserPointer(&read_ptr), |
+ MakeUserPointer(&num_bytes), false)); |
EXPECT_EQ(2u, num_bytes); |
EXPECT_EQ('x', static_cast<const char*>(read_ptr)[0]); |
EXPECT_EQ('y', static_cast<const char*>(read_ptr)[1]); |