| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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 #ifndef MOJO_EDK_SYSTEM_SLAVE_CONNECTION_MANAGER_H_ | 5 #ifndef MOJO_EDK_SYSTEM_SLAVE_CONNECTION_MANAGER_H_ |
| 6 #define MOJO_EDK_SYSTEM_SLAVE_CONNECTION_MANAGER_H_ | 6 #define MOJO_EDK_SYSTEM_SLAVE_CONNECTION_MANAGER_H_ |
| 7 | 7 |
| 8 #include <memory> | 8 #include <memory> |
| 9 | 9 |
| 10 #include "base/threading/thread.h" | 10 #include "base/threading/thread.h" |
| (...skipping 62 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 73 Result* result); | 73 Result* result); |
| 74 void ConnectOnPrivateThread(const ConnectionIdentifier& connection_id, | 74 void ConnectOnPrivateThread(const ConnectionIdentifier& connection_id, |
| 75 Result* result, | 75 Result* result, |
| 76 ProcessIdentifier* peer_process_identifier, | 76 ProcessIdentifier* peer_process_identifier, |
| 77 bool* is_first, | 77 bool* is_first, |
| 78 embedder::ScopedPlatformHandle* platform_handle); | 78 embedder::ScopedPlatformHandle* platform_handle); |
| 79 | 79 |
| 80 // |RawChannel::Delegate| methods (only called on |private_thread_|): | 80 // |RawChannel::Delegate| methods (only called on |private_thread_|): |
| 81 void OnReadMessage( | 81 void OnReadMessage( |
| 82 const MessageInTransit::View& message_view, | 82 const MessageInTransit::View& message_view, |
| 83 embedder::ScopedPlatformHandleVectorPtr platform_handles) override; | 83 std::unique_ptr<std::vector<embedder::ScopedPlatformHandle>> |
| 84 platform_handles) override; |
| 84 void OnError(Error error) override; | 85 void OnError(Error error) override; |
| 85 | 86 |
| 86 // Asserts that the current thread is *not* |private_thread_| (no-op if | 87 // Asserts that the current thread is *not* |private_thread_| (no-op if |
| 87 // DCHECKs are not enabled). This should only be called while | 88 // DCHECKs are not enabled). This should only be called while |
| 88 // |private_thread_| is alive (i.e., after |Init()| but before |Shutdown()|). | 89 // |private_thread_| is alive (i.e., after |Init()| but before |Shutdown()|). |
| 89 void AssertNotOnPrivateThread() const; | 90 void AssertNotOnPrivateThread() const; |
| 90 | 91 |
| 91 // Asserts that the current thread is |private_thread_| (no-op if DCHECKs are | 92 // Asserts that the current thread is |private_thread_| (no-op if DCHECKs are |
| 92 // not enabled). This should only be called while |private_thread_| is alive | 93 // not enabled). This should only be called while |private_thread_| is alive |
| 93 // (i.e., after |Init()| but before |Shutdown()|). | 94 // (i.e., after |Init()| but before |Shutdown()|). |
| (...skipping 55 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 149 util::Mutex mutex_; | 150 util::Mutex mutex_; |
| 150 util::AutoResetWaitableEvent event_; | 151 util::AutoResetWaitableEvent event_; |
| 151 | 152 |
| 152 MOJO_DISALLOW_COPY_AND_ASSIGN(SlaveConnectionManager); | 153 MOJO_DISALLOW_COPY_AND_ASSIGN(SlaveConnectionManager); |
| 153 }; | 154 }; |
| 154 | 155 |
| 155 } // namespace system | 156 } // namespace system |
| 156 } // namespace mojo | 157 } // namespace mojo |
| 157 | 158 |
| 158 #endif // MOJO_EDK_SYSTEM_SLAVE_CONNECTION_MANAGER_H_ | 159 #endif // MOJO_EDK_SYSTEM_SLAVE_CONNECTION_MANAGER_H_ |
| OLD | NEW |