Index: third_party/mojo/src/mojo/edk/system/test_channel_endpoint_client.cc |
diff --git a/third_party/mojo/src/mojo/edk/system/test_channel_endpoint_client.cc b/third_party/mojo/src/mojo/edk/system/test_channel_endpoint_client.cc |
index 51d2a5806a6fc9589fbe2eeceb5b83fcca0a98f6..b3e69b11c8d5674f7541ac23cc66e512cd99cfdf 100644 |
--- a/third_party/mojo/src/mojo/edk/system/test_channel_endpoint_client.cc |
+++ b/third_party/mojo/src/mojo/edk/system/test_channel_endpoint_client.cc |
@@ -17,7 +17,7 @@ TestChannelEndpointClient::TestChannelEndpointClient() |
} |
void TestChannelEndpointClient::Init(unsigned port, ChannelEndpoint* endpoint) { |
- base::AutoLock locker(lock_); |
+ MutexLocker locker(&mutex_); |
ASSERT_EQ(0u, port_); |
ASSERT_FALSE(endpoint_); |
port_ = port; |
@@ -25,30 +25,30 @@ void TestChannelEndpointClient::Init(unsigned port, ChannelEndpoint* endpoint) { |
} |
bool TestChannelEndpointClient::IsDetached() const { |
- base::AutoLock locker(lock_); |
+ MutexLocker locker(&mutex_); |
return !endpoint_; |
} |
size_t TestChannelEndpointClient::NumMessages() const { |
- base::AutoLock locker(lock_); |
+ MutexLocker locker(&mutex_); |
return messages_.Size(); |
} |
scoped_ptr<MessageInTransit> TestChannelEndpointClient::PopMessage() { |
- base::AutoLock locker(lock_); |
+ MutexLocker locker(&mutex_); |
if (messages_.IsEmpty()) |
return nullptr; |
return messages_.GetMessage(); |
} |
void TestChannelEndpointClient::SetReadEvent(base::WaitableEvent* read_event) { |
- base::AutoLock locker(lock_); |
+ MutexLocker locker(&mutex_); |
read_event_ = read_event; |
} |
bool TestChannelEndpointClient::OnReadMessage(unsigned port, |
MessageInTransit* message) { |
- base::AutoLock locker(lock_); |
+ MutexLocker locker(&mutex_); |
EXPECT_EQ(port_, port); |
EXPECT_TRUE(endpoint_); |
@@ -61,9 +61,9 @@ bool TestChannelEndpointClient::OnReadMessage(unsigned port, |
} |
void TestChannelEndpointClient::OnDetachFromChannel(unsigned port) { |
- EXPECT_EQ(port_, port); |
+ MutexLocker locker(&mutex_); |
- base::AutoLock locker(lock_); |
+ EXPECT_EQ(port_, port); |
ASSERT_TRUE(endpoint_); |
endpoint_->DetachFromClient(); |
endpoint_ = nullptr; |