OLD | NEW |
1 // Copyright 2015 The Chromium Authors. All rights reserved. | 1 // Copyright 2015 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/public/cpp/bindings/interface_endpoint_client.h" | 5 #include "mojo/public/cpp/bindings/interface_endpoint_client.h" |
6 | 6 |
7 #include <stdint.h> | 7 #include <stdint.h> |
8 | 8 |
9 #include <utility> | 9 #include <utility> |
10 | 10 |
(...skipping 263 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
274 if (encountered_error_) | 274 if (encountered_error_) |
275 return; | 275 return; |
276 encountered_error_ = true; | 276 encountered_error_ = true; |
277 | 277 |
278 // The callbacks may hold on to resources. There is no need to keep them any | 278 // The callbacks may hold on to resources. There is no need to keep them any |
279 // longer. | 279 // longer. |
280 async_responders_.clear(); | 280 async_responders_.clear(); |
281 | 281 |
282 control_message_proxy_.OnConnectionError(); | 282 control_message_proxy_.OnConnectionError(); |
283 | 283 |
284 if (!error_handler_.is_null()) | 284 if (!error_handler_.is_null()) { |
285 error_handler_.Run(); | 285 error_handler_.Run(); |
| 286 } else if (!error_with_reason_handler_.is_null()) { |
| 287 // Make a copy on the stack. If we directly pass a reference to a member of |
| 288 // |control_message_handler_|, that reference will be invalidated as soon as |
| 289 // the user destroys the interface endpoint. |
| 290 std::string description = control_message_handler_.disconnect_description(); |
| 291 error_with_reason_handler_.Run( |
| 292 control_message_handler_.disconnect_custom_reason(), description); |
| 293 } |
286 } | 294 } |
287 | 295 |
288 bool InterfaceEndpointClient::HandleValidatedMessage(Message* message) { | 296 bool InterfaceEndpointClient::HandleValidatedMessage(Message* message) { |
289 DCHECK_EQ(handle_.id(), message->interface_id()); | 297 DCHECK_EQ(handle_.id(), message->interface_id()); |
290 DCHECK(!encountered_error_); | 298 DCHECK(!encountered_error_); |
291 | 299 |
292 if (message->has_flag(Message::kFlagExpectsResponse)) { | 300 if (message->has_flag(Message::kFlagExpectsResponse)) { |
293 MessageReceiverWithStatus* responder = | 301 MessageReceiverWithStatus* responder = |
294 new ResponderThunk(weak_ptr_factory_.GetWeakPtr(), task_runner_); | 302 new ResponderThunk(weak_ptr_factory_.GetWeakPtr(), task_runner_); |
295 bool ok = false; | 303 bool ok = false; |
(...skipping 25 matching lines...) Expand all Loading... |
321 return responder->Accept(message); | 329 return responder->Accept(message); |
322 } else { | 330 } else { |
323 if (mojo::internal::ControlMessageHandler::IsControlMessage(message)) | 331 if (mojo::internal::ControlMessageHandler::IsControlMessage(message)) |
324 return control_message_handler_.Accept(message); | 332 return control_message_handler_.Accept(message); |
325 | 333 |
326 return incoming_receiver_->Accept(message); | 334 return incoming_receiver_->Accept(message); |
327 } | 335 } |
328 } | 336 } |
329 | 337 |
330 } // namespace mojo | 338 } // namespace mojo |
OLD | NEW |