Index: third_party/mojo/src/mojo/edk/system/slave_connection_manager.h |
diff --git a/third_party/mojo/src/mojo/edk/system/slave_connection_manager.h b/third_party/mojo/src/mojo/edk/system/slave_connection_manager.h |
index b2cd92cd08278415b43bb767cb950f95fa192491..40fc79bf2ff7c53be72b6f0d8dfda8ecfe175b46 100644 |
--- a/third_party/mojo/src/mojo/edk/system/slave_connection_manager.h |
+++ b/third_party/mojo/src/mojo/edk/system/slave_connection_manager.h |
@@ -7,12 +7,12 @@ |
#include "base/memory/ref_counted.h" |
#include "base/memory/scoped_ptr.h" |
+#include "base/synchronization/lock.h" |
#include "base/synchronization/waitable_event.h" |
#include "base/threading/thread.h" |
#include "mojo/edk/embedder/scoped_platform_handle.h" |
#include "mojo/edk/embedder/slave_process_delegate.h" |
#include "mojo/edk/system/connection_manager.h" |
-#include "mojo/edk/system/mutex.h" |
#include "mojo/edk/system/raw_channel.h" |
#include "mojo/edk/system/system_impl_export.h" |
#include "mojo/public/cpp/system/macros.h" |
@@ -58,20 +58,20 @@ |
void Shutdown() override; |
bool AllowConnect(const ConnectionIdentifier& connection_id) override; |
bool CancelConnect(const ConnectionIdentifier& connection_id) override; |
- Result Connect(const ConnectionIdentifier& connection_id, |
- ProcessIdentifier* peer_process_identifier, |
- embedder::ScopedPlatformHandle* platform_handle) override; |
+ bool Connect(const ConnectionIdentifier& connection_id, |
+ ProcessIdentifier* peer_process_identifier, |
+ embedder::ScopedPlatformHandle* platform_handle) override; |
private: |
// These should only be called on |private_thread_|: |
void InitOnPrivateThread(embedder::ScopedPlatformHandle platform_handle); |
void ShutdownOnPrivateThread(); |
void AllowConnectOnPrivateThread(const ConnectionIdentifier& connection_id, |
- Result* result); |
+ bool* result); |
void CancelConnectOnPrivateThread(const ConnectionIdentifier& connection_id, |
- Result* result); |
+ bool* result); |
void ConnectOnPrivateThread(const ConnectionIdentifier& connection_id, |
- Result* result, |
+ bool* result, |
ProcessIdentifier* peer_process_identifier, |
embedder::ScopedPlatformHandle* platform_handle); |
@@ -112,7 +112,7 @@ |
AWAITING_CONNECT_ACK |
}; |
AwaitingAckType awaiting_ack_type_; |
- Result* ack_result_; |
+ bool* ack_result_; |
// Used only when waiting for the ack to "connect": |
ProcessIdentifier* ack_peer_process_identifier_; |
embedder::ScopedPlatformHandle* ack_platform_handle_; |
@@ -143,7 +143,7 @@ |
// |
// TODO(vtl): This is all a hack. It'd really suffice to have a version of |
// |RawChannel| with fully synchronous reading and writing. |
- Mutex mutex_; |
+ base::Lock lock_; |
base::WaitableEvent event_; |
MOJO_DISALLOW_COPY_AND_ASSIGN(SlaveConnectionManager); |