Index: third_party/mojo/src/mojo/edk/system/connection_manager_unittest.cc |
diff --git a/third_party/mojo/src/mojo/edk/system/connection_manager_unittest.cc b/third_party/mojo/src/mojo/edk/system/connection_manager_unittest.cc |
index 0d8f4795ae845cc90bba62984b9099a776d10f2f..ba4af9c21bcf61a8071c9269ddce76daf0152396 100644 |
--- a/third_party/mojo/src/mojo/edk/system/connection_manager_unittest.cc |
+++ b/third_party/mojo/src/mojo/edk/system/connection_manager_unittest.cc |
@@ -78,20 +78,20 @@ class TestSlaveInfo { |
DISALLOW_COPY_AND_ASSIGN(TestSlaveInfo); |
}; |
-// Connects the given |slave| (with the given |slave_process_delegate| to the |
+// Connects the given |slave| (with the given |slave_process_delegate|) to the |
// given master, creating and using a |TestSlaveInfo| with the given |
-// |slave_name|. |
-void ConnectSlave(MasterConnectionManager* master, |
- embedder::SlaveProcessDelegate* slave_process_delegate, |
- SlaveConnectionManager* slave, |
- const std::string& slave_name, |
- ProcessIdentifier* slave_process_identifier) { |
+// |slave_name|, and returns the process identifier for the slave. |
+ProcessIdentifier ConnectSlave( |
+ MasterConnectionManager* master, |
+ embedder::SlaveProcessDelegate* slave_process_delegate, |
+ SlaveConnectionManager* slave, |
+ const std::string& slave_name) { |
embedder::PlatformChannelPair platform_channel_pair; |
- master->AddSlave(new TestSlaveInfo(slave_name), |
- platform_channel_pair.PassServerHandle(), |
- slave_process_identifier); |
+ ProcessIdentifier slave_process_identifier = master->AddSlave( |
+ new TestSlaveInfo(slave_name), platform_channel_pair.PassServerHandle()); |
slave->Init(base::MessageLoop::current()->task_runner(), |
slave_process_delegate, platform_channel_pair.PassClientHandle()); |
+ return slave_process_identifier; |
} |
class MockMasterProcessDelegate : public embedder::MasterProcessDelegate { |
@@ -207,16 +207,14 @@ TEST_F(ConnectionManagerTest, BasicConnectSlaves) { |
MockSlaveProcessDelegate slave1_process_delegate; |
SlaveConnectionManager slave1(platform_support()); |
- ProcessIdentifier slave1_id = kInvalidProcessIdentifier; |
- ConnectSlave(&master, &slave1_process_delegate, &slave1, "slave1", |
- &slave1_id); |
+ ProcessIdentifier slave1_id = |
+ ConnectSlave(&master, &slave1_process_delegate, &slave1, "slave1"); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave1_id)); |
MockSlaveProcessDelegate slave2_process_delegate; |
SlaveConnectionManager slave2(platform_support()); |
- ProcessIdentifier slave2_id = kInvalidProcessIdentifier; |
- ConnectSlave(&master, &slave2_process_delegate, &slave2, "slave2", |
- &slave2_id); |
+ ProcessIdentifier slave2_id = |
+ ConnectSlave(&master, &slave2_process_delegate, &slave2, "slave2"); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave2_id)); |
// TODO(vtl): If/when I add the ability to get one's own process identifier, |
// there'll be more we can check. |
@@ -273,8 +271,8 @@ TEST_F(ConnectionManagerTest, ShutdownMasterBeforeSlave) { |
MockSlaveProcessDelegate slave_process_delegate; |
SlaveConnectionManager slave(platform_support()); |
- ProcessIdentifier slave_id = kInvalidProcessIdentifier; |
- ConnectSlave(&master, &slave_process_delegate, &slave, "slave", &slave_id); |
+ ProcessIdentifier slave_id = |
+ ConnectSlave(&master, &slave_process_delegate, &slave, "slave"); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave_id)); |
// The process manager shouldn't have gotten any notifications yet. (Spin the |
@@ -303,16 +301,14 @@ TEST_F(ConnectionManagerTest, SlaveCancelConnect) { |
MockSlaveProcessDelegate slave1_process_delegate; |
SlaveConnectionManager slave1(platform_support()); |
- ProcessIdentifier slave1_id = kInvalidProcessIdentifier; |
- ConnectSlave(&master, &slave1_process_delegate, &slave1, "slave1", |
- &slave1_id); |
+ ProcessIdentifier slave1_id = |
+ ConnectSlave(&master, &slave1_process_delegate, &slave1, "slave1"); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave1_id)); |
MockSlaveProcessDelegate slave2_process_delegate; |
SlaveConnectionManager slave2(platform_support()); |
- ProcessIdentifier slave2_id = kInvalidProcessIdentifier; |
- ConnectSlave(&master, &slave2_process_delegate, &slave2, "slave2", |
- &slave2_id); |
+ ProcessIdentifier slave2_id = |
+ ConnectSlave(&master, &slave2_process_delegate, &slave2, "slave2"); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave2_id)); |
EXPECT_NE(slave1_id, slave2_id); |
@@ -340,16 +336,14 @@ TEST_F(ConnectionManagerTest, ErrorRemovePending) { |
MockSlaveProcessDelegate slave1_process_delegate; |
SlaveConnectionManager slave1(platform_support()); |
- ProcessIdentifier slave1_id = kInvalidProcessIdentifier; |
- ConnectSlave(&master, &slave1_process_delegate, &slave1, "slave1", |
- &slave1_id); |
+ ProcessIdentifier slave1_id = |
+ ConnectSlave(&master, &slave1_process_delegate, &slave1, "slave1"); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave1_id)); |
MockSlaveProcessDelegate slave2_process_delegate; |
SlaveConnectionManager slave2(platform_support()); |
- ProcessIdentifier slave2_id = kInvalidProcessIdentifier; |
- ConnectSlave(&master, &slave2_process_delegate, &slave2, "slave2", |
- &slave2_id); |
+ ProcessIdentifier slave2_id = |
+ ConnectSlave(&master, &slave2_process_delegate, &slave2, "slave2"); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave2_id)); |
EXPECT_NE(slave1_id, slave2_id); |
@@ -382,8 +376,8 @@ TEST_F(ConnectionManagerTest, ConnectSlaveToSelf) { |
MockSlaveProcessDelegate slave_process_delegate; |
SlaveConnectionManager slave(platform_support()); |
- ProcessIdentifier slave_id = kInvalidProcessIdentifier; |
- ConnectSlave(&master, &slave_process_delegate, &slave, "slave", &slave_id); |
+ ProcessIdentifier slave_id = |
+ ConnectSlave(&master, &slave_process_delegate, &slave, "slave"); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave_id)); |
ConnectionIdentifier connection_id = master.GenerateConnectionIdentifier(); |
@@ -414,16 +408,14 @@ TEST_F(ConnectionManagerTest, ConnectSlavesTwice) { |
MockSlaveProcessDelegate slave1_process_delegate; |
SlaveConnectionManager slave1(platform_support()); |
- ProcessIdentifier slave1_id = kInvalidProcessIdentifier; |
- ConnectSlave(&master, &slave1_process_delegate, &slave1, "slave1", |
- &slave1_id); |
+ ProcessIdentifier slave1_id = |
+ ConnectSlave(&master, &slave1_process_delegate, &slave1, "slave1"); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave1_id)); |
MockSlaveProcessDelegate slave2_process_delegate; |
SlaveConnectionManager slave2(platform_support()); |
- ProcessIdentifier slave2_id = kInvalidProcessIdentifier; |
- ConnectSlave(&master, &slave2_process_delegate, &slave2, "slave2", |
- &slave2_id); |
+ ProcessIdentifier slave2_id = |
+ ConnectSlave(&master, &slave2_process_delegate, &slave2, "slave2"); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave2_id)); |
EXPECT_NE(slave1_id, slave2_id); |
@@ -474,8 +466,8 @@ TEST_F(ConnectionManagerTest, ConnectMasterToSlave) { |
MockSlaveProcessDelegate slave_process_delegate; |
SlaveConnectionManager slave(platform_support()); |
- ProcessIdentifier slave_id = kInvalidProcessIdentifier; |
- ConnectSlave(&master, &slave_process_delegate, &slave, "slave", &slave_id); |
+ ProcessIdentifier slave_id = |
+ ConnectSlave(&master, &slave_process_delegate, &slave, "slave"); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave_id)); |
ConnectionIdentifier connection_id = master.GenerateConnectionIdentifier(); |
@@ -533,8 +525,8 @@ TEST_F(ConnectionManagerTest, MasterCancelConnect) { |
MockSlaveProcessDelegate slave_process_delegate; |
SlaveConnectionManager slave(platform_support()); |
- ProcessIdentifier slave_id = kInvalidProcessIdentifier; |
- ConnectSlave(&master, &slave_process_delegate, &slave, "slave", &slave_id); |
+ ProcessIdentifier slave_id = |
+ ConnectSlave(&master, &slave_process_delegate, &slave, "slave"); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave_id)); |
ConnectionIdentifier connection_id = master.GenerateConnectionIdentifier(); |
@@ -560,9 +552,8 @@ TEST_F(ConnectionManagerTest, AddSlaveThenImmediateShutdown) { |
MockSlaveProcessDelegate slave_process_delegate; |
SlaveConnectionManager slave(platform_support()); |
embedder::PlatformChannelPair platform_channel_pair; |
- ProcessIdentifier slave_id = kInvalidProcessIdentifier; |
- master.AddSlave(new TestSlaveInfo("slave"), |
- platform_channel_pair.PassServerHandle(), &slave_id); |
+ ProcessIdentifier slave_id = master.AddSlave( |
+ new TestSlaveInfo("slave"), platform_channel_pair.PassServerHandle()); |
master.Shutdown(); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave_id)); |
// Since we never initialized |slave|, we don't have to shut it down. |
@@ -575,10 +566,9 @@ TEST_F(ConnectionManagerTest, AddSlaveAndBootstrap) { |
embedder::PlatformChannelPair platform_channel_pair; |
ConnectionIdentifier connection_id = master.GenerateConnectionIdentifier(); |
- ProcessIdentifier slave_id = kInvalidProcessIdentifier; |
- master.AddSlaveAndBootstrap(new TestSlaveInfo("slave"), |
- platform_channel_pair.PassServerHandle(), |
- connection_id, &slave_id); |
+ ProcessIdentifier slave_id = master.AddSlaveAndBootstrap( |
+ new TestSlaveInfo("slave"), platform_channel_pair.PassServerHandle(), |
+ connection_id); |
EXPECT_TRUE(IsValidSlaveProcessIdentifier(slave_id)); |
embedder::ScopedPlatformHandle h1; |