| Index: third_party/mojo/src/mojo/public/tools/bindings/generators/go_templates/interface.tmpl
|
| diff --git a/third_party/mojo/src/mojo/public/tools/bindings/generators/go_templates/interface.tmpl b/third_party/mojo/src/mojo/public/tools/bindings/generators/go_templates/interface.tmpl
|
| deleted file mode 100644
|
| index 8fa02ee767f6193916ff10de483db8d94eb1b8b9..0000000000000000000000000000000000000000
|
| --- a/third_party/mojo/src/mojo/public/tools/bindings/generators/go_templates/interface.tmpl
|
| +++ /dev/null
|
| @@ -1,229 +0,0 @@
|
| -// Copyright 2015 The Chromium Authors. All rights reserved.
|
| -// Use of this source code is governed by a BSD-style license that can be
|
| -// found in the LICENSE file.
|
| -
|
| -{% import "struct.tmpl" as struct_macros %}
|
| -
|
| -{%- macro declare_params(struct) %}
|
| -{%- for field in struct.fields -%}
|
| - {{field|name(False)}} {{field.kind|go_type}}{% if not loop.last %}, {% endif %}
|
| -{%- endfor %}
|
| -{%- endmacro %}
|
| -
|
| -
|
| -
|
| -{% macro declare_request_params(method) %}
|
| -({{declare_params(method.param_struct)}})
|
| -{%- if method.response_parameters|is_none_or_empty -%}
|
| - {{' (err error)'}}
|
| -{%- else -%}
|
| - {{' '}}({{declare_params(method.response_param_struct)}}, err error)
|
| -{%- endif -%}
|
| -{% endmacro %}
|
| -
|
| -
|
| -
|
| -{%- macro flags(response_parameters, is_response) -%}
|
| -{%- if not response_parameters -%}
|
| - bindings.MessageNoFlag
|
| -{%- elif is_response: -%}
|
| - bindings.MessageIsResponseFlag
|
| -{%- else -%}
|
| - bindings.MessageExpectsResponseFlag
|
| -{%- endif -%}
|
| -{%- endmacro -%}
|
| -
|
| -
|
| -
|
| -{% macro define(interface) %}
|
| -type {{interface|name}} interface {
|
| -{% for method in interface.methods %}
|
| - {{method|name}}{{declare_request_params(method)}}
|
| -{% endfor %}
|
| -}
|
| -
|
| -var {{interface|name(False)}}_Name = "{{interface.module.namespace|replace(".","::")}}::{{interface.name}}"
|
| -
|
| -type {{interface|name}}_Request bindings.InterfaceRequest
|
| -
|
| -func (r *{{interface|name}}_Request) Name() string {
|
| - return {{interface|name(False)}}_Name
|
| -}
|
| -
|
| -type {{interface|name}}_Pointer bindings.InterfacePointer
|
| -
|
| -func (p *{{interface|name}}_Pointer) Name() string {
|
| - return {{interface|name(False)}}_Name
|
| -}
|
| -
|
| -type {{interface|name}}_ServiceFactory struct{
|
| - Delegate {{interface|name}}_Factory
|
| -}
|
| -
|
| -type {{interface|name}}_Factory interface {
|
| - Create(request {{interface|name}}_Request)
|
| -}
|
| -
|
| -func (f *{{interface|name}}_ServiceFactory) Name() string {
|
| - return {{interface|name(False)}}_Name
|
| -}
|
| -
|
| -func (f *{{interface|name}}_ServiceFactory) Create(messagePipe system.MessagePipeHandle) {
|
| - request := {{interface|name}}_Request{bindings.NewMessagePipeHandleOwner(messagePipe)}
|
| - f.Delegate.Create(request)
|
| -}
|
| -
|
| -// CreateMessagePipeFor{{interface|name}} creates a message pipe for use with the
|
| -// {{interface|name}} interface with a {{interface|name}}_Request on one end and a {{interface|name}}_Pointer on the other.
|
| -func CreateMessagePipeFor{{interface|name}}() ({{interface|name}}_Request, {{interface|name}}_Pointer) {
|
| - r, p := bindings.CreateMessagePipeForMojoInterface()
|
| - return {{interface|name}}_Request(r), {{interface|name}}_Pointer(p)
|
| -}
|
| -
|
| -{% for method in interface.methods %}
|
| -const {{interface|name(False)}}_{{method|name}}_Name uint32 = {{method.ordinal}}
|
| -{% endfor %}
|
| -
|
| -type {{interface|name}}_Proxy struct {
|
| - router *bindings.Router
|
| - ids bindings.Counter
|
| -}
|
| -
|
| -func New{{interface|name}}Proxy(p {{interface|name}}_Pointer, waiter bindings.AsyncWaiter) *{{interface|name}}_Proxy {
|
| - return &{{interface|name}}_Proxy{
|
| - bindings.NewRouter(p.PassMessagePipe(), waiter),
|
| - bindings.NewCounter(),
|
| - }
|
| -}
|
| -
|
| -func (p *{{interface|name}}_Proxy) Close_Proxy() {
|
| - p.router.Close()
|
| -}
|
| -
|
| -{% for method in interface.methods %}
|
| -{{struct_macros.define(method.param_struct, False)}}
|
| -{%- if method.response_parameters %}
|
| -{{struct_macros.define(method.response_param_struct, False)}}
|
| -{%- endif %}
|
| -func (p *{{interface|name}}_Proxy) {{method|name}}{{declare_request_params(method)}} {
|
| - payload := &{{method.param_struct|name(False)}}{
|
| -{% for field in (method.param_struct).fields %}
|
| - {{field|name(False)}},
|
| -{% endfor %}
|
| - }
|
| - header := bindings.MessageHeader{
|
| - Type: {{interface|name(False)}}_{{method|name}}_Name,
|
| - Flags: {{flags(method.response_parameters, False)}},
|
| -{% if method.response_parameters %}
|
| - RequestId: p.ids.Count(),
|
| -{% endif %}
|
| - }
|
| - var message *bindings.Message
|
| - if message, err = bindings.EncodeMessage(header, payload); err != nil {
|
| - err = fmt.Errorf("can't encode request: %v", err.Error())
|
| - p.Close_Proxy()
|
| - return
|
| - }
|
| -{% if method.response_parameters %}
|
| - readResult := <-p.router.AcceptWithResponse(message)
|
| - if err = readResult.Error; err != nil {
|
| - p.Close_Proxy()
|
| - return
|
| - }
|
| - if readResult.Message.Header.Flags != bindings.MessageIsResponseFlag {
|
| - err = &bindings.ValidationError{bindings.MessageHeaderInvalidFlags,
|
| - fmt.Sprintf("invalid message header flag: %v", readResult.Message.Header.Flags),
|
| - }
|
| - return
|
| - }
|
| - if got, want := readResult.Message.Header.Type, {{interface|name(False)}}_{{method|name}}_Name; got != want {
|
| - err = &bindings.ValidationError{bindings.MessageHeaderUnknownMethod,
|
| - fmt.Sprintf("invalid method in response: expected %v, got %v", want, got),
|
| - }
|
| - return
|
| - }
|
| - var response {{method.response_param_struct|name(False)}}
|
| - if err = readResult.Message.DecodePayload(&response); err != nil {
|
| - p.Close_Proxy()
|
| - return
|
| - }
|
| -{% for field in (method.response_param_struct).fields %}
|
| - {{field|name(False)}} = response.{{field|name(False)}}
|
| -{% endfor %}
|
| -{% else %}
|
| - if err = p.router.Accept(message); err != nil {
|
| - p.Close_Proxy()
|
| - return
|
| - }
|
| -{% endif %}
|
| - return
|
| -}
|
| -
|
| -{% endfor %}
|
| -type {{interface|name(False)}}_Stub struct {
|
| - connector *bindings.Connector
|
| - impl {{interface|name}}
|
| -}
|
| -
|
| -func New{{interface|name}}Stub(r {{interface|name}}_Request, impl {{interface|name}}, waiter bindings.AsyncWaiter) *bindings.Stub {
|
| - connector := bindings.NewConnector(r.PassMessagePipe(), waiter)
|
| - return bindings.NewStub(connector, &{{interface|name(False)}}_Stub{connector, impl})
|
| -}
|
| -
|
| -func (s *{{interface|name(False)}}_Stub) Accept(message *bindings.Message) (err error) {
|
| - switch message.Header.Type {
|
| -{% for method in interface.methods %}
|
| - case {{interface|name(False)}}_{{method|name}}_Name:
|
| -{% if method.response_parameters %}
|
| - if message.Header.Flags != bindings.MessageExpectsResponseFlag {
|
| -{% else %}
|
| - if message.Header.Flags != bindings.MessageNoFlag {
|
| -{% endif %}
|
| - return &bindings.ValidationError{bindings.MessageHeaderInvalidFlags,
|
| - fmt.Sprintf("invalid message header flag: %v", message.Header.Flags),
|
| - }
|
| - }
|
| - var request {{method.param_struct|name(False)}}
|
| - if err := message.DecodePayload(&request); err != nil {
|
| - return err
|
| - }
|
| -{% if method.response_parameters %}
|
| - var response {{method.response_param_struct|name(False)}}
|
| -{% endif %}
|
| -{% if method.response_parameters|is_none_or_empty %}
|
| - err = s.impl.{{method|name}}(
|
| -{%- else -%}
|
| -{% for field in (method.response_param_struct).fields %}
|
| - response.{{field|name(False)}}{{', '}}
|
| -{%- endfor -%}err = s.impl.{{method|name}}(
|
| -{%- endif -%}
|
| -{%- for field in (method.param_struct).fields -%}
|
| - request.{{field|name(False)}}{% if not loop.last %}, {% endif %}
|
| -{%- endfor -%}
|
| - )
|
| - if err != nil {
|
| - return
|
| - }
|
| -{% if method.response_parameters %}
|
| - header := bindings.MessageHeader{
|
| - Type: {{interface|name(False)}}_{{method|name}}_Name,
|
| - Flags: {{flags(method.response_parameters, True)}},
|
| - RequestId: message.Header.RequestId,
|
| - }
|
| - message, err = bindings.EncodeMessage(header, &response)
|
| - if err != nil {
|
| - return err
|
| - }
|
| - return s.connector.WriteMessage(message)
|
| -{% endif %}
|
| -{% endfor %}
|
| - default:
|
| - return &bindings.ValidationError{
|
| - bindings.MessageHeaderUnknownMethod,
|
| - fmt.Sprintf("unknown method %v", message.Header.Type),
|
| - }
|
| - }
|
| - return
|
| -}
|
| -
|
| -{% endmacro %}
|
|
|