| 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 82 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 93 private: | 93 private: |
| 94 {{interface_macros.declare_callback(method)}} callback_; | 94 {{interface_macros.declare_callback(method)}} callback_; |
| 95 MOJO_DISALLOW_COPY_AND_ASSIGN({{class_name}}_{{method.name}}_ForwardToCallback
); | 95 MOJO_DISALLOW_COPY_AND_ASSIGN({{class_name}}_{{method.name}}_ForwardToCallback
); |
| 96 }; | 96 }; |
| 97 bool {{class_name}}_{{method.name}}_ForwardToCallback::Accept( | 97 bool {{class_name}}_{{method.name}}_ForwardToCallback::Accept( |
| 98 mojo::Message* message) { | 98 mojo::Message* message) { |
| 99 internal::{{class_name}}_{{method.name}}_ResponseParams_Data* params = | 99 internal::{{class_name}}_{{method.name}}_ResponseParams_Data* params = |
| 100 reinterpret_cast<internal::{{class_name}}_{{method.name}}_ResponseParams_D
ata*>( | 100 reinterpret_cast<internal::{{class_name}}_{{method.name}}_ResponseParams_D
ata*>( |
| 101 message->mutable_payload()); | 101 message->mutable_payload()); |
| 102 | 102 |
| 103 if (!params->DecodePointersAndHandles(message)) | 103 params->DecodePointersAndHandles(message->mutable_handles()); |
| 104 return false; | |
| 105 {{alloc_params(method.response_parameters)|indent(2)}} | 104 {{alloc_params(method.response_parameters)|indent(2)}} |
| 106 callback_.Run({{pass_params(method.response_parameters)}}); | 105 callback_.Run({{pass_params(method.response_parameters)}}); |
| 107 return true; | 106 return true; |
| 108 } | 107 } |
| 109 {%- endif %} | 108 {%- endif %} |
| 110 {%- endfor %} | 109 {%- endfor %} |
| 111 | 110 |
| 112 {{proxy_name}}::{{proxy_name}}(mojo::MessageReceiverWithResponder* receiver) | 111 {{proxy_name}}::{{proxy_name}}(mojo::MessageReceiverWithResponder* receiver) |
| 113 : receiver_(receiver) { | 112 : receiver_(receiver) { |
| 114 } | 113 } |
| (...skipping 83 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 198 bool {{class_name}}Stub::Accept(mojo::Message* message) { | 197 bool {{class_name}}Stub::Accept(mojo::Message* message) { |
| 199 {%- if interface.methods %} | 198 {%- if interface.methods %} |
| 200 switch (message->header()->name) { | 199 switch (message->header()->name) { |
| 201 {%- for method in interface.methods %} | 200 {%- for method in interface.methods %} |
| 202 case internal::k{{class_name}}_{{method.name}}_Name: { | 201 case internal::k{{class_name}}_{{method.name}}_Name: { |
| 203 {%- if method.response_parameters == None %} | 202 {%- if method.response_parameters == None %} |
| 204 internal::{{class_name}}_{{method.name}}_Params_Data* params = | 203 internal::{{class_name}}_{{method.name}}_Params_Data* params = |
| 205 reinterpret_cast<internal::{{class_name}}_{{method.name}}_Params_Data*
>( | 204 reinterpret_cast<internal::{{class_name}}_{{method.name}}_Params_Data*
>( |
| 206 message->mutable_payload()); | 205 message->mutable_payload()); |
| 207 | 206 |
| 208 if (!params->DecodePointersAndHandles(message)) | 207 params->DecodePointersAndHandles(message->mutable_handles()); |
| 209 return false; | |
| 210 {{alloc_params(method.parameters)|indent(6)}} | 208 {{alloc_params(method.parameters)|indent(6)}} |
| 211 sink_->{{method.name}}({{pass_params(method.parameters)}}); | 209 sink_->{{method.name}}({{pass_params(method.parameters)}}); |
| 212 return true; | 210 return true; |
| 213 {%- else %} | 211 {%- else %} |
| 214 break; | 212 break; |
| 215 {%- endif %} | 213 {%- endif %} |
| 216 } | 214 } |
| 217 {%- endfor %} | 215 {%- endfor %} |
| 218 } | 216 } |
| 219 {%- endif %} | 217 {%- endif %} |
| 220 return false; | 218 return false; |
| 221 } | 219 } |
| 222 | 220 |
| 223 bool {{class_name}}Stub::AcceptWithResponder( | 221 bool {{class_name}}Stub::AcceptWithResponder( |
| 224 mojo::Message* message, mojo::MessageReceiver* responder) { | 222 mojo::Message* message, mojo::MessageReceiver* responder) { |
| 225 {%- if interface.methods %} | 223 {%- if interface.methods %} |
| 226 switch (message->header()->name) { | 224 switch (message->header()->name) { |
| 227 {%- for method in interface.methods %} | 225 {%- for method in interface.methods %} |
| 228 case internal::k{{class_name}}_{{method.name}}_Name: { | 226 case internal::k{{class_name}}_{{method.name}}_Name: { |
| 229 {%- if method.response_parameters != None %} | 227 {%- if method.response_parameters != None %} |
| 230 internal::{{class_name}}_{{method.name}}_Params_Data* params = | 228 internal::{{class_name}}_{{method.name}}_Params_Data* params = |
| 231 reinterpret_cast<internal::{{class_name}}_{{method.name}}_Params_Data*
>( | 229 reinterpret_cast<internal::{{class_name}}_{{method.name}}_Params_Data*
>( |
| 232 message->mutable_payload()); | 230 message->mutable_payload()); |
| 233 | 231 |
| 234 if (!params->DecodePointersAndHandles(message)) | 232 params->DecodePointersAndHandles(message->mutable_handles()); |
| 235 return false; | |
| 236 {{interface_macros.declare_callback(method)}}::Runnable* runnable = | 233 {{interface_macros.declare_callback(method)}}::Runnable* runnable = |
| 237 new {{class_name}}_{{method.name}}_ProxyToResponder( | 234 new {{class_name}}_{{method.name}}_ProxyToResponder( |
| 238 message->request_id(), responder); | 235 message->request_id(), responder); |
| 239 {{interface_macros.declare_callback(method)}} callback(runnable); | 236 {{interface_macros.declare_callback(method)}} callback(runnable); |
| 240 {{alloc_params(method.parameters)|indent(6)}} | 237 {{alloc_params(method.parameters)|indent(6)}} |
| 241 sink_->{{method.name}}( | 238 sink_->{{method.name}}( |
| 242 {%- if method.parameters -%}{{pass_params(method.parameters)}}, {% endif -%}call
back); | 239 {%- if method.parameters -%}{{pass_params(method.parameters)}}, {% endif -%}call
back); |
| 243 return true; | 240 return true; |
| 244 {%- else %} | 241 {%- else %} |
| 245 break; | 242 break; |
| (...skipping 63 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
| 309 } | 306 } |
| 310 break; | 307 break; |
| 311 } | 308 } |
| 312 {%- endfor %} | 309 {%- endfor %} |
| 313 } | 310 } |
| 314 {%- endif %} | 311 {%- endif %} |
| 315 | 312 |
| 316 return sink_->Accept(message); | 313 return sink_->Accept(message); |
| 317 } | 314 } |
| 318 {%- endif -%} | 315 {%- endif -%} |
| OLD | NEW |