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; |