diff options
| author | James Robinson <jamesr@chromium.org> | 2014-10-02 17:19:39 -0700 |
|---|---|---|
| committer | James Robinson <jamesr@chromium.org> | 2014-10-03 00:20:26 +0000 |
| commit | ee7ff197a98da4636f33bd713de784948b487bd4 (patch) | |
| tree | bde85518c9be483f1e0a32c98a6dbb5e9b93e62e /mojo/edk/system/local_data_pipe.h | |
| parent | 20894f54fc1460d9f13210b427a077267ebe86ee (diff) | |
| download | chromium_src-ee7ff197a98da4636f33bd713de784948b487bd4.zip chromium_src-ee7ff197a98da4636f33bd713de784948b487bd4.tar.gz chromium_src-ee7ff197a98da4636f33bd713de784948b487bd4.tar.bz2 | |
Move mojo edk into mojo/edk
This creates a mojo/edk directory which contains the "embedder developer
kit" aka the set of code needed to embed mojo code.
mojo/edk/embedder = code from mojo/embedder
mojo/edk/system = code from mojo/system
mojo/edk/test = code used to test the previous two, from mojo/common/test
mojo/edk/ can only depend on mojo/public/, base/ and itself.
R=viettrungluu@chromium.org
Review URL: https://codereview.chromium.org/621153003
Cr-Commit-Position: refs/heads/master@{#297958}
Diffstat (limited to 'mojo/edk/system/local_data_pipe.h')
| -rw-r--r-- | mojo/edk/system/local_data_pipe.h | 92 |
1 files changed, 92 insertions, 0 deletions
diff --git a/mojo/edk/system/local_data_pipe.h b/mojo/edk/system/local_data_pipe.h new file mode 100644 index 0000000..8d3b75b --- /dev/null +++ b/mojo/edk/system/local_data_pipe.h @@ -0,0 +1,92 @@ +// 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. + +#ifndef MOJO_EDK_SYSTEM_LOCAL_DATA_PIPE_H_ +#define MOJO_EDK_SYSTEM_LOCAL_DATA_PIPE_H_ + +#include "base/macros.h" +#include "base/memory/aligned_memory.h" +#include "base/memory/ref_counted.h" +#include "base/memory/scoped_ptr.h" +#include "mojo/edk/system/data_pipe.h" +#include "mojo/edk/system/system_impl_export.h" + +namespace mojo { +namespace system { + +// |LocalDataPipe| is a subclass that "implements" |DataPipe| for data pipes +// whose producer and consumer are both local. This class is thread-safe (with +// protection provided by |DataPipe|'s |lock_|. +class MOJO_SYSTEM_IMPL_EXPORT LocalDataPipe : public DataPipe { + public: + // |validated_options| should be the output of |DataPipe::ValidateOptions()|. + // In particular: |struct_size| is ignored (so |validated_options| must be the + // current version of the struct) and |capacity_num_bytes| must be nonzero. + explicit LocalDataPipe(const MojoCreateDataPipeOptions& validated_options); + + private: + friend class base::RefCountedThreadSafe<LocalDataPipe>; + virtual ~LocalDataPipe(); + + // |DataPipe| implementation: + virtual void ProducerCloseImplNoLock() override; + virtual MojoResult ProducerWriteDataImplNoLock( + UserPointer<const void> elements, + UserPointer<uint32_t> num_bytes, + uint32_t max_num_bytes_to_write, + uint32_t min_num_bytes_to_write) override; + virtual MojoResult ProducerBeginWriteDataImplNoLock( + UserPointer<void*> buffer, + UserPointer<uint32_t> buffer_num_bytes, + uint32_t min_num_bytes_to_write) override; + virtual MojoResult ProducerEndWriteDataImplNoLock( + uint32_t num_bytes_written) override; + virtual HandleSignalsState ProducerGetHandleSignalsStateImplNoLock() + const override; + virtual void ConsumerCloseImplNoLock() override; + virtual MojoResult ConsumerReadDataImplNoLock( + UserPointer<void> elements, + UserPointer<uint32_t> num_bytes, + uint32_t max_num_bytes_to_read, + uint32_t min_num_bytes_to_read) override; + virtual MojoResult ConsumerDiscardDataImplNoLock( + UserPointer<uint32_t> num_bytes, + uint32_t max_num_bytes_to_discard, + uint32_t min_num_bytes_to_discard) override; + virtual MojoResult ConsumerQueryDataImplNoLock( + UserPointer<uint32_t> num_bytes) override; + virtual MojoResult ConsumerBeginReadDataImplNoLock( + UserPointer<const void*> buffer, + UserPointer<uint32_t> buffer_num_bytes, + uint32_t min_num_bytes_to_read) override; + virtual MojoResult ConsumerEndReadDataImplNoLock( + uint32_t num_bytes_read) override; + virtual HandleSignalsState ConsumerGetHandleSignalsStateImplNoLock() + const override; + + void EnsureBufferNoLock(); + void DestroyBufferNoLock(); + + // Get the maximum (single) write/read size right now (in number of elements); + // result fits in a |uint32_t|. + size_t GetMaxNumBytesToWriteNoLock(); + size_t GetMaxNumBytesToReadNoLock(); + + // Marks the given number of bytes as consumed/discarded. |num_bytes| must be + // greater than |current_num_bytes_|. + void MarkDataAsConsumedNoLock(size_t num_bytes); + + // The members below are protected by |DataPipe|'s |lock_|: + scoped_ptr<char, base::AlignedFreeDeleter> buffer_; + // Circular buffer. + size_t start_index_; + size_t current_num_bytes_; + + DISALLOW_COPY_AND_ASSIGN(LocalDataPipe); +}; + +} // namespace system +} // namespace mojo + +#endif // MOJO_EDK_SYSTEM_LOCAL_DATA_PIPE_H_ |