| 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/weak_ptr.h" | 11 #include "base/memory/weak_ptr.h" |
| 12 #include "mojo/edk/embedder/platform_handle_vector.h" | |
| 13 #include "mojo/edk/embedder/scoped_platform_handle.h" | 12 #include "mojo/edk/embedder/scoped_platform_handle.h" |
| 14 #include "mojo/edk/system/message_in_transit.h" | 13 #include "mojo/edk/system/message_in_transit.h" |
| 15 #include "mojo/edk/system/message_in_transit_queue.h" | 14 #include "mojo/edk/system/message_in_transit_queue.h" |
| 16 #include "mojo/edk/util/mutex.h" | 15 #include "mojo/edk/util/mutex.h" |
| 17 #include "mojo/edk/util/thread_annotations.h" | 16 #include "mojo/edk/util/thread_annotations.h" |
| 18 #include "mojo/public/cpp/system/macros.h" | 17 #include "mojo/public/cpp/system/macros.h" |
| 19 | 18 |
| 20 namespace base { | 19 namespace base { |
| 21 class MessageLoopForIO; | 20 class MessageLoopForIO; |
| 22 } | 21 } |
| (...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 60 // Unknown read error. | 59 // Unknown read error. |
| 61 ERROR_READ_UNKNOWN, | 60 ERROR_READ_UNKNOWN, |
| 62 // Generic write error. | 61 // Generic write error. |
| 63 ERROR_WRITE | 62 ERROR_WRITE |
| 64 }; | 63 }; |
| 65 | 64 |
| 66 // Called when a message is read. This may call the |RawChannel|'s | 65 // Called when a message is read. This may call the |RawChannel|'s |
| 67 // |Shutdown()| and then (if desired) destroy it. | 66 // |Shutdown()| and then (if desired) destroy it. |
| 68 virtual void OnReadMessage( | 67 virtual void OnReadMessage( |
| 69 const MessageInTransit::View& message_view, | 68 const MessageInTransit::View& message_view, |
| 70 embedder::ScopedPlatformHandleVectorPtr platform_handles) = 0; | 69 std::unique_ptr<std::vector<embedder::ScopedPlatformHandle>> |
| 70 platform_handles) = 0; |
| 71 | 71 |
| 72 // Called when there's a (fatal) error. This may call the |RawChannel|'s | 72 // Called when there's a (fatal) error. This may call the |RawChannel|'s |
| 73 // |Shutdown()| and then (if desired) destroy it. | 73 // |Shutdown()| and then (if desired) destroy it. |
| 74 // | 74 // |
| 75 // For each raw channel, there'll be at most one |ERROR_READ_...| and at | 75 // For each raw channel, there'll be at most one |ERROR_READ_...| and at |
| 76 // most one |ERROR_WRITE| notification. After |OnError(ERROR_READ_...)|, | 76 // most one |ERROR_WRITE| notification. After |OnError(ERROR_READ_...)|, |
| 77 // |OnReadMessage()| won't be called again. | 77 // |OnReadMessage()| won't be called again. |
| 78 virtual void OnError(Error error) = 0; | 78 virtual void OnError(Error error) = 0; |
| 79 | 79 |
| 80 protected: | 80 protected: |
| (...skipping 173 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 254 // Similar to |Read()|, except that the implementing subclass must also | 254 // Similar to |Read()|, except that the implementing subclass must also |
| 255 // guarantee that the method doesn't succeed synchronously, i.e., it only | 255 // guarantee that the method doesn't succeed synchronously, i.e., it only |
| 256 // returns |IO_FAILED_...| or |IO_PENDING|. | 256 // returns |IO_FAILED_...| or |IO_PENDING|. |
| 257 virtual IOResult ScheduleRead() MOJO_LOCKS_EXCLUDED(write_mutex_) = 0; | 257 virtual IOResult ScheduleRead() MOJO_LOCKS_EXCLUDED(write_mutex_) = 0; |
| 258 | 258 |
| 259 // Called by |OnReadCompleted()| to get the platform handles associated with | 259 // Called by |OnReadCompleted()| to get the platform handles associated with |
| 260 // the given platform handle table (from a message). This should only be | 260 // the given platform handle table (from a message). This should only be |
| 261 // called when |num_platform_handles| is nonzero. Returns null if the | 261 // called when |num_platform_handles| is nonzero. Returns null if the |
| 262 // |num_platform_handles| handles are not available. Only called on the I/O | 262 // |num_platform_handles| handles are not available. Only called on the I/O |
| 263 // thread. | 263 // thread. |
| 264 virtual embedder::ScopedPlatformHandleVectorPtr GetReadPlatformHandles( | 264 virtual std::unique_ptr<std::vector<embedder::ScopedPlatformHandle>> |
| 265 size_t num_platform_handles, | 265 GetReadPlatformHandles(size_t num_platform_handles, |
| 266 const void* platform_handle_table) MOJO_LOCKS_EXCLUDED(write_mutex_) = 0; | 266 const void* platform_handle_table) |
| 267 MOJO_LOCKS_EXCLUDED(write_mutex_) = 0; |
| 267 | 268 |
| 268 // Writes contents in |write_buffer_no_lock()|. | 269 // Writes contents in |write_buffer_no_lock()|. |
| 269 // This class guarantees that: | 270 // This class guarantees that: |
| 270 // - the |PlatformHandle|s given by |GetPlatformHandlesToSend()| and the | 271 // - the |PlatformHandle|s given by |GetPlatformHandlesToSend()| and the |
| 271 // buffer(s) given by |GetBuffers()| will remain valid until write | 272 // buffer(s) given by |GetBuffers()| will remain valid until write |
| 272 // completion (see also the comments for |OnShutdownNoLock()|); | 273 // completion (see also the comments for |OnShutdownNoLock()|); |
| 273 // - a second write is not started if there is a pending write. | 274 // - a second write is not started if there is a pending write. |
| 274 // | 275 // |
| 275 // The implementing subclass must guarantee that: | 276 // The implementing subclass must guarantee that: |
| 276 // - |platform_handles_written| and |bytes_written| are untouched unless | 277 // - |platform_handles_written| and |bytes_written| are untouched unless |
| (...skipping 53 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 330 base::WeakPtrFactory<RawChannel> weak_ptr_factory_ | 331 base::WeakPtrFactory<RawChannel> weak_ptr_factory_ |
| 331 MOJO_GUARDED_BY(write_mutex_); | 332 MOJO_GUARDED_BY(write_mutex_); |
| 332 | 333 |
| 333 MOJO_DISALLOW_COPY_AND_ASSIGN(RawChannel); | 334 MOJO_DISALLOW_COPY_AND_ASSIGN(RawChannel); |
| 334 }; | 335 }; |
| 335 | 336 |
| 336 } // namespace system | 337 } // namespace system |
| 337 } // namespace mojo | 338 } // namespace mojo |
| 338 | 339 |
| 339 #endif // MOJO_EDK_SYSTEM_RAW_CHANNEL_H_ | 340 #endif // MOJO_EDK_SYSTEM_RAW_CHANNEL_H_ |
| OLD | NEW |