| OLD | NEW |
| 1 // Copyright 2013 The Chromium Authors. All rights reserved. | 1 // Copyright 2013 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_H_ | 5 #ifndef MOJO_EDK_SYSTEM_DATA_PIPE_H_ |
| 6 #define MOJO_EDK_SYSTEM_DATA_PIPE_H_ | 6 #define MOJO_EDK_SYSTEM_DATA_PIPE_H_ |
| 7 | 7 |
| 8 #include <stdint.h> | 8 #include <stdint.h> |
| 9 | 9 |
| 10 #include <memory> | 10 #include <memory> |
| (...skipping 98 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 109 void ProducerGetOptions(uint32_t* write_threshold_num_bytes); | 109 void ProducerGetOptions(uint32_t* write_threshold_num_bytes); |
| 110 MojoResult ProducerWriteData(UserPointer<const void> elements, | 110 MojoResult ProducerWriteData(UserPointer<const void> elements, |
| 111 UserPointer<uint32_t> num_bytes, | 111 UserPointer<uint32_t> num_bytes, |
| 112 bool all_or_none); | 112 bool all_or_none); |
| 113 MojoResult ProducerBeginWriteData(UserPointer<void*> buffer, | 113 MojoResult ProducerBeginWriteData(UserPointer<void*> buffer, |
| 114 UserPointer<uint32_t> buffer_num_bytes); | 114 UserPointer<uint32_t> buffer_num_bytes); |
| 115 MojoResult ProducerEndWriteData(uint32_t num_bytes_written); | 115 MojoResult ProducerEndWriteData(uint32_t num_bytes_written); |
| 116 HandleSignalsState ProducerGetHandleSignalsState(); | 116 HandleSignalsState ProducerGetHandleSignalsState(); |
| 117 MojoResult ProducerAddAwakable(Awakable* awakable, | 117 MojoResult ProducerAddAwakable(Awakable* awakable, |
| 118 uint64_t context, | 118 uint64_t context, |
| 119 bool force, | 119 bool persistent, |
| 120 MojoHandleSignals signals, | 120 MojoHandleSignals signals, |
| 121 HandleSignalsState* signals_state); | 121 HandleSignalsState* signals_state); |
| 122 void ProducerRemoveAwakable(bool match_context, | 122 void ProducerRemoveAwakable(bool match_context, |
| 123 Awakable* awakable, | 123 Awakable* awakable, |
| 124 uint64_t context, | 124 uint64_t context, |
| 125 HandleSignalsState* signals_state); | 125 HandleSignalsState* signals_state); |
| 126 void ProducerStartSerialize(Channel* channel, | 126 void ProducerStartSerialize(Channel* channel, |
| 127 size_t* max_size, | 127 size_t* max_size, |
| 128 size_t* max_platform_handles); | 128 size_t* max_platform_handles); |
| 129 bool ProducerEndSerialize( | 129 bool ProducerEndSerialize( |
| (...skipping 16 matching lines...) Expand all Loading... |
| 146 bool peek); | 146 bool peek); |
| 147 MojoResult ConsumerDiscardData(UserPointer<uint32_t> num_bytes, | 147 MojoResult ConsumerDiscardData(UserPointer<uint32_t> num_bytes, |
| 148 bool all_or_none); | 148 bool all_or_none); |
| 149 MojoResult ConsumerQueryData(UserPointer<uint32_t> num_bytes); | 149 MojoResult ConsumerQueryData(UserPointer<uint32_t> num_bytes); |
| 150 MojoResult ConsumerBeginReadData(UserPointer<const void*> buffer, | 150 MojoResult ConsumerBeginReadData(UserPointer<const void*> buffer, |
| 151 UserPointer<uint32_t> buffer_num_bytes); | 151 UserPointer<uint32_t> buffer_num_bytes); |
| 152 MojoResult ConsumerEndReadData(uint32_t num_bytes_read); | 152 MojoResult ConsumerEndReadData(uint32_t num_bytes_read); |
| 153 HandleSignalsState ConsumerGetHandleSignalsState(); | 153 HandleSignalsState ConsumerGetHandleSignalsState(); |
| 154 MojoResult ConsumerAddAwakable(Awakable* awakable, | 154 MojoResult ConsumerAddAwakable(Awakable* awakable, |
| 155 uint64_t context, | 155 uint64_t context, |
| 156 bool force, | 156 bool persistent, |
| 157 MojoHandleSignals signals, | 157 MojoHandleSignals signals, |
| 158 HandleSignalsState* signals_state); | 158 HandleSignalsState* signals_state); |
| 159 void ConsumerRemoveAwakable(bool match_context, | 159 void ConsumerRemoveAwakable(bool match_context, |
| 160 Awakable* awakable, | 160 Awakable* awakable, |
| 161 uint64_t context, | 161 uint64_t context, |
| 162 HandleSignalsState* signals_state); | 162 HandleSignalsState* signals_state); |
| 163 void ConsumerStartSerialize(Channel* channel, | 163 void ConsumerStartSerialize(Channel* channel, |
| 164 size_t* max_size, | 164 size_t* max_size, |
| 165 size_t* max_platform_handles); | 165 size_t* max_platform_handles); |
| 166 bool ConsumerEndSerialize( | 166 bool ConsumerEndSerialize( |
| (...skipping 144 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 311 uint32_t consumer_two_phase_max_num_bytes_read_ MOJO_GUARDED_BY(mutex_); | 311 uint32_t consumer_two_phase_max_num_bytes_read_ MOJO_GUARDED_BY(mutex_); |
| 312 std::unique_ptr<DataPipeImpl> impl_ MOJO_GUARDED_BY(mutex_); | 312 std::unique_ptr<DataPipeImpl> impl_ MOJO_GUARDED_BY(mutex_); |
| 313 | 313 |
| 314 MOJO_DISALLOW_COPY_AND_ASSIGN(DataPipe); | 314 MOJO_DISALLOW_COPY_AND_ASSIGN(DataPipe); |
| 315 }; | 315 }; |
| 316 | 316 |
| 317 } // namespace system | 317 } // namespace system |
| 318 } // namespace mojo | 318 } // namespace mojo |
| 319 | 319 |
| 320 #endif // MOJO_EDK_SYSTEM_DATA_PIPE_H_ | 320 #endif // MOJO_EDK_SYSTEM_DATA_PIPE_H_ |
| OLD | NEW |