Mojo: MojoWaitFlags -> MojoHandleSignals.

mojo/system/data_pipe.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/system/data_pipe.h"
 
 #include <string.h>
 
 #include <algorithm>
 #include <limits>
@@ skipping 159 matching lines @@
   WaitFlagsState new_producer_state = ProducerGetWaitFlagsStateNoLock();
   if (new_producer_state.satisfies(MOJO_WAIT_FLAG_WRITABLE))
     AwakeProducerWaitersForStateChangeNoLock(new_producer_state);
   WaitFlagsState new_consumer_state = ConsumerGetWaitFlagsStateNoLock();
   if (!new_consumer_state.equals(old_consumer_state))
     AwakeConsumerWaitersForStateChangeNoLock(new_consumer_state);
   return rv;
 }
 
 MojoResult DataPipe::ProducerAddWaiter(Waiter* waiter,
-                                       MojoWaitFlags flags,
+                                       MojoHandleSignals signals,
                                        uint32_t context) {
   base::AutoLock locker(lock_);
   DCHECK(has_local_producer_no_lock());
 
   WaitFlagsState producer_state = ProducerGetWaitFlagsStateNoLock();
-  if (producer_state.satisfies(flags))
+  if (producer_state.satisfies(signals))
     return MOJO_RESULT_ALREADY_EXISTS;
-  if (!producer_state.can_satisfy(flags))
+  if (!producer_state.can_satisfy(signals))
     return MOJO_RESULT_FAILED_PRECONDITION;
 
-  producer_waiter_list_->AddWaiter(waiter, flags, context);
+  producer_waiter_list_->AddWaiter(waiter, signals, context);
   return MOJO_RESULT_OK;
 }
 
 void DataPipe::ProducerRemoveWaiter(Waiter* waiter) {
   base::AutoLock locker(lock_);
   DCHECK(has_local_producer_no_lock());
   producer_waiter_list_->RemoveWaiter(waiter);
 }
 
 bool DataPipe::ProducerIsBusy() const {
@@ skipping 120 matching lines @@
   WaitFlagsState new_consumer_state = ConsumerGetWaitFlagsStateNoLock();
   if (new_consumer_state.satisfies(MOJO_WAIT_FLAG_READABLE))
     AwakeConsumerWaitersForStateChangeNoLock(new_consumer_state);
   WaitFlagsState new_producer_state = ProducerGetWaitFlagsStateNoLock();
   if (!new_producer_state.equals(old_producer_state))
     AwakeProducerWaitersForStateChangeNoLock(new_producer_state);
   return rv;
 }
 
 MojoResult DataPipe::ConsumerAddWaiter(Waiter* waiter,
-                                       MojoWaitFlags flags,
+                                       MojoHandleSignals signals,
                                        uint32_t context) {
   base::AutoLock locker(lock_);
   DCHECK(has_local_consumer_no_lock());
 
   WaitFlagsState consumer_state = ConsumerGetWaitFlagsStateNoLock();
-  if (consumer_state.satisfies(flags))
+  if (consumer_state.satisfies(signals))
     return MOJO_RESULT_ALREADY_EXISTS;
-  if (!consumer_state.can_satisfy(flags))
+  if (!consumer_state.can_satisfy(signals))
     return MOJO_RESULT_FAILED_PRECONDITION;
 
-  consumer_waiter_list_->AddWaiter(waiter, flags, context);
+  consumer_waiter_list_->AddWaiter(waiter, signals, context);
   return MOJO_RESULT_OK;
 }
 
 void DataPipe::ConsumerRemoveWaiter(Waiter* waiter) {
   base::AutoLock locker(lock_);
   DCHECK(has_local_consumer_no_lock());
   consumer_waiter_list_->RemoveWaiter(waiter);
 }
 
 bool DataPipe::ConsumerIsBusy() const {
@@ skipping 38 matching lines @@
 void DataPipe::AwakeConsumerWaitersForStateChangeNoLock(
     const WaitFlagsState& new_consumer_state) {
   lock_.AssertAcquired();
   if (!has_local_consumer_no_lock())
     return;
   consumer_waiter_list_->AwakeWaitersForStateChange(new_consumer_state);
 }
 
 }  // namespace system
 }  // namespace mojo