Add different behavior to AwakableList for "persistent" vs "one-shot" awakables.

mojo/edk/system/local_message_pipe_endpoint.cc

 // Copyright 2013 The Chromium Authors. All rights reserved.
 // Use of this source code is governed by a BSD-style license that can be
 // found in the LICENSE file.
 
 #include "mojo/edk/system/local_message_pipe_endpoint.h"
 
 #include <string.h>
 
 #include <utility>
 
@@ skipping 47 matching lines @@
 }
 
 void LocalMessagePipeEndpoint::Close() {
   DCHECK(is_open_);
   is_open_ = false;
   message_queue_.Clear();
 }
 
 void LocalMessagePipeEndpoint::CancelAllState() {
   DCHECK(is_open_);
-  awakable_list_.CancelAll();
+  awakable_list_.CancelAndRemoveAll();
 }
 
 MojoResult LocalMessagePipeEndpoint::ReadMessage(
     UserPointer<void> bytes,
     UserPointer<uint32_t> num_bytes,
     HandleVector* handles,
     uint32_t* num_handles,
     MojoReadMessageFlags flags) {
   DCHECK(is_open_);
   DCHECK(!handles || handles->empty());
@@ skipping 65 matching lines @@
   } else {
     rv.satisfied_signals |= MOJO_HANDLE_SIGNAL_PEER_CLOSED;
   }
   rv.satisfiable_signals |= MOJO_HANDLE_SIGNAL_PEER_CLOSED;
   return rv;
 }
 
 MojoResult LocalMessagePipeEndpoint::AddAwakable(
     Awakable* awakable,
     uint64_t context,
-    bool force,
+    bool persistent,
     MojoHandleSignals signals,
     HandleSignalsState* signals_state) {
   DCHECK(is_open_);
 
   HandleSignalsState state = GetHandleSignalsState();
   if (signals_state)
     *signals_state = state;
   if (state.satisfies(signals)) {
-    if (force)
-      awakable_list_.Add(awakable, context, signals);
+    if (persistent)
+      awakable_list_.Add(awakable, context, persistent, signals);
     return MOJO_RESULT_ALREADY_EXISTS;
   }
   if (!state.can_satisfy(signals)) {
-    if (force)
-      awakable_list_.Add(awakable, context, signals);
+    if (persistent)
+      awakable_list_.Add(awakable, context, persistent, signals);
     return MOJO_RESULT_FAILED_PRECONDITION;
   }
 
-  awakable_list_.Add(awakable, context, signals);
+  awakable_list_.Add(awakable, context, persistent, signals);
   return MOJO_RESULT_OK;
 }
 
 void LocalMessagePipeEndpoint::RemoveAwakable(
     bool match_context,
     Awakable* awakable,
     uint64_t context,
     HandleSignalsState* signals_state) {
   DCHECK(is_open_);
   awakable_list_.Remove(match_context, awakable, context);
   if (signals_state)
     *signals_state = GetHandleSignalsState();
 }
 
 }  // namespace system
 }  // namespace mojo