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 "base/compiler_specific.h" | 10 #include "base/compiler_specific.h" |
(...skipping 212 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
223 // current version of the struct) and |capacity_num_bytes| must be nonzero. | 223 // current version of the struct) and |capacity_num_bytes| must be nonzero. |
224 // TODO(vtl): |has_local_producer|/|has_local_consumer| shouldn't really be | 224 // TODO(vtl): |has_local_producer|/|has_local_consumer| shouldn't really be |
225 // arguments here. Instead, they should be determined from the |impl| ... but | 225 // arguments here. Instead, they should be determined from the |impl| ... but |
226 // the |impl|'s typically figures these out by examining the owner, i.e., the | 226 // the |impl|'s typically figures these out by examining the owner, i.e., the |
227 // |DataPipe| object. Probably, this indicates that more stuff should be moved | 227 // |DataPipe| object. Probably, this indicates that more stuff should be moved |
228 // to |DataPipeImpl|, but for now we'll live with this. | 228 // to |DataPipeImpl|, but for now we'll live with this. |
229 DataPipe(bool has_local_producer, | 229 DataPipe(bool has_local_producer, |
230 bool has_local_consumer, | 230 bool has_local_consumer, |
231 const MojoCreateDataPipeOptions& validated_options, | 231 const MojoCreateDataPipeOptions& validated_options, |
232 scoped_ptr<DataPipeImpl> impl); | 232 scoped_ptr<DataPipeImpl> impl); |
233 virtual ~DataPipe(); | 233 ~DataPipe() override; |
234 | 234 |
235 // |ChannelEndpointClient| implementation: | 235 // |ChannelEndpointClient| implementation: |
236 bool OnReadMessage(unsigned port, MessageInTransit* message) override; | 236 bool OnReadMessage(unsigned port, MessageInTransit* message) override; |
237 void OnDetachFromChannel(unsigned port) override; | 237 void OnDetachFromChannel(unsigned port) override; |
238 | 238 |
239 void AwakeProducerAwakablesForStateChangeNoLock( | 239 void AwakeProducerAwakablesForStateChangeNoLock( |
240 const HandleSignalsState& new_producer_state); | 240 const HandleSignalsState& new_producer_state); |
241 void AwakeConsumerAwakablesForStateChangeNoLock( | 241 void AwakeConsumerAwakablesForStateChangeNoLock( |
242 const HandleSignalsState& new_consumer_state); | 242 const HandleSignalsState& new_consumer_state); |
243 | 243 |
(...skipping 24 matching lines...) Expand all Loading... |
268 uint32_t consumer_two_phase_max_num_bytes_read_; | 268 uint32_t consumer_two_phase_max_num_bytes_read_; |
269 scoped_ptr<DataPipeImpl> impl_; | 269 scoped_ptr<DataPipeImpl> impl_; |
270 | 270 |
271 DISALLOW_COPY_AND_ASSIGN(DataPipe); | 271 DISALLOW_COPY_AND_ASSIGN(DataPipe); |
272 }; | 272 }; |
273 | 273 |
274 } // namespace system | 274 } // namespace system |
275 } // namespace mojo | 275 } // namespace mojo |
276 | 276 |
277 #endif // MOJO_EDK_SYSTEM_DATA_PIPE_H_ | 277 #endif // MOJO_EDK_SYSTEM_DATA_PIPE_H_ |
OLD | NEW |