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_CONSUMER_DISPATCHER_H_ | 5 #ifndef MOJO_EDK_SYSTEM_DATA_PIPE_CONSUMER_DISPATCHER_H_ |
6 #define MOJO_EDK_SYSTEM_DATA_PIPE_CONSUMER_DISPATCHER_H_ | 6 #define MOJO_EDK_SYSTEM_DATA_PIPE_CONSUMER_DISPATCHER_H_ |
7 | 7 |
8 #include <stddef.h> | 8 #include <stddef.h> |
9 #include <stdint.h> | 9 #include <stdint.h> |
10 | 10 |
(...skipping 25 matching lines...) Expand all Loading... |
36 NodeController* node_controller, | 36 NodeController* node_controller, |
37 const ports::PortRef& control_port, | 37 const ports::PortRef& control_port, |
38 scoped_refptr<PlatformSharedBuffer> shared_ring_buffer, | 38 scoped_refptr<PlatformSharedBuffer> shared_ring_buffer, |
39 const MojoCreateDataPipeOptions& options, | 39 const MojoCreateDataPipeOptions& options, |
40 bool initialized, | 40 bool initialized, |
41 uint64_t pipe_id); | 41 uint64_t pipe_id); |
42 | 42 |
43 // Dispatcher: | 43 // Dispatcher: |
44 Type GetType() const override; | 44 Type GetType() const override; |
45 MojoResult Close() override; | 45 MojoResult Close() override; |
| 46 MojoResult Watch(MojoHandleSignals signals, |
| 47 const Watcher::WatchCallback& callback, |
| 48 uintptr_t context) override; |
| 49 MojoResult CancelWatch(uintptr_t context) override; |
46 MojoResult ReadData(void* elements, | 50 MojoResult ReadData(void* elements, |
47 uint32_t* num_bytes, | 51 uint32_t* num_bytes, |
48 MojoReadDataFlags flags) override; | 52 MojoReadDataFlags flags) override; |
49 MojoResult BeginReadData(const void** buffer, | 53 MojoResult BeginReadData(const void** buffer, |
50 uint32_t* buffer_num_bytes, | 54 uint32_t* buffer_num_bytes, |
51 MojoReadDataFlags flags) override; | 55 MojoReadDataFlags flags) override; |
52 MojoResult EndReadData(uint32_t num_bytes_read) override; | 56 MojoResult EndReadData(uint32_t num_bytes_read) override; |
53 HandleSignalsState GetHandleSignalsState() const override; | 57 HandleSignalsState GetHandleSignalsState() const override; |
54 MojoResult AddAwakable(Awakable* awakable, | 58 MojoResult AddAwakable(Awakable* awakable, |
55 MojoHandleSignals signals, | 59 MojoHandleSignals signals, |
(...skipping 57 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
113 uint32_t read_offset_ = 0; | 117 uint32_t read_offset_ = 0; |
114 uint32_t bytes_available_ = 0; | 118 uint32_t bytes_available_ = 0; |
115 | 119 |
116 DISALLOW_COPY_AND_ASSIGN(DataPipeConsumerDispatcher); | 120 DISALLOW_COPY_AND_ASSIGN(DataPipeConsumerDispatcher); |
117 }; | 121 }; |
118 | 122 |
119 } // namespace edk | 123 } // namespace edk |
120 } // namespace mojo | 124 } // namespace mojo |
121 | 125 |
122 #endif // MOJO_EDK_SYSTEM_DATA_PIPE_CONSUMER_DISPATCHER_H_ | 126 #endif // MOJO_EDK_SYSTEM_DATA_PIPE_CONSUMER_DISPATCHER_H_ |
OLD | NEW |