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

mojo/edk/system/data_pipe_impl_unittest.cc

 // Copyright 2015 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.
 
 // This file contains tests that are shared between different implementations of
 // |DataPipeImpl|.
 
 #include "mojo/edk/system/data_pipe_impl.h"
 
 #include <stdint.h>
@@ skipping 123 matching lines @@
   }
   MojoResult ProducerBeginWriteData(UserPointer<void*> buffer,
                                     UserPointer<uint32_t> buffer_num_bytes) {
     return dpp()->ProducerBeginWriteData(buffer, buffer_num_bytes);
   }
   MojoResult ProducerEndWriteData(uint32_t num_bytes_written) {
     return dpp()->ProducerEndWriteData(num_bytes_written);
   }
   MojoResult ProducerAddAwakable(Awakable* awakable,
                                  uint64_t context,
-                                 bool force,
+                                 bool persistent,
                                  MojoHandleSignals signals,
                                  HandleSignalsState* signals_state) {
-    return dpp()->ProducerAddAwakable(awakable, context, force, signals,
+    return dpp()->ProducerAddAwakable(awakable, context, persistent, signals,
                                       signals_state);
   }
   void ProducerRemoveAwakable(bool match_context,
                               Awakable* awakable,
                               uint64_t context,
                               HandleSignalsState* signals_state) {
     return dpp()->ProducerRemoveAwakable(match_context, awakable, context,
                                          signals_state);
   }
 
@@ skipping 19 matching lines @@
   }
   MojoResult ConsumerBeginReadData(UserPointer<const void*> buffer,
                                    UserPointer<uint32_t> buffer_num_bytes) {
     return dpc()->ConsumerBeginReadData(buffer, buffer_num_bytes);
   }
   MojoResult ConsumerEndReadData(uint32_t num_bytes_read) {
     return dpc()->ConsumerEndReadData(num_bytes_read);
   }
   MojoResult ConsumerAddAwakable(Awakable* awakable,
                                  uint64_t context,
-                                 bool force,
+                                 bool persistent,
                                  MojoHandleSignals signals,
                                  HandleSignalsState* signals_state) {
-    return dpc()->ConsumerAddAwakable(awakable, context, force, signals,
+    return dpc()->ConsumerAddAwakable(awakable, context, persistent, signals,
                                       signals_state);
   }
   void ConsumerRemoveAwakable(bool match_context,
                               Awakable* awakable,
                               uint64_t context,
                               HandleSignalsState* signals_state) {
     return dpc()->ConsumerRemoveAwakable(match_context, awakable, context,
                                          signals_state);
   }
 
@@ skipping 2768 matching lines @@
                                       MOJO_HANDLE_SIGNAL_READ_THRESHOLD, &hss));
   EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfied_signals);
   EXPECT_EQ(MOJO_HANDLE_SIGNAL_PEER_CLOSED, hss.satisfiable_signals);
 
   this->ConsumerClose();
 }
 
 }  // namespace
 }  // namespace system
 }  // namespace mojo