Upstream version 5.34.104.0

[platform/framework/web/crosswalk.git] / src / mojo / system / data_pipe.cc

diff --git a/src/mojo/system/data_pipe.cc b/src/mojo/system/data_pipe.cc
index 670d9fd..469e557 100644 (file)
--- a/src/mojo/system/data_pipe.cc
+++ b/src/mojo/system/data_pipe.cc
@@ -183,6 +183,11 @@ void DataPipe::ProducerRemoveWaiter(Waiter* waiter) {
   producer_waiter_list_->RemoveWaiter(waiter);
 }
 
+bool DataPipe::ProducerIsBusy() const {
+  base::AutoLock locker(lock_);
+  return producer_in_two_phase_write_no_lock();
+}
+
 void DataPipe::ConsumerCancelAllWaiters() {
   base::AutoLock locker(lock_);
   DCHECK(has_local_consumer_no_lock());
@@ -325,6 +330,12 @@ void DataPipe::ConsumerRemoveWaiter(Waiter* waiter) {
   consumer_waiter_list_->RemoveWaiter(waiter);
 }
 
+bool DataPipe::ConsumerIsBusy() const {
+  base::AutoLock locker(lock_);
+  return consumer_in_two_phase_read_no_lock();
+}
+
+
 DataPipe::DataPipe(bool has_local_producer,
                    bool has_local_consumer,
                    const MojoCreateDataPipeOptions& validated_options)