| OLD | NEW |
| 1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 The Chromium Authors. All rights reserved. |
| 2 // Use of this source code is governed by a BSD-style license that can be | 2 // Use of this source code is governed by a BSD-style license that can be |
| 3 // found in the LICENSE file. | 3 // found in the LICENSE file. |
| 4 | 4 |
| 5 #ifndef MOJO_EDK_SYSTEM_DATA_PIPE_IMPL_H_ | 5 #ifndef MOJO_EDK_SYSTEM_DATA_PIPE_IMPL_H_ |
| 6 #define MOJO_EDK_SYSTEM_DATA_PIPE_IMPL_H_ | 6 #define MOJO_EDK_SYSTEM_DATA_PIPE_IMPL_H_ |
| 7 | 7 |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 | 9 |
| 10 #include <utility> | 10 #include <utility> |
| (...skipping 46 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 57 void set_owner(DataPipe* owner) { owner_ = owner; } | 57 void set_owner(DataPipe* owner) { owner_ = owner; } |
| 58 | 58 |
| 59 virtual void ProducerClose() = 0; | 59 virtual void ProducerClose() = 0; |
| 60 // |num_bytes.Get()| will be a nonzero multiple of |element_num_bytes()|. | 60 // |num_bytes.Get()| will be a nonzero multiple of |element_num_bytes()|. |
| 61 virtual MojoResult ProducerWriteData(UserPointer<const void> elements, | 61 virtual MojoResult ProducerWriteData(UserPointer<const void> elements, |
| 62 UserPointer<uint32_t> num_bytes, | 62 UserPointer<uint32_t> num_bytes, |
| 63 uint32_t max_num_bytes_to_write, | 63 uint32_t max_num_bytes_to_write, |
| 64 uint32_t min_num_bytes_to_write) = 0; | 64 uint32_t min_num_bytes_to_write) = 0; |
| 65 virtual MojoResult ProducerBeginWriteData( | 65 virtual MojoResult ProducerBeginWriteData( |
| 66 UserPointer<void*> buffer, | 66 UserPointer<void*> buffer, |
| 67 UserPointer<uint32_t> buffer_num_bytes, | 67 UserPointer<uint32_t> buffer_num_bytes) = 0; |
| 68 uint32_t min_num_bytes_to_write) = 0; | |
| 69 virtual MojoResult ProducerEndWriteData(uint32_t num_bytes_written) = 0; | 68 virtual MojoResult ProducerEndWriteData(uint32_t num_bytes_written) = 0; |
| 70 // Note: A producer should not be writable during a two-phase write. | 69 // Note: A producer should not be writable during a two-phase write. |
| 71 virtual HandleSignalsState ProducerGetHandleSignalsState() const = 0; | 70 virtual HandleSignalsState ProducerGetHandleSignalsState() const = 0; |
| 72 virtual void ProducerStartSerialize(Channel* channel, | 71 virtual void ProducerStartSerialize(Channel* channel, |
| 73 size_t* max_size, | 72 size_t* max_size, |
| 74 size_t* max_platform_handles) = 0; | 73 size_t* max_platform_handles) = 0; |
| 75 virtual bool ProducerEndSerialize( | 74 virtual bool ProducerEndSerialize( |
| 76 Channel* channel, | 75 Channel* channel, |
| 77 void* destination, | 76 void* destination, |
| 78 size_t* actual_size, | 77 size_t* actual_size, |
| 79 embedder::PlatformHandleVector* platform_handles) = 0; | 78 embedder::PlatformHandleVector* platform_handles) = 0; |
| 80 | 79 |
| 81 virtual void ConsumerClose() = 0; | 80 virtual void ConsumerClose() = 0; |
| 82 // |num_bytes.Get()| will be a nonzero multiple of |element_num_bytes()|. | 81 // |num_bytes.Get()| will be a nonzero multiple of |element_num_bytes()|. |
| 83 virtual MojoResult ConsumerReadData(UserPointer<void> elements, | 82 virtual MojoResult ConsumerReadData(UserPointer<void> elements, |
| 84 UserPointer<uint32_t> num_bytes, | 83 UserPointer<uint32_t> num_bytes, |
| 85 uint32_t max_num_bytes_to_read, | 84 uint32_t max_num_bytes_to_read, |
| 86 uint32_t min_num_bytes_to_read, | 85 uint32_t min_num_bytes_to_read, |
| 87 bool peek) = 0; | 86 bool peek) = 0; |
| 88 virtual MojoResult ConsumerDiscardData(UserPointer<uint32_t> num_bytes, | 87 virtual MojoResult ConsumerDiscardData(UserPointer<uint32_t> num_bytes, |
| 89 uint32_t max_num_bytes_to_discard, | 88 uint32_t max_num_bytes_to_discard, |
| 90 uint32_t min_num_bytes_to_discard) = 0; | 89 uint32_t min_num_bytes_to_discard) = 0; |
| 91 // |num_bytes.Get()| will be a nonzero multiple of |element_num_bytes()|. | 90 // |num_bytes.Get()| will be a nonzero multiple of |element_num_bytes()|. |
| 92 virtual MojoResult ConsumerQueryData(UserPointer<uint32_t> num_bytes) = 0; | 91 virtual MojoResult ConsumerQueryData(UserPointer<uint32_t> num_bytes) = 0; |
| 93 virtual MojoResult ConsumerBeginReadData( | 92 virtual MojoResult ConsumerBeginReadData( |
| 94 UserPointer<const void*> buffer, | 93 UserPointer<const void*> buffer, |
| 95 UserPointer<uint32_t> buffer_num_bytes, | 94 UserPointer<uint32_t> buffer_num_bytes) = 0; |
| 96 uint32_t min_num_bytes_to_read) = 0; | |
| 97 virtual MojoResult ConsumerEndReadData(uint32_t num_bytes_read) = 0; | 95 virtual MojoResult ConsumerEndReadData(uint32_t num_bytes_read) = 0; |
| 98 // Note: A consumer should not be writable during a two-phase read. | 96 // Note: A consumer should not be writable during a two-phase read. |
| 99 virtual HandleSignalsState ConsumerGetHandleSignalsState() const = 0; | 97 virtual HandleSignalsState ConsumerGetHandleSignalsState() const = 0; |
| 100 virtual void ConsumerStartSerialize(Channel* channel, | 98 virtual void ConsumerStartSerialize(Channel* channel, |
| 101 size_t* max_size, | 99 size_t* max_size, |
| 102 size_t* max_platform_handles) = 0; | 100 size_t* max_platform_handles) = 0; |
| 103 virtual bool ConsumerEndSerialize( | 101 virtual bool ConsumerEndSerialize( |
| 104 Channel* channel, | 102 Channel* channel, |
| 105 void* destination, | 103 void* destination, |
| 106 size_t* actual_size, | 104 size_t* actual_size, |
| (...skipping 87 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 194 struct MOJO_ALIGNAS(8) SerializedDataPipeConsumerDispatcher { | 192 struct MOJO_ALIGNAS(8) SerializedDataPipeConsumerDispatcher { |
| 195 // Only validated (and thus canonicalized) options should be serialized. | 193 // Only validated (and thus canonicalized) options should be serialized. |
| 196 // However, the deserializer must revalidate (as with everything received). | 194 // However, the deserializer must revalidate (as with everything received). |
| 197 MojoCreateDataPipeOptions validated_options; | 195 MojoCreateDataPipeOptions validated_options; |
| 198 }; | 196 }; |
| 199 | 197 |
| 200 } // namespace system | 198 } // namespace system |
| 201 } // namespace mojo | 199 } // namespace mojo |
| 202 | 200 |
| 203 #endif // MOJO_EDK_SYSTEM_DATA_PIPE_IMPL_H_ | 201 #endif // MOJO_EDK_SYSTEM_DATA_PIPE_IMPL_H_ |
| OLD | NEW |