Chromium Code Reviews
chromiumcodereview-hr@appspot.gserviceaccount.com (chromiumcodereview-hr) | Please choose your nickname with Settings | Help | Chromium Project | Gerrit Changes | Sign out
(29)

Side by Side Diff: mojo/system/local_message_pipe_endpoint.cc

Issue 262093003: Mojo: Add/use |typedef std::vector<scoped_refptr<Dispatcher> > DispatcherVector. (Closed) Base URL: svn://svn.chromium.org/chrome/trunk/src
Patch Set: Created 6 years, 7 months ago
Use n/p to move between diff chunks; N/P to move between comments. Draft comments are only viewable by you.
Jump to:
View unified diff | Download patch | Annotate | Revision Log
« no previous file with comments | « mojo/system/local_message_pipe_endpoint.h ('k') | mojo/system/message_in_transit.h » ('j') | no next file with comments »
Toggle Intra-line Diffs ('i') | Expand Comments ('e') | Collapse Comments ('c') | Show Comments Hide Comments ('s')
OLDNEW
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 #include "mojo/system/local_message_pipe_endpoint.h" 5 #include "mojo/system/local_message_pipe_endpoint.h"
6 6
7 #include <string.h> 7 #include <string.h>
8 8
9 #include "base/logging.h" 9 #include "base/logging.h"
10 #include "mojo/system/dispatcher.h" 10 #include "mojo/system/dispatcher.h"
(...skipping 52 matching lines...) Expand 10 before | Expand all | Expand 10 after
63 DCHECK(is_open_); 63 DCHECK(is_open_);
64 is_open_ = false; 64 is_open_ = false;
65 message_queue_.Clear(); 65 message_queue_.Clear();
66 } 66 }
67 67
68 void LocalMessagePipeEndpoint::CancelAllWaiters() { 68 void LocalMessagePipeEndpoint::CancelAllWaiters() {
69 DCHECK(is_open_); 69 DCHECK(is_open_);
70 waiter_list_.CancelAllWaiters(); 70 waiter_list_.CancelAllWaiters();
71 } 71 }
72 72
73 MojoResult LocalMessagePipeEndpoint::ReadMessage( 73 MojoResult LocalMessagePipeEndpoint::ReadMessage(void* bytes,
74 void* bytes, uint32_t* num_bytes, 74 uint32_t* num_bytes,
75 std::vector<scoped_refptr<Dispatcher> >* dispatchers, 75 DispatcherVector* dispatchers,
76 uint32_t* num_dispatchers, 76 uint32_t* num_dispatchers,
77 MojoReadMessageFlags flags) { 77 MojoReadMessageFlags flags) {
78 DCHECK(is_open_); 78 DCHECK(is_open_);
79 DCHECK(!dispatchers || dispatchers->empty()); 79 DCHECK(!dispatchers || dispatchers->empty());
80 80
81 const uint32_t max_bytes = num_bytes ? *num_bytes : 0; 81 const uint32_t max_bytes = num_bytes ? *num_bytes : 0;
82 const uint32_t max_num_dispatchers = num_dispatchers ? *num_dispatchers : 0; 82 const uint32_t max_num_dispatchers = num_dispatchers ? *num_dispatchers : 0;
83 83
84 if (message_queue_.IsEmpty()) { 84 if (message_queue_.IsEmpty()) {
85 return is_peer_open_ ? MOJO_RESULT_SHOULD_WAIT : 85 return is_peer_open_ ? MOJO_RESULT_SHOULD_WAIT :
86 MOJO_RESULT_FAILED_PRECONDITION; 86 MOJO_RESULT_FAILED_PRECONDITION;
87 } 87 }
88 88
89 // TODO(vtl): If |flags & MOJO_READ_MESSAGE_FLAG_MAY_DISCARD|, we could pop 89 // TODO(vtl): If |flags & MOJO_READ_MESSAGE_FLAG_MAY_DISCARD|, we could pop
90 // and release the lock immediately. 90 // and release the lock immediately.
91 bool enough_space = true; 91 bool enough_space = true;
92 MessageInTransit* message = message_queue_.PeekMessage(); 92 MessageInTransit* message = message_queue_.PeekMessage();
93 if (num_bytes) 93 if (num_bytes)
94 *num_bytes = message->num_bytes(); 94 *num_bytes = message->num_bytes();
95 if (message->num_bytes() <= max_bytes) 95 if (message->num_bytes() <= max_bytes)
96 memcpy(bytes, message->bytes(), message->num_bytes()); 96 memcpy(bytes, message->bytes(), message->num_bytes());
97 else 97 else
98 enough_space = false; 98 enough_space = false;
99 99
100 if (std::vector<scoped_refptr<Dispatcher> >* queued_dispatchers = 100 if (DispatcherVector* queued_dispatchers = message->dispatchers()) {
101 message->dispatchers()) {
102 if (num_dispatchers) 101 if (num_dispatchers)
103 *num_dispatchers = static_cast<uint32_t>(queued_dispatchers->size()); 102 *num_dispatchers = static_cast<uint32_t>(queued_dispatchers->size());
104 if (enough_space) { 103 if (enough_space) {
105 if (queued_dispatchers->empty()) { 104 if (queued_dispatchers->empty()) {
106 // Nothing to do. 105 // Nothing to do.
107 } else if (queued_dispatchers->size() <= max_num_dispatchers) { 106 } else if (queued_dispatchers->size() <= max_num_dispatchers) {
108 DCHECK(dispatchers); 107 DCHECK(dispatchers);
109 dispatchers->swap(*queued_dispatchers); 108 dispatchers->swap(*queued_dispatchers);
110 } else { 109 } else {
111 enough_space = false; 110 enough_space = false;
(...skipping 56 matching lines...) Expand 10 before | Expand all | Expand 10 after
168 MojoWaitFlags satisfiable_flags = 0; 167 MojoWaitFlags satisfiable_flags = 0;
169 if (!message_queue_.IsEmpty() || is_peer_open_) 168 if (!message_queue_.IsEmpty() || is_peer_open_)
170 satisfiable_flags |= MOJO_WAIT_FLAG_READABLE; 169 satisfiable_flags |= MOJO_WAIT_FLAG_READABLE;
171 if (is_peer_open_) 170 if (is_peer_open_)
172 satisfiable_flags |= MOJO_WAIT_FLAG_WRITABLE; 171 satisfiable_flags |= MOJO_WAIT_FLAG_WRITABLE;
173 return satisfiable_flags; 172 return satisfiable_flags;
174 } 173 }
175 174
176 } // namespace system 175 } // namespace system
177 } // namespace mojo 176 } // namespace mojo
OLDNEW
« no previous file with comments | « mojo/system/local_message_pipe_endpoint.h ('k') | mojo/system/message_in_transit.h » ('j') | no next file with comments »

Powered by Google App Engine
This is Rietveld 408576698