Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(743)

Side by Side Diff: mojo/edk/system/multiprocess_message_pipe_unittest.cc

Issue 2725133002: Mojo: Armed Watchers (Closed)
Patch Set: . Created 3 years, 9 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch
OLDNEW
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 #include <stddef.h> 5 #include <stddef.h>
6 #include <stdint.h> 6 #include <stdint.h>
7 #include <stdio.h> 7 #include <stdio.h>
8 #include <string.h> 8 #include <string.h>
9 9
10 #include <string> 10 #include <string>
(...skipping 1256 matching lines...) Expand 10 before | Expand all | Expand 10 after
1267 1267
1268 // Wait on handle 0 using MojoWait. 1268 // Wait on handle 0 using MojoWait.
1269 EXPECT_EQ(MOJO_RESULT_OK, MojoWait(handles[0], MOJO_HANDLE_SIGNAL_PEER_CLOSED, 1269 EXPECT_EQ(MOJO_RESULT_OK, MojoWait(handles[0], MOJO_HANDLE_SIGNAL_PEER_CLOSED,
1270 MOJO_DEADLINE_INDEFINITE, nullptr)); 1270 MOJO_DEADLINE_INDEFINITE, nullptr));
1271 1271
1272 base::MessageLoop message_loop; 1272 base::MessageLoop message_loop;
1273 1273
1274 // Wait on handle 1 using a Watcher. 1274 // Wait on handle 1 using a Watcher.
1275 { 1275 {
1276 base::RunLoop run_loop; 1276 base::RunLoop run_loop;
1277 Watcher watcher(FROM_HERE); 1277 Watcher watcher(FROM_HERE, Watcher::ArmingPolicy::AUTOMATIC);
1278 watcher.Start(Handle(handles[1]), MOJO_HANDLE_SIGNAL_PEER_CLOSED, 1278 watcher.Start(Handle(handles[1]), MOJO_HANDLE_SIGNAL_PEER_CLOSED,
1279 base::Bind([] (base::RunLoop* loop, MojoResult result) { 1279 base::Bind([] (base::RunLoop* loop, MojoResult result) {
1280 EXPECT_EQ(MOJO_RESULT_OK, result); 1280 EXPECT_EQ(MOJO_RESULT_OK, result);
1281 loop->Quit(); 1281 loop->Quit();
1282 }, &run_loop)); 1282 }, &run_loop));
1283 run_loop.Run(); 1283 run_loop.Run();
1284 } 1284 }
1285 1285
1286 // Wait on handle 2 by polling with MojoReadMessage. 1286 // Wait on handle 2 by polling with MojoReadMessage.
1287 MojoResult result; 1287 MojoResult result;
(...skipping 95 matching lines...) Expand 10 before | Expand all | Expand 10 after
1383 INSTANTIATE_TEST_CASE_P( 1383 INSTANTIATE_TEST_CASE_P(
1384 , 1384 ,
1385 MultiprocessMessagePipeTestWithPeerSupport, 1385 MultiprocessMessagePipeTestWithPeerSupport,
1386 testing::Values(test::MojoTestBase::LaunchType::CHILD, 1386 testing::Values(test::MojoTestBase::LaunchType::CHILD,
1387 test::MojoTestBase::LaunchType::PEER, 1387 test::MojoTestBase::LaunchType::PEER,
1388 test::MojoTestBase::LaunchType::NAMED_CHILD, 1388 test::MojoTestBase::LaunchType::NAMED_CHILD,
1389 test::MojoTestBase::LaunchType::NAMED_PEER)); 1389 test::MojoTestBase::LaunchType::NAMED_PEER));
1390 } // namespace 1390 } // namespace
1391 } // namespace edk 1391 } // namespace edk
1392 } // namespace mojo 1392 } // namespace mojo
OLDNEW

Powered by Google App Engine
This is Rietveld 408576698