| OLD | NEW |
| 1 {%- import "interface_macros.tmpl" as interface_macros %} | 1 {%- import "interface_macros.tmpl" as interface_macros %} |
| 2 {%- set class_name = interface.name %} | 2 {%- set class_name = interface.name %} |
| 3 {%- set proxy_name = interface.name ~ "Proxy" %} | 3 {%- set proxy_name = interface.name ~ "Proxy" %} |
| 4 {%- set namespace_as_string = "%s"|format(namespace|replace(".","::")) %} | 4 {%- set namespace_as_string = "%s"|format(namespace|replace(".","::")) %} |
| 5 | 5 |
| 6 {%- macro alloc_params(parameters) %} | 6 {%- macro alloc_params(parameters) %} |
| 7 {%- for param in parameters %} | 7 {%- for param in parameters %} |
| 8 {%- if param.kind|is_object_kind %} | 8 {%- if param.kind|is_object_kind %} |
| 9 {{param.kind|cpp_result_type}} p{{loop.index}}; | 9 {{param.kind|cpp_result_type}} p{{loop.index}}; |
| 10 Deserialize_(params->{{param.name}}.ptr, &p{{loop.index}}); | 10 Deserialize_(params->{{param.name}}.ptr, &p{{loop.index}}); |
| (...skipping 26 matching lines...) Expand all Loading... |
| 37 size_t payload_size = | 37 size_t payload_size = |
| 38 mojo::internal::Align(sizeof({{params_name}})); | 38 mojo::internal::Align(sizeof({{params_name}})); |
| 39 {#--- Computes #} | 39 {#--- Computes #} |
| 40 {%- for param in parameters %} | 40 {%- for param in parameters %} |
| 41 {%- if param.kind|is_object_kind %} | 41 {%- if param.kind|is_object_kind %} |
| 42 payload_size += GetSerializedSize_(in_{{param.name}}); | 42 payload_size += GetSerializedSize_(in_{{param.name}}); |
| 43 {%- endif %} | 43 {%- endif %} |
| 44 {%- endfor %} | 44 {%- endfor %} |
| 45 {%- endmacro %} | 45 {%- endmacro %} |
| 46 | 46 |
| 47 {%- macro build_message(params_name, parameters) -%} | 47 {%- macro build_message(params_name, parameters, params_description) -%} |
| 48 {# TODO(yzshen): Consider refactoring to share code with | 48 {# TODO(yzshen): Consider refactoring to share code with |
| 49 struct_serialization_definition.tmpl #} | 49 struct_serialization_definition.tmpl #} |
| 50 {{params_name}}* params = | 50 {{params_name}}* params = |
| 51 {{params_name}}::New(builder.buffer()); | 51 {{params_name}}::New(builder.buffer()); |
| 52 {#--- Sets #} | 52 {#--- Sets #} |
| 53 {% for param in parameters %} | 53 {% for param in parameters %} |
| 54 {%- if param.kind|is_object_kind %} | 54 {%- if param.kind|is_object_kind %} |
| 55 {%- if param.kind|is_any_array_kind %} | 55 {%- if param.kind|is_any_array_kind %} |
| 56 mojo::SerializeArray_<{{param.kind|get_array_validate_params|indent(24)}}>( | 56 mojo::SerializeArray_<{{param.kind|get_array_validate_params|indent(24)}}>( |
| 57 mojo::internal::Forward(in_{{param.name}}), builder.buffer(), ¶ms->{{p
aram.name}}.ptr); | 57 mojo::internal::Forward(in_{{param.name}}), builder.buffer(), ¶ms->{{p
aram.name}}.ptr); |
| 58 {%- else %} | 58 {%- else %} |
| 59 Serialize_(mojo::internal::Forward(in_{{param.name}}), builder.buffer(), ¶
ms->{{param.name}}.ptr); | 59 Serialize_(mojo::internal::Forward(in_{{param.name}}), builder.buffer(), ¶
ms->{{param.name}}.ptr); |
| 60 {%- endif %} | 60 {%- endif %} |
| 61 {%- if not param.kind|is_nullable_kind %} | 61 {%- if not param.kind|is_nullable_kind %} |
| 62 MOJO_INTERNAL_DLOG_SERIALIZATION_WARNING( | 62 MOJO_INTERNAL_DLOG_SERIALIZATION_WARNING( |
| 63 !params->{{param.name}}.ptr, | 63 !params->{{param.name}}.ptr, |
| 64 mojo::internal::VALIDATION_ERROR_UNEXPECTED_NULL_POINTER); | 64 mojo::internal::VALIDATION_ERROR_UNEXPECTED_NULL_POINTER, |
| 65 "null {{param.name}} argument in {{params_description}}"); |
| 65 {%- endif %} | 66 {%- endif %} |
| 66 {%- elif param.kind|is_any_handle_kind %} | 67 {%- elif param.kind|is_any_handle_kind %} |
| 67 {%- if param.kind|is_interface_kind or | 68 {%- if param.kind|is_interface_kind or |
| 68 param.kind|is_interface_request_kind %} | 69 param.kind|is_interface_request_kind %} |
| 69 // Delegate handle. | 70 // Delegate handle. |
| 70 params->{{param.name}} = in_{{param.name}}.PassMessagePipe().release(); | 71 params->{{param.name}} = in_{{param.name}}.PassMessagePipe().release(); |
| 71 {%- else %} | 72 {%- else %} |
| 72 params->{{param.name}} = in_{{param.name}}.release(); | 73 params->{{param.name}} = in_{{param.name}}.release(); |
| 73 {%- endif %} | 74 {%- endif %} |
| 74 {%- if not param.kind|is_nullable_kind %} | 75 {%- if not param.kind|is_nullable_kind %} |
| 75 MOJO_INTERNAL_DLOG_SERIALIZATION_WARNING( | 76 MOJO_INTERNAL_DLOG_SERIALIZATION_WARNING( |
| 76 !params->{{param.name}}.is_valid(), | 77 !params->{{param.name}}.is_valid(), |
| 77 mojo::internal::VALIDATION_ERROR_UNEXPECTED_INVALID_HANDLE); | 78 mojo::internal::VALIDATION_ERROR_UNEXPECTED_INVALID_HANDLE, |
| 79 "invalid {{param.name}} argument in {{params_description}}"); |
| 78 {%- endif %} | 80 {%- endif %} |
| 79 {%- else %} | 81 {%- else %} |
| 80 params->{{param.name}} = in_{{param.name}}; | 82 params->{{param.name}} = in_{{param.name}}; |
| 81 {%- endif %} | 83 {%- endif %} |
| 82 {%- endfor %} | 84 {%- endfor %} |
| 83 mojo::Message message; | 85 mojo::Message message; |
| 84 params->EncodePointersAndHandles(message.mutable_handles()); | 86 params->EncodePointersAndHandles(message.mutable_handles()); |
| 85 builder.Finish(&message); | 87 builder.Finish(&message); |
| 86 {%- endmacro %} | 88 {%- endmacro %} |
| 87 | 89 |
| (...skipping 37 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 125 : receiver_(receiver) { | 127 : receiver_(receiver) { |
| 126 } | 128 } |
| 127 | 129 |
| 128 {#--- Proxy definitions #} | 130 {#--- Proxy definitions #} |
| 129 | 131 |
| 130 {%- for method in interface.methods %} | 132 {%- for method in interface.methods %} |
| 131 {%- set message_name = | 133 {%- set message_name = |
| 132 "internal::k%s_%s_Name"|format(interface.name, method.name) %} | 134 "internal::k%s_%s_Name"|format(interface.name, method.name) %} |
| 133 {%- set params_name = | 135 {%- set params_name = |
| 134 "internal::%s_%s_Params_Data"|format(interface.name, method.name) %} | 136 "internal::%s_%s_Params_Data"|format(interface.name, method.name) %} |
| 137 {%- set params_description = |
| 138 "%s.%s request"|format(interface.name, method.name) %} |
| 135 void {{proxy_name}}::{{method.name}}( | 139 void {{proxy_name}}::{{method.name}}( |
| 136 {{interface_macros.declare_request_params("in_", method)}}) { | 140 {{interface_macros.declare_request_params("in_", method)}}) { |
| 137 {{compute_payload_size(params_name, method.parameters)}} | 141 {{compute_payload_size(params_name, method.parameters)}} |
| 138 | 142 |
| 139 {%- if method.response_parameters != None %} | 143 {%- if method.response_parameters != None %} |
| 140 mojo::internal::RequestMessageBuilder builder({{message_name}}, payload_size); | 144 mojo::internal::RequestMessageBuilder builder({{message_name}}, payload_size); |
| 141 {%- else %} | 145 {%- else %} |
| 142 mojo::internal::MessageBuilder builder({{message_name}}, payload_size); | 146 mojo::internal::MessageBuilder builder({{message_name}}, payload_size); |
| 143 {%- endif %} | 147 {%- endif %} |
| 144 | 148 |
| 145 {{build_message(params_name, method.parameters)}} | 149 {{build_message(params_name, method.parameters, params_description)}} |
| 146 | 150 |
| 147 {%- if method.response_parameters != None %} | 151 {%- if method.response_parameters != None %} |
| 148 mojo::MessageReceiver* responder = | 152 mojo::MessageReceiver* responder = |
| 149 new {{class_name}}_{{method.name}}_ForwardToCallback(callback); | 153 new {{class_name}}_{{method.name}}_ForwardToCallback(callback); |
| 150 if (!receiver_->AcceptWithResponder(&message, responder)) | 154 if (!receiver_->AcceptWithResponder(&message, responder)) |
| 151 delete responder; | 155 delete responder; |
| 152 {%- else %} | 156 {%- else %} |
| 153 bool ok MOJO_ALLOW_UNUSED = receiver_->Accept(&message); | 157 bool ok MOJO_ALLOW_UNUSED = receiver_->Accept(&message); |
| 154 // This return value may be ignored as !ok implies the Connector has | 158 // This return value may be ignored as !ok implies the Connector has |
| 155 // encountered an error, which will be visible through other means. | 159 // encountered an error, which will be visible through other means. |
| 156 {%- endif %} | 160 {%- endif %} |
| 157 } | 161 } |
| 158 {%- endfor %} | 162 {%- endfor %} |
| 159 | 163 |
| 160 {#--- ProxyToResponder definition #} | 164 {#--- ProxyToResponder definition #} |
| 161 {%- for method in interface.methods -%} | 165 {%- for method in interface.methods -%} |
| 162 {%- if method.response_parameters != None %} | 166 {%- if method.response_parameters != None %} |
| 163 {%- set message_name = | 167 {%- set message_name = |
| 164 "internal::k%s_%s_Name"|format(interface.name, method.name) %} | 168 "internal::k%s_%s_Name"|format(interface.name, method.name) %} |
| 165 {%- set params_name = | 169 {%- set params_name = |
| 166 "internal::%s_%s_ResponseParams_Data"|format(interface.name, method.
name) %} | 170 "internal::%s_%s_ResponseParams_Data"|format(interface.name, method.
name) %} |
| 171 {%- set params_description = |
| 172 "%s.%s response"|format(interface.name, method.name) %} |
| 167 class {{class_name}}_{{method.name}}_ProxyToResponder | 173 class {{class_name}}_{{method.name}}_ProxyToResponder |
| 168 : public {{interface_macros.declare_callback(method)}}::Runnable { | 174 : public {{interface_macros.declare_callback(method)}}::Runnable { |
| 169 public: | 175 public: |
| 170 virtual ~{{class_name}}_{{method.name}}_ProxyToResponder() { | 176 virtual ~{{class_name}}_{{method.name}}_ProxyToResponder() { |
| 171 delete responder_; | 177 delete responder_; |
| 172 } | 178 } |
| 173 | 179 |
| 174 {{class_name}}_{{method.name}}_ProxyToResponder( | 180 {{class_name}}_{{method.name}}_ProxyToResponder( |
| 175 uint64_t request_id, | 181 uint64_t request_id, |
| 176 mojo::MessageReceiver* responder) | 182 mojo::MessageReceiver* responder) |
| 177 : request_id_(request_id), | 183 : request_id_(request_id), |
| 178 responder_(responder) { | 184 responder_(responder) { |
| 179 } | 185 } |
| 180 | 186 |
| 181 virtual void Run({{interface_macros.declare_params("in_", method.response_para
meters)}}) const; | 187 virtual void Run({{interface_macros.declare_params("in_", method.response_para
meters)}}) const; |
| 182 | 188 |
| 183 private: | 189 private: |
| 184 uint64_t request_id_; | 190 uint64_t request_id_; |
| 185 mutable mojo::MessageReceiver* responder_; | 191 mutable mojo::MessageReceiver* responder_; |
| 186 MOJO_DISALLOW_COPY_AND_ASSIGN({{class_name}}_{{method.name}}_ProxyToResponder)
; | 192 MOJO_DISALLOW_COPY_AND_ASSIGN({{class_name}}_{{method.name}}_ProxyToResponder)
; |
| 187 }; | 193 }; |
| 188 void {{class_name}}_{{method.name}}_ProxyToResponder::Run( | 194 void {{class_name}}_{{method.name}}_ProxyToResponder::Run( |
| 189 {{interface_macros.declare_params("in_", method.response_parameters)}}) cons
t { | 195 {{interface_macros.declare_params("in_", method.response_parameters)}}) cons
t { |
| 190 {{compute_payload_size(params_name, method.response_parameters)}} | 196 {{compute_payload_size(params_name, method.response_parameters)}} |
| 191 mojo::internal::ResponseMessageBuilder builder( | 197 mojo::internal::ResponseMessageBuilder builder( |
| 192 {{message_name}}, payload_size, request_id_); | 198 {{message_name}}, payload_size, request_id_); |
| 193 {{build_message(params_name, method.response_parameters)}} | 199 {{build_message(params_name, method.response_parameters, params_description)}} |
| 194 bool ok MOJO_ALLOW_UNUSED = responder_->Accept(&message); | 200 bool ok MOJO_ALLOW_UNUSED = responder_->Accept(&message); |
| 195 // TODO(darin): !ok returned here indicates a malformed message, and that may | 201 // TODO(darin): !ok returned here indicates a malformed message, and that may |
| 196 // be good reason to close the connection. However, we don't have a way to do | 202 // be good reason to close the connection. However, we don't have a way to do |
| 197 // that from here. We should add a way. | 203 // that from here. We should add a way. |
| 198 delete responder_; | 204 delete responder_; |
| 199 responder_ = NULL; | 205 responder_ = NULL; |
| 200 } | 206 } |
| 201 {%- endif -%} | 207 {%- endif -%} |
| 202 {%- endfor %} | 208 {%- endfor %} |
| 203 | 209 |
| (...skipping 115 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 319 } | 325 } |
| 320 break; | 326 break; |
| 321 } | 327 } |
| 322 {%- endfor %} | 328 {%- endfor %} |
| 323 } | 329 } |
| 324 {%- endif %} | 330 {%- endif %} |
| 325 | 331 |
| 326 return sink_->Accept(message); | 332 return sink_->Accept(message); |
| 327 } | 333 } |
| 328 {%- endif -%} | 334 {%- endif -%} |
| OLD | NEW |