| Index: mojo/edk/system/core.cc
|
| diff --git a/mojo/edk/system/core.cc b/mojo/edk/system/core.cc
|
| index c0b8be223c394da3512b18a539240e49d5617492..dfdb377d7b64ac5d7b27205dba73d4584b9cce0d 100644
|
| --- a/mojo/edk/system/core.cc
|
| +++ b/mojo/edk/system/core.cc
|
| @@ -152,7 +152,7 @@ NodeController* Core::GetNodeController() {
|
| }
|
|
|
| scoped_refptr<Dispatcher> Core::GetDispatcher(MojoHandle handle) {
|
| - base::AutoLock lock(handles_lock_);
|
| + base::AutoLock lock(handles_.GetLock());
|
| return handles_.GetDispatcher(handle);
|
| }
|
|
|
| @@ -208,7 +208,7 @@ void Core::SetMachPortProvider(base::PortProvider* port_provider) {
|
| }
|
|
|
| MojoHandle Core::AddDispatcher(scoped_refptr<Dispatcher> dispatcher) {
|
| - base::AutoLock lock(handles_lock_);
|
| + base::AutoLock lock(handles_.GetLock());
|
| return handles_.AddDispatcher(dispatcher);
|
| }
|
|
|
| @@ -217,7 +217,7 @@ bool Core::AddDispatchersFromTransit(
|
| MojoHandle* handles) {
|
| bool failed = false;
|
| {
|
| - base::AutoLock lock(handles_lock_);
|
| + base::AutoLock lock(handles_.GetLock());
|
| if (!handles_.AddDispatchersFromTransit(dispatchers, handles))
|
| failed = true;
|
| }
|
| @@ -243,7 +243,7 @@ MojoResult Core::CreatePlatformHandleWrapper(
|
| MojoResult Core::PassWrappedPlatformHandle(
|
| MojoHandle wrapper_handle,
|
| ScopedPlatformHandle* platform_handle) {
|
| - base::AutoLock lock(handles_lock_);
|
| + base::AutoLock lock(handles_.GetLock());
|
| scoped_refptr<Dispatcher> d;
|
| MojoResult result = handles_.GetAndRemoveDispatcher(wrapper_handle, &d);
|
| if (result != MOJO_RESULT_OK)
|
| @@ -294,7 +294,7 @@ MojoResult Core::PassSharedMemoryHandle(
|
| scoped_refptr<Dispatcher> dispatcher;
|
| MojoResult result = MOJO_RESULT_OK;
|
| {
|
| - base::AutoLock lock(handles_lock_);
|
| + base::AutoLock lock(handles_.GetLock());
|
| // Get the dispatcher and check it before removing it from the handle table
|
| // to ensure that the dispatcher is of the correct type. This ensures we
|
| // don't close and remove the wrong type of dispatcher.
|
| @@ -360,7 +360,7 @@ MojoResult Core::Close(MojoHandle handle) {
|
| RequestContext request_context;
|
| scoped_refptr<Dispatcher> dispatcher;
|
| {
|
| - base::AutoLock lock(handles_lock_);
|
| + base::AutoLock lock(handles_.GetLock());
|
| MojoResult rv = handles_.GetAndRemoveDispatcher(handle, &dispatcher);
|
| if (rv != MOJO_RESULT_OK)
|
| return rv;
|
| @@ -452,7 +452,7 @@ MojoResult Core::AllocMessage(uint32_t num_bytes,
|
|
|
| std::vector<Dispatcher::DispatcherInTransit> dispatchers;
|
| {
|
| - base::AutoLock lock(handles_lock_);
|
| + base::AutoLock lock(handles_.GetLock());
|
| MojoResult rv = handles_.BeginTransit(handles, num_handles, &dispatchers);
|
| if (rv != MOJO_RESULT_OK) {
|
| handles_.CancelTransit(dispatchers);
|
| @@ -466,7 +466,7 @@ MojoResult Core::AllocMessage(uint32_t num_bytes,
|
| &msg, num_bytes, dispatchers.data(), num_handles);
|
|
|
| {
|
| - base::AutoLock lock(handles_lock_);
|
| + base::AutoLock lock(handles_.GetLock());
|
| if (rv == MOJO_RESULT_OK) {
|
| handles_.CompleteTransitAndClose(dispatchers);
|
| *message = reinterpret_cast<MojoMessageHandle>(msg.release());
|
| @@ -531,7 +531,7 @@ MojoResult Core::CreateMessagePipe(
|
| scoped_refptr<Dispatcher> unused;
|
| unused->Close();
|
|
|
| - base::AutoLock lock(handles_lock_);
|
| + base::AutoLock lock(handles_.GetLock());
|
| handles_.GetAndRemoveDispatcher(*message_pipe_handle0, &unused);
|
| return MOJO_RESULT_RESOURCE_EXHAUSTED;
|
| }
|
| @@ -631,7 +631,7 @@ MojoResult Core::FuseMessagePipes(MojoHandle handle0, MojoHandle handle1) {
|
|
|
| bool valid_handles = true;
|
| {
|
| - base::AutoLock lock(handles_lock_);
|
| + base::AutoLock lock(handles_.GetLock());
|
| MojoResult result0 = handles_.GetAndRemoveDispatcher(handle0, &dispatcher0);
|
| MojoResult result1 = handles_.GetAndRemoveDispatcher(handle1, &dispatcher1);
|
| if (result0 != MOJO_RESULT_OK || result1 != MOJO_RESULT_OK ||
|
| @@ -727,7 +727,7 @@ MojoResult Core::CreateDataPipe(
|
| *data_pipe_consumer_handle == MOJO_HANDLE_INVALID) {
|
| if (*data_pipe_producer_handle != MOJO_HANDLE_INVALID) {
|
| scoped_refptr<Dispatcher> unused;
|
| - base::AutoLock lock(handles_lock_);
|
| + base::AutoLock lock(handles_.GetLock());
|
| handles_.GetAndRemoveDispatcher(*data_pipe_producer_handle, &unused);
|
| }
|
| producer->Close();
|
| @@ -966,7 +966,7 @@ MojoResult Core::UnwrapPlatformSharedBufferHandle(
|
| scoped_refptr<Dispatcher> dispatcher;
|
| MojoResult result = MOJO_RESULT_OK;
|
| {
|
| - base::AutoLock lock(handles_lock_);
|
| + base::AutoLock lock(handles_.GetLock());
|
| result = handles_.GetAndRemoveDispatcher(mojo_handle, &dispatcher);
|
| if (result != MOJO_RESULT_OK)
|
| return result;
|
| @@ -997,7 +997,7 @@ MojoResult Core::UnwrapPlatformSharedBufferHandle(
|
| }
|
|
|
| void Core::GetActiveHandlesForTest(std::vector<MojoHandle>* handles) {
|
| - base::AutoLock lock(handles_lock_);
|
| + base::AutoLock lock(handles_.GetLock());
|
| handles_.GetActiveHandlesForTest(handles);
|
| }
|
|
|
|
|