Move mojo edk into mojo/edk

mojo/system/data_pipe_producer_dispatcher.cc

Index: mojo/system/data_pipe_producer_dispatcher.cc
diff --git a/mojo/system/data_pipe_producer_dispatcher.cc b/mojo/system/data_pipe_producer_dispatcher.cc
deleted file mode 100644
index b7e7db3a032416d4443ff5ec06181a5864079628..0000000000000000000000000000000000000000
--- a/mojo/system/data_pipe_producer_dispatcher.cc
+++ /dev/null
@@ -1,107 +0,0 @@
-// 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_producer_dispatcher.h"
-
-#include "base/logging.h"
-#include "mojo/system/data_pipe.h"
-#include "mojo/system/memory.h"
-
-namespace mojo {
-namespace system {
-
-DataPipeProducerDispatcher::DataPipeProducerDispatcher() {
-}
-
-void DataPipeProducerDispatcher::Init(scoped_refptr<DataPipe> data_pipe) {
-  DCHECK(data_pipe.get());
-  data_pipe_ = data_pipe;
-}
-
-Dispatcher::Type DataPipeProducerDispatcher::GetType() const {
-  return kTypeDataPipeProducer;
-}
-
-DataPipeProducerDispatcher::~DataPipeProducerDispatcher() {
-  // |Close()|/|CloseImplNoLock()| should have taken care of the pipe.
-  DCHECK(!data_pipe_.get());
-}
-
-void DataPipeProducerDispatcher::CancelAllWaitersNoLock() {
-  lock().AssertAcquired();
-  data_pipe_->ProducerCancelAllWaiters();
-}
-
-void DataPipeProducerDispatcher::CloseImplNoLock() {
-  lock().AssertAcquired();
-  data_pipe_->ProducerClose();
-  data_pipe_ = nullptr;
-}
-
-scoped_refptr<Dispatcher>
-DataPipeProducerDispatcher::CreateEquivalentDispatcherAndCloseImplNoLock() {
-  lock().AssertAcquired();
-
-  scoped_refptr<DataPipeProducerDispatcher> rv =
-      new DataPipeProducerDispatcher();
-  rv->Init(data_pipe_);
-  data_pipe_ = nullptr;
-  return scoped_refptr<Dispatcher>(rv.get());
-}
-
-MojoResult DataPipeProducerDispatcher::WriteDataImplNoLock(
-    UserPointer<const void> elements,
-    UserPointer<uint32_t> num_bytes,
-    MojoWriteDataFlags flags) {
-  lock().AssertAcquired();
-  return data_pipe_->ProducerWriteData(
-      elements, num_bytes, (flags & MOJO_WRITE_DATA_FLAG_ALL_OR_NONE));
-}
-
-MojoResult DataPipeProducerDispatcher::BeginWriteDataImplNoLock(
-    UserPointer<void*> buffer,
-    UserPointer<uint32_t> buffer_num_bytes,
-    MojoWriteDataFlags flags) {
-  lock().AssertAcquired();
-
-  return data_pipe_->ProducerBeginWriteData(
-      buffer, buffer_num_bytes, (flags & MOJO_WRITE_DATA_FLAG_ALL_OR_NONE));
-}
-
-MojoResult DataPipeProducerDispatcher::EndWriteDataImplNoLock(
-    uint32_t num_bytes_written) {
-  lock().AssertAcquired();
-
-  return data_pipe_->ProducerEndWriteData(num_bytes_written);
-}
-
-HandleSignalsState DataPipeProducerDispatcher::GetHandleSignalsStateImplNoLock()
-    const {
-  lock().AssertAcquired();
-  return data_pipe_->ProducerGetHandleSignalsState();
-}
-
-MojoResult DataPipeProducerDispatcher::AddWaiterImplNoLock(
-    Waiter* waiter,
-    MojoHandleSignals signals,
-    uint32_t context,
-    HandleSignalsState* signals_state) {
-  lock().AssertAcquired();
-  return data_pipe_->ProducerAddWaiter(waiter, signals, context, signals_state);
-}
-
-void DataPipeProducerDispatcher::RemoveWaiterImplNoLock(
-    Waiter* waiter,
-    HandleSignalsState* signals_state) {
-  lock().AssertAcquired();
-  data_pipe_->ProducerRemoveWaiter(waiter, signals_state);
-}
-
-bool DataPipeProducerDispatcher::IsBusyNoLock() const {
-  lock().AssertAcquired();
-  return data_pipe_->ProducerIsBusy();
-}
-
-}  // namespace system
-}  // namespace mojo