OLD | NEW |
1 {%- import "interface_macros.tmpl" as interface_macros %} | 1 {%- import "interface_macros.tmpl" as interface_macros %} |
2 {%- import "struct_macros.tmpl" as struct_macros %} | 2 {%- import "struct_macros.tmpl" as struct_macros %} |
3 | 3 |
4 {%- set class_name = interface.name %} | 4 {%- set class_name = interface.name %} |
5 {%- set proxy_name = interface.name ~ "Proxy" %} | 5 {%- set proxy_name = interface.name ~ "Proxy" %} |
6 {%- set namespace_as_string = "%s"|format(namespace|replace(".","::")) %} | 6 {%- set namespace_as_string = "%s"|format(namespace|replace(".","::")) %} |
7 | 7 |
8 {%- macro alloc_params(struct, params, message, serialization_context, | 8 {%- macro alloc_params(struct, params, message, serialization_context, |
9 description) %} | 9 description) %} |
10 ({{serialization_context}})->handles.Swap(({{message}})->mutable_handles()); | 10 ({{serialization_context}})->handles.Swap(({{message}})->mutable_handles()); |
(...skipping 247 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
258 "{{class_name}}::{{method.name}}() was never run."); | 258 "{{class_name}}::{{method.name}}() was never run."); |
259 } | 259 } |
260 #endif | 260 #endif |
261 // If the Callback was dropped then deleting the responder will close | 261 // If the Callback was dropped then deleting the responder will close |
262 // the pipe so the calling application knows to stop waiting for a reply. | 262 // the pipe so the calling application knows to stop waiting for a reply. |
263 delete responder_; | 263 delete responder_; |
264 } | 264 } |
265 | 265 |
266 void Run( | 266 void Run( |
267 {{interface_macros.declare_responder_params( | 267 {{interface_macros.declare_responder_params( |
268 "in_", method.response_parameters, for_blink)}}); | 268 "in_", method.response_parameters, for_blink, |
| 269 use_new_wrapper_types)}}); |
269 | 270 |
270 uint64_t request_id_; | 271 uint64_t request_id_; |
271 bool is_sync_; | 272 bool is_sync_; |
272 mojo::MessageReceiverWithStatus* responder_; | 273 mojo::MessageReceiverWithStatus* responder_; |
273 // TODO(yzshen): maybe I should use a ref to the original one? | 274 // TODO(yzshen): maybe I should use a ref to the original one? |
274 mojo::internal::SerializationContext serialization_context_; | 275 mojo::internal::SerializationContext serialization_context_; |
275 | 276 |
276 DISALLOW_COPY_AND_ASSIGN({{class_name}}_{{method.name}}_ProxyToResponder); | 277 DISALLOW_COPY_AND_ASSIGN({{class_name}}_{{method.name}}_ProxyToResponder); |
277 }; | 278 }; |
278 | 279 |
279 void {{class_name}}_{{method.name}}_ProxyToResponder::Run( | 280 void {{class_name}}_{{method.name}}_ProxyToResponder::Run( |
280 {{interface_macros.declare_responder_params( | 281 {{interface_macros.declare_responder_params( |
281 "in_", method.response_parameters, for_blink)}}) { | 282 "in_", method.response_parameters, for_blink, |
| 283 use_new_wrapper_types)}}) { |
282 {{struct_macros.get_serialized_size(response_params_struct, "in_%s", | 284 {{struct_macros.get_serialized_size(response_params_struct, "in_%s", |
283 "&serialization_context_")}} | 285 "&serialization_context_")}} |
284 mojo::internal::ResponseMessageBuilder builder( | 286 mojo::internal::ResponseMessageBuilder builder( |
285 {{message_name}}, size, request_id_, | 287 {{message_name}}, size, request_id_, |
286 is_sync_ ? mojo::Message::kFlagIsSync : 0); | 288 is_sync_ ? mojo::Message::kFlagIsSync : 0); |
287 {{build_message(response_params_struct, "in_%s", params_description, | 289 {{build_message(response_params_struct, "in_%s", params_description, |
288 "&serialization_context_")}} | 290 "&serialization_context_")}} |
289 bool ok = responder_->Accept(builder.message()); | 291 bool ok = responder_->Accept(builder.message()); |
290 ALLOW_UNUSED_LOCAL(ok); | 292 ALLOW_UNUSED_LOCAL(ok); |
291 // TODO(darin): !ok returned here indicates a malformed message, and that may | 293 // TODO(darin): !ok returned here indicates a malformed message, and that may |
(...skipping 170 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
462 break; | 464 break; |
463 } | 465 } |
464 | 466 |
465 // Unrecognized message. | 467 // Unrecognized message. |
466 ReportValidationError( | 468 ReportValidationError( |
467 &validation_context, | 469 &validation_context, |
468 mojo::internal::VALIDATION_ERROR_MESSAGE_HEADER_UNKNOWN_METHOD); | 470 mojo::internal::VALIDATION_ERROR_MESSAGE_HEADER_UNKNOWN_METHOD); |
469 return false; | 471 return false; |
470 } | 472 } |
471 {%- endif -%} | 473 {%- endif -%} |
OLD | NEW |