| Index: mojo/edk/system/message_pipe.h
|
| diff --git a/mojo/edk/system/message_pipe.h b/mojo/edk/system/message_pipe.h
|
| index d54ba7c9dd3485c2aff6d7079b736330f3f2b557..4cffa35ccf28e3d0bde130567e852be8bf9b5c67 100644
|
| --- a/mojo/edk/system/message_pipe.h
|
| +++ b/mojo/edk/system/message_pipe.h
|
| @@ -117,6 +117,12 @@ class MessagePipe final : public ChannelEndpointClient {
|
| size_t* actual_size,
|
| std::vector<platform::ScopedPlatformHandle>* platform_handles);
|
|
|
| + // This "implements" |CancelAllAwakables()|, but assumes that |mutex_| is
|
| + // already held. This is for use by
|
| + // |MessagePipeDispatcher::CreateEquivalentDispatcherAndCloseImplNoLock()|.
|
| + void CancelAllAwakablesNoLock(unsigned port)
|
| + MOJO_EXCLUSIVE_LOCKS_REQUIRED(mutex_);
|
| +
|
| // |ChannelEndpointClient| methods:
|
| bool OnReadMessage(unsigned port, MessageInTransit* message) override;
|
| void OnDetachFromChannel(unsigned port) override;
|
|
|