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_RAW_CHANNEL_H_ | 5 #ifndef MOJO_EDK_SYSTEM_RAW_CHANNEL_H_ |
6 #define MOJO_EDK_SYSTEM_RAW_CHANNEL_H_ | 6 #define MOJO_EDK_SYSTEM_RAW_CHANNEL_H_ |
7 | 7 |
8 #include <memory> | 8 #include <memory> |
9 #include <vector> | 9 #include <vector> |
10 | 10 |
11 #include "base/memory/scoped_ptr.h" | |
12 #include "base/memory/weak_ptr.h" | 11 #include "base/memory/weak_ptr.h" |
13 #include "mojo/edk/embedder/platform_handle_vector.h" | 12 #include "mojo/edk/embedder/platform_handle_vector.h" |
14 #include "mojo/edk/embedder/scoped_platform_handle.h" | 13 #include "mojo/edk/embedder/scoped_platform_handle.h" |
15 #include "mojo/edk/system/message_in_transit.h" | 14 #include "mojo/edk/system/message_in_transit.h" |
16 #include "mojo/edk/system/message_in_transit_queue.h" | 15 #include "mojo/edk/system/message_in_transit_queue.h" |
17 #include "mojo/edk/system/mutex.h" | 16 #include "mojo/edk/system/mutex.h" |
18 #include "mojo/edk/system/system_impl_export.h" | 17 #include "mojo/edk/system/system_impl_export.h" |
19 #include "mojo/edk/system/thread_annotations.h" | 18 #include "mojo/edk/system/thread_annotations.h" |
20 #include "mojo/public/cpp/system/macros.h" | 19 #include "mojo/public/cpp/system/macros.h" |
21 | 20 |
(...skipping 73 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
95 // will no longer be used after |Shutdown()|. | 94 // will no longer be used after |Shutdown()|. |
96 void Init(Delegate* delegate) MOJO_NOT_THREAD_SAFE; | 95 void Init(Delegate* delegate) MOJO_NOT_THREAD_SAFE; |
97 | 96 |
98 // This must be called (on the I/O thread) before this object is destroyed. | 97 // This must be called (on the I/O thread) before this object is destroyed. |
99 void Shutdown() MOJO_NOT_THREAD_SAFE; | 98 void Shutdown() MOJO_NOT_THREAD_SAFE; |
100 | 99 |
101 // Writes the given message (or schedules it to be written). |message| must | 100 // Writes the given message (or schedules it to be written). |message| must |
102 // have no |Dispatcher|s still attached (i.e., | 101 // have no |Dispatcher|s still attached (i.e., |
103 // |SerializeAndCloseDispatchers()| should have been called). This method is | 102 // |SerializeAndCloseDispatchers()| should have been called). This method is |
104 // thread-safe and may be called from any thread. Returns true on success. | 103 // thread-safe and may be called from any thread. Returns true on success. |
105 bool WriteMessage(scoped_ptr<MessageInTransit> message); | 104 bool WriteMessage(std::unique_ptr<MessageInTransit> message); |
106 | 105 |
107 // Returns true if the write buffer is empty (i.e., all messages written using | 106 // Returns true if the write buffer is empty (i.e., all messages written using |
108 // |WriteMessage()| have actually been sent. | 107 // |WriteMessage()| have actually been sent. |
109 // TODO(vtl): We should really also notify our delegate when the write buffer | 108 // TODO(vtl): We should really also notify our delegate when the write buffer |
110 // becomes empty (or something like that). | 109 // becomes empty (or something like that). |
111 bool IsWriteBufferEmpty(); | 110 bool IsWriteBufferEmpty(); |
112 | 111 |
113 // Returns the amount of space needed in the |MessageInTransit|'s | 112 // Returns the amount of space needed in the |MessageInTransit|'s |
114 // |TransportData|'s "platform handle table" per platform handle (to be | 113 // |TransportData|'s "platform handle table" per platform handle (to be |
115 // attached to a message). (This amount may be zero.) | 114 // attached to a message). (This amount may be zero.) |
(...skipping 103 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
219 ReadBuffer* read_buffer() { return read_buffer_.get(); } | 218 ReadBuffer* read_buffer() { return read_buffer_.get(); } |
220 | 219 |
221 WriteBuffer* write_buffer_no_lock() | 220 WriteBuffer* write_buffer_no_lock() |
222 MOJO_EXCLUSIVE_LOCKS_REQUIRED(write_mutex_) { | 221 MOJO_EXCLUSIVE_LOCKS_REQUIRED(write_mutex_) { |
223 return write_buffer_.get(); | 222 return write_buffer_.get(); |
224 } | 223 } |
225 | 224 |
226 // Adds |message| to the write message queue. Implementation subclasses may | 225 // Adds |message| to the write message queue. Implementation subclasses may |
227 // override this to add any additional "control" messages needed. This is | 226 // override this to add any additional "control" messages needed. This is |
228 // called (on any thread). | 227 // called (on any thread). |
229 virtual void EnqueueMessageNoLock(scoped_ptr<MessageInTransit> message) | 228 virtual void EnqueueMessageNoLock(std::unique_ptr<MessageInTransit> message) |
230 MOJO_EXCLUSIVE_LOCKS_REQUIRED(write_mutex_); | 229 MOJO_EXCLUSIVE_LOCKS_REQUIRED(write_mutex_); |
231 | 230 |
232 // Handles any control messages targeted to the |RawChannel| (or | 231 // Handles any control messages targeted to the |RawChannel| (or |
233 // implementation subclass). Implementation subclasses may override this to | 232 // implementation subclass). Implementation subclasses may override this to |
234 // handle any implementation-specific control messages, but should call | 233 // handle any implementation-specific control messages, but should call |
235 // |RawChannel::OnReadMessageForRawChannel()| for any remaining messages. | 234 // |RawChannel::OnReadMessageForRawChannel()| for any remaining messages. |
236 // Returns true on success and false on error (e.g., invalid control message). | 235 // Returns true on success and false on error (e.g., invalid control message). |
237 // This is only called on the I/O thread. | 236 // This is only called on the I/O thread. |
238 virtual bool OnReadMessageForRawChannel( | 237 virtual bool OnReadMessageForRawChannel( |
239 const MessageInTransit::View& message_view); | 238 const MessageInTransit::View& message_view); |
(...skipping 90 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
330 base::WeakPtrFactory<RawChannel> weak_ptr_factory_ | 329 base::WeakPtrFactory<RawChannel> weak_ptr_factory_ |
331 MOJO_GUARDED_BY(write_mutex_); | 330 MOJO_GUARDED_BY(write_mutex_); |
332 | 331 |
333 MOJO_DISALLOW_COPY_AND_ASSIGN(RawChannel); | 332 MOJO_DISALLOW_COPY_AND_ASSIGN(RawChannel); |
334 }; | 333 }; |
335 | 334 |
336 } // namespace system | 335 } // namespace system |
337 } // namespace mojo | 336 } // namespace mojo |
338 | 337 |
339 #endif // MOJO_EDK_SYSTEM_RAW_CHANNEL_H_ | 338 #endif // MOJO_EDK_SYSTEM_RAW_CHANNEL_H_ |
OLD | NEW |