OLD | NEW |
1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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 // NOTE(vtl): Some of these tests are inherently flaky (e.g., if run on a | 5 // NOTE(vtl): Some of these tests are inherently flaky (e.g., if run on a |
6 // heavily-loaded system). Sorry. |test::EpsilonTimeout()| may be increased to | 6 // heavily-loaded system). Sorry. |test::EpsilonTimeout()| may be increased to |
7 // increase tolerance and reduce observed flakiness (though doing so reduces the | 7 // increase tolerance and reduce observed flakiness (though doing so reduces the |
8 // meaningfulness of the test). | 8 // meaningfulness of the test). |
9 | 9 |
10 #include "mojo/system/message_pipe_dispatcher.h" | 10 #include "mojo/system/message_pipe_dispatcher.h" |
(...skipping 240 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
251 buffer[0] = 345678901; | 251 buffer[0] = 345678901; |
252 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, | 252 EXPECT_EQ(MOJO_RESULT_FAILED_PRECONDITION, |
253 d0->WriteMessage(buffer, kBufferSize, | 253 d0->WriteMessage(buffer, kBufferSize, |
254 NULL, | 254 NULL, |
255 MOJO_WRITE_MESSAGE_FLAG_NONE)); | 255 MOJO_WRITE_MESSAGE_FLAG_NONE)); |
256 | 256 |
257 EXPECT_EQ(MOJO_RESULT_OK, d0->Close()); | 257 EXPECT_EQ(MOJO_RESULT_OK, d0->Close()); |
258 } | 258 } |
259 } | 259 } |
260 | 260 |
261 TEST(MessagePipeDispatcherTest, BasicThreaded) { | 261 #if defined(OS_WIN) |
| 262 // http://crbug.com/396386 |
| 263 #define MAYBE_BasicThreaded DISABLED_BasicThreaded |
| 264 #else |
| 265 #define MAYBE_BasicThreaded BasicThreaded |
| 266 #endif |
| 267 TEST(MessagePipeDispatcherTest, MAYBE_BasicThreaded) { |
262 test::Stopwatch stopwatch; | 268 test::Stopwatch stopwatch; |
263 int32_t buffer[1]; | 269 int32_t buffer[1]; |
264 const uint32_t kBufferSize = static_cast<uint32_t>(sizeof(buffer)); | 270 const uint32_t kBufferSize = static_cast<uint32_t>(sizeof(buffer)); |
265 uint32_t buffer_size; | 271 uint32_t buffer_size; |
266 base::TimeDelta elapsed; | 272 base::TimeDelta elapsed; |
267 bool did_wait; | 273 bool did_wait; |
268 MojoResult result; | 274 MojoResult result; |
269 uint32_t context; | 275 uint32_t context; |
270 | 276 |
271 // Run this test both with |d0| as port 0, |d1| as port 1 and vice versa. | 277 // Run this test both with |d0| as port 0, |d1| as port 1 and vice versa. |
(...skipping 317 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
589 EXPECT_EQ(total_messages_written, total_messages_read); | 595 EXPECT_EQ(total_messages_written, total_messages_read); |
590 EXPECT_EQ(total_bytes_written, total_bytes_read); | 596 EXPECT_EQ(total_bytes_written, total_bytes_read); |
591 | 597 |
592 EXPECT_EQ(MOJO_RESULT_OK, d_write->Close()); | 598 EXPECT_EQ(MOJO_RESULT_OK, d_write->Close()); |
593 EXPECT_EQ(MOJO_RESULT_OK, d_read->Close()); | 599 EXPECT_EQ(MOJO_RESULT_OK, d_read->Close()); |
594 } | 600 } |
595 | 601 |
596 } // namespace | 602 } // namespace |
597 } // namespace system | 603 } // namespace system |
598 } // namespace mojo | 604 } // namespace mojo |
OLD | NEW |