| 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 #include "mojo/edk/system/message_pipe_dispatcher.h" | 5 #include "mojo/edk/system/message_pipe_dispatcher.h" |
| 6 | 6 |
| 7 #include "base/logging.h" | 7 #include "base/logging.h" |
| 8 #include "mojo/edk/system/channel.h" | 8 #include "mojo/edk/system/channel.h" |
| 9 #include "mojo/edk/system/channel_endpoint.h" | 9 #include "mojo/edk/system/channel_endpoint.h" |
| 10 #include "mojo/edk/system/channel_endpoint_id.h" | 10 #include "mojo/edk/system/channel_endpoint_id.h" |
| (...skipping 164 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 175 MojoWriteMessageFlags flags) { | 175 MojoWriteMessageFlags flags) { |
| 176 DCHECK(!transports || | 176 DCHECK(!transports || |
| 177 (transports->size() > 0 && | 177 (transports->size() > 0 && |
| 178 transports->size() <= GetConfiguration().max_message_num_handles)); | 178 transports->size() <= GetConfiguration().max_message_num_handles)); |
| 179 | 179 |
| 180 lock().AssertAcquired(); | 180 lock().AssertAcquired(); |
| 181 | 181 |
| 182 if (num_bytes > GetConfiguration().max_message_num_bytes) | 182 if (num_bytes > GetConfiguration().max_message_num_bytes) |
| 183 return MOJO_RESULT_RESOURCE_EXHAUSTED; | 183 return MOJO_RESULT_RESOURCE_EXHAUSTED; |
| 184 | 184 |
| 185 return message_pipe_->WriteMessage( | 185 return message_pipe_->WriteMessage(port_, bytes, num_bytes, transports, |
| 186 port_, bytes, num_bytes, transports, flags); | 186 flags); |
| 187 } | 187 } |
| 188 | 188 |
| 189 MojoResult MessagePipeDispatcher::ReadMessageImplNoLock( | 189 MojoResult MessagePipeDispatcher::ReadMessageImplNoLock( |
| 190 UserPointer<void> bytes, | 190 UserPointer<void> bytes, |
| 191 UserPointer<uint32_t> num_bytes, | 191 UserPointer<uint32_t> num_bytes, |
| 192 DispatcherVector* dispatchers, | 192 DispatcherVector* dispatchers, |
| 193 uint32_t* num_dispatchers, | 193 uint32_t* num_dispatchers, |
| 194 MojoReadMessageFlags flags) { | 194 MojoReadMessageFlags flags) { |
| 195 lock().AssertAcquired(); | 195 lock().AssertAcquired(); |
| 196 return message_pipe_->ReadMessage( | 196 return message_pipe_->ReadMessage(port_, bytes, num_bytes, dispatchers, |
| 197 port_, bytes, num_bytes, dispatchers, num_dispatchers, flags); | 197 num_dispatchers, flags); |
| 198 } | 198 } |
| 199 | 199 |
| 200 HandleSignalsState MessagePipeDispatcher::GetHandleSignalsStateImplNoLock() | 200 HandleSignalsState MessagePipeDispatcher::GetHandleSignalsStateImplNoLock() |
| 201 const { | 201 const { |
| 202 lock().AssertAcquired(); | 202 lock().AssertAcquired(); |
| 203 return message_pipe_->GetHandleSignalsState(port_); | 203 return message_pipe_->GetHandleSignalsState(port_); |
| 204 } | 204 } |
| 205 | 205 |
| 206 MojoResult MessagePipeDispatcher::AddWaiterImplNoLock( | 206 MojoResult MessagePipeDispatcher::AddWaiterImplNoLock( |
| 207 Waiter* waiter, | 207 Waiter* waiter, |
| 208 MojoHandleSignals signals, | 208 MojoHandleSignals signals, |
| 209 uint32_t context, | 209 uint32_t context, |
| 210 HandleSignalsState* signals_state) { | 210 HandleSignalsState* signals_state) { |
| 211 lock().AssertAcquired(); | 211 lock().AssertAcquired(); |
| 212 return message_pipe_->AddWaiter( | 212 return message_pipe_->AddWaiter(port_, waiter, signals, context, |
| 213 port_, waiter, signals, context, signals_state); | 213 signals_state); |
| 214 } | 214 } |
| 215 | 215 |
| 216 void MessagePipeDispatcher::RemoveWaiterImplNoLock( | 216 void MessagePipeDispatcher::RemoveWaiterImplNoLock( |
| 217 Waiter* waiter, | 217 Waiter* waiter, |
| 218 HandleSignalsState* signals_state) { | 218 HandleSignalsState* signals_state) { |
| 219 lock().AssertAcquired(); | 219 lock().AssertAcquired(); |
| 220 message_pipe_->RemoveWaiter(port_, waiter, signals_state); | 220 message_pipe_->RemoveWaiter(port_, waiter, signals_state); |
| 221 } | 221 } |
| 222 | 222 |
| 223 void MessagePipeDispatcher::StartSerializeImplNoLock( | 223 void MessagePipeDispatcher::StartSerializeImplNoLock( |
| (...skipping 32 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 256 // MessagePipeDispatcherTransport ---------------------------------------------- | 256 // MessagePipeDispatcherTransport ---------------------------------------------- |
| 257 | 257 |
| 258 MessagePipeDispatcherTransport::MessagePipeDispatcherTransport( | 258 MessagePipeDispatcherTransport::MessagePipeDispatcherTransport( |
| 259 DispatcherTransport transport) | 259 DispatcherTransport transport) |
| 260 : DispatcherTransport(transport) { | 260 : DispatcherTransport(transport) { |
| 261 DCHECK_EQ(message_pipe_dispatcher()->GetType(), Dispatcher::kTypeMessagePipe); | 261 DCHECK_EQ(message_pipe_dispatcher()->GetType(), Dispatcher::kTypeMessagePipe); |
| 262 } | 262 } |
| 263 | 263 |
| 264 } // namespace system | 264 } // namespace system |
| 265 } // namespace mojo | 265 } // namespace mojo |
| OLD | NEW |