| 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 89 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 100 scoped_refptr<DataPipe>* data_pipe); | 100 scoped_refptr<DataPipe>* data_pipe); |
| 101 | 101 |
| 102 // These are called by the producer dispatcher to implement its methods of | 102 // These are called by the producer dispatcher to implement its methods of |
| 103 // corresponding names. | 103 // corresponding names. |
| 104 void ProducerCancelAllAwakables(); | 104 void ProducerCancelAllAwakables(); |
| 105 void ProducerClose(); | 105 void ProducerClose(); |
| 106 MojoResult ProducerWriteData(UserPointer<const void> elements, | 106 MojoResult ProducerWriteData(UserPointer<const void> elements, |
| 107 UserPointer<uint32_t> num_bytes, | 107 UserPointer<uint32_t> num_bytes, |
| 108 bool all_or_none); | 108 bool all_or_none); |
| 109 MojoResult ProducerBeginWriteData(UserPointer<void*> buffer, | 109 MojoResult ProducerBeginWriteData(UserPointer<void*> buffer, |
| 110 UserPointer<uint32_t> buffer_num_bytes, | 110 UserPointer<uint32_t> buffer_num_bytes); |
| 111 bool all_or_none); | |
| 112 MojoResult ProducerEndWriteData(uint32_t num_bytes_written); | 111 MojoResult ProducerEndWriteData(uint32_t num_bytes_written); |
| 113 HandleSignalsState ProducerGetHandleSignalsState(); | 112 HandleSignalsState ProducerGetHandleSignalsState(); |
| 114 MojoResult ProducerAddAwakable(Awakable* awakable, | 113 MojoResult ProducerAddAwakable(Awakable* awakable, |
| 115 MojoHandleSignals signals, | 114 MojoHandleSignals signals, |
| 116 uint32_t context, | 115 uint32_t context, |
| 117 HandleSignalsState* signals_state); | 116 HandleSignalsState* signals_state); |
| 118 void ProducerRemoveAwakable(Awakable* awakable, | 117 void ProducerRemoveAwakable(Awakable* awakable, |
| 119 HandleSignalsState* signals_state); | 118 HandleSignalsState* signals_state); |
| 120 void ProducerStartSerialize(Channel* channel, | 119 void ProducerStartSerialize(Channel* channel, |
| 121 size_t* max_size, | 120 size_t* max_size, |
| (...skipping 11 matching lines...) Expand all Loading... |
| 133 // This does not validate its arguments, except to check that |*num_bytes| is | 132 // This does not validate its arguments, except to check that |*num_bytes| is |
| 134 // a multiple of |element_num_bytes_|. | 133 // a multiple of |element_num_bytes_|. |
| 135 MojoResult ConsumerReadData(UserPointer<void> elements, | 134 MojoResult ConsumerReadData(UserPointer<void> elements, |
| 136 UserPointer<uint32_t> num_bytes, | 135 UserPointer<uint32_t> num_bytes, |
| 137 bool all_or_none, | 136 bool all_or_none, |
| 138 bool peek); | 137 bool peek); |
| 139 MojoResult ConsumerDiscardData(UserPointer<uint32_t> num_bytes, | 138 MojoResult ConsumerDiscardData(UserPointer<uint32_t> num_bytes, |
| 140 bool all_or_none); | 139 bool all_or_none); |
| 141 MojoResult ConsumerQueryData(UserPointer<uint32_t> num_bytes); | 140 MojoResult ConsumerQueryData(UserPointer<uint32_t> num_bytes); |
| 142 MojoResult ConsumerBeginReadData(UserPointer<const void*> buffer, | 141 MojoResult ConsumerBeginReadData(UserPointer<const void*> buffer, |
| 143 UserPointer<uint32_t> buffer_num_bytes, | 142 UserPointer<uint32_t> buffer_num_bytes); |
| 144 bool all_or_none); | |
| 145 MojoResult ConsumerEndReadData(uint32_t num_bytes_read); | 143 MojoResult ConsumerEndReadData(uint32_t num_bytes_read); |
| 146 HandleSignalsState ConsumerGetHandleSignalsState(); | 144 HandleSignalsState ConsumerGetHandleSignalsState(); |
| 147 MojoResult ConsumerAddAwakable(Awakable* awakable, | 145 MojoResult ConsumerAddAwakable(Awakable* awakable, |
| 148 MojoHandleSignals signals, | 146 MojoHandleSignals signals, |
| 149 uint32_t context, | 147 uint32_t context, |
| 150 HandleSignalsState* signals_state); | 148 HandleSignalsState* signals_state); |
| 151 void ConsumerRemoveAwakable(Awakable* awakable, | 149 void ConsumerRemoveAwakable(Awakable* awakable, |
| 152 HandleSignalsState* signals_state); | 150 HandleSignalsState* signals_state); |
| 153 void ConsumerStartSerialize(Channel* channel, | 151 void ConsumerStartSerialize(Channel* channel, |
| 154 size_t* max_size, | 152 size_t* max_size, |
| (...skipping 123 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 278 uint32_t consumer_two_phase_max_num_bytes_read_ MOJO_GUARDED_BY(mutex_); | 276 uint32_t consumer_two_phase_max_num_bytes_read_ MOJO_GUARDED_BY(mutex_); |
| 279 std::unique_ptr<DataPipeImpl> impl_ MOJO_GUARDED_BY(mutex_); | 277 std::unique_ptr<DataPipeImpl> impl_ MOJO_GUARDED_BY(mutex_); |
| 280 | 278 |
| 281 MOJO_DISALLOW_COPY_AND_ASSIGN(DataPipe); | 279 MOJO_DISALLOW_COPY_AND_ASSIGN(DataPipe); |
| 282 }; | 280 }; |
| 283 | 281 |
| 284 } // namespace system | 282 } // namespace system |
| 285 } // namespace mojo | 283 } // namespace mojo |
| 286 | 284 |
| 287 #endif // MOJO_EDK_SYSTEM_DATA_PIPE_H_ | 285 #endif // MOJO_EDK_SYSTEM_DATA_PIPE_H_ |
| OLD | NEW |