Index: mojo/system/message_pipe_dispatcher_unittest.cc |
diff --git a/mojo/system/message_pipe_dispatcher_unittest.cc b/mojo/system/message_pipe_dispatcher_unittest.cc |
index f68334841e91422cd39c4e2035c41dc85ebab623..2fc64693ed5ace256a9d8dd1903c0c91bd838650 100644 |
--- a/mojo/system/message_pipe_dispatcher_unittest.cc |
+++ b/mojo/system/message_pipe_dispatcher_unittest.cc |
@@ -37,9 +37,11 @@ TEST(MessagePipeDispatcherTest, Basic) { |
// Run this test both with |d0| as port 0, |d1| as port 1 and vice versa. |
for (unsigned i = 0; i < 2; i++) { |
- scoped_refptr<MessagePipeDispatcher> d0(new MessagePipeDispatcher()); |
+ scoped_refptr<MessagePipeDispatcher> d0(new MessagePipeDispatcher( |
+ MessagePipeDispatcher::kDefaultCreateOptions)); |
EXPECT_EQ(Dispatcher::kTypeMessagePipe, d0->GetType()); |
- scoped_refptr<MessagePipeDispatcher> d1(new MessagePipeDispatcher()); |
+ scoped_refptr<MessagePipeDispatcher> d1(new MessagePipeDispatcher( |
+ MessagePipeDispatcher::kDefaultCreateOptions)); |
{ |
scoped_refptr<MessagePipe> mp(new MessagePipe()); |
d0->Init(mp, i); // 0, 1. |
@@ -113,8 +115,10 @@ TEST(MessagePipeDispatcherTest, Basic) { |
TEST(MessagePipeDispatcherTest, InvalidParams) { |
char buffer[1]; |
- scoped_refptr<MessagePipeDispatcher> d0(new MessagePipeDispatcher()); |
- scoped_refptr<MessagePipeDispatcher> d1(new MessagePipeDispatcher()); |
+ scoped_refptr<MessagePipeDispatcher> d0(new MessagePipeDispatcher( |
+ MessagePipeDispatcher::kDefaultCreateOptions)); |
+ scoped_refptr<MessagePipeDispatcher> d1(new MessagePipeDispatcher( |
+ MessagePipeDispatcher::kDefaultCreateOptions)); |
{ |
scoped_refptr<MessagePipe> mp(new MessagePipe()); |
d0->Init(mp, 0); |
@@ -153,8 +157,10 @@ TEST(MessagePipeDispatcherTest, BasicClosed) { |
// Run this test both with |d0| as port 0, |d1| as port 1 and vice versa. |
for (unsigned i = 0; i < 2; i++) { |
- scoped_refptr<MessagePipeDispatcher> d0(new MessagePipeDispatcher()); |
- scoped_refptr<MessagePipeDispatcher> d1(new MessagePipeDispatcher()); |
+ scoped_refptr<MessagePipeDispatcher> d0(new MessagePipeDispatcher( |
+ MessagePipeDispatcher::kDefaultCreateOptions)); |
+ scoped_refptr<MessagePipeDispatcher> d1(new MessagePipeDispatcher( |
+ MessagePipeDispatcher::kDefaultCreateOptions)); |
{ |
scoped_refptr<MessagePipe> mp(new MessagePipe()); |
d0->Init(mp, i); // 0, 1. |
@@ -261,8 +267,10 @@ TEST(MessagePipeDispatcherTest, BasicThreaded) { |
// Run this test both with |d0| as port 0, |d1| as port 1 and vice versa. |
for (unsigned i = 0; i < 2; i++) { |
- scoped_refptr<MessagePipeDispatcher> d0(new MessagePipeDispatcher()); |
- scoped_refptr<MessagePipeDispatcher> d1(new MessagePipeDispatcher()); |
+ scoped_refptr<MessagePipeDispatcher> d0(new MessagePipeDispatcher( |
+ MessagePipeDispatcher::kDefaultCreateOptions)); |
+ scoped_refptr<MessagePipeDispatcher> d1(new MessagePipeDispatcher( |
+ MessagePipeDispatcher::kDefaultCreateOptions)); |
{ |
scoped_refptr<MessagePipe> mp(new MessagePipe()); |
d0->Init(mp, i); // 0, 1. |
@@ -339,8 +347,10 @@ TEST(MessagePipeDispatcherTest, BasicThreaded) { |
} |
for (unsigned i = 0; i < 2; i++) { |
- scoped_refptr<MessagePipeDispatcher> d0(new MessagePipeDispatcher()); |
- scoped_refptr<MessagePipeDispatcher> d1(new MessagePipeDispatcher()); |
+ scoped_refptr<MessagePipeDispatcher> d0(new MessagePipeDispatcher( |
+ MessagePipeDispatcher::kDefaultCreateOptions)); |
+ scoped_refptr<MessagePipeDispatcher> d1(new MessagePipeDispatcher( |
+ MessagePipeDispatcher::kDefaultCreateOptions)); |
{ |
scoped_refptr<MessagePipe> mp(new MessagePipe()); |
d0->Init(mp, i); // 0, 1. |
@@ -513,8 +523,10 @@ TEST(MessagePipeDispatcherTest, Stress) { |
static const size_t kNumWriters = 30; |
static const size_t kNumReaders = kNumWriters; |
- scoped_refptr<MessagePipeDispatcher> d_write(new MessagePipeDispatcher()); |
- scoped_refptr<MessagePipeDispatcher> d_read(new MessagePipeDispatcher()); |
+ scoped_refptr<MessagePipeDispatcher> d_write(new MessagePipeDispatcher( |
+ MessagePipeDispatcher::kDefaultCreateOptions)); |
+ scoped_refptr<MessagePipeDispatcher> d_read(new MessagePipeDispatcher( |
+ MessagePipeDispatcher::kDefaultCreateOptions)); |
{ |
scoped_refptr<MessagePipe> mp(new MessagePipe()); |
d_write->Init(mp, 0); |