OLD | NEW |
1 // Copyright 2014 The Chromium Authors. All rights reserved. | 1 // Copyright 2014 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 library http_server_mojom; | 5 library http_server_mojom; |
6 import 'dart:async'; | 6 import 'dart:async'; |
7 import 'package:mojo/bindings.dart' as bindings; | 7 import 'package:mojo/bindings.dart' as bindings; |
8 import 'package:mojo/core.dart' as core; | 8 import 'package:mojo/core.dart' as core; |
9 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; | 9 import 'package:mojo/mojo/bindings/types/service_describer.mojom.dart' as servic
e_describer; |
10 import 'package:mojo_services/mojo/http_connection.mojom.dart' as http_connectio
n_mojom; | 10 import 'package:mojo_services/mojo/http_connection.mojom.dart' as http_connectio
n_mojom; |
(...skipping 94 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
105 | 105 |
106 dynamic getAllTypeDefinitions([Function responseFactory]) => | 106 dynamic getAllTypeDefinitions([Function responseFactory]) => |
107 responseFactory(null); | 107 responseFactory(null); |
108 } | 108 } |
109 | 109 |
110 abstract class HttpServerDelegate { | 110 abstract class HttpServerDelegate { |
111 static const String serviceName = null; | 111 static const String serviceName = null; |
112 void onConnected(Object connection, Object delegate); | 112 void onConnected(Object connection, Object delegate); |
113 } | 113 } |
114 | 114 |
115 | 115 class _HttpServerDelegateProxyControl |
116 class _HttpServerDelegateProxyControl extends bindings.ProxyMessageHandler | 116 extends bindings.ProxyMessageHandler |
117 implements bindings.ProxyControl { | 117 implements bindings.ProxyControl { |
118 _HttpServerDelegateProxyControl.fromEndpoint( | 118 _HttpServerDelegateProxyControl.fromEndpoint( |
119 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); | 119 core.MojoMessagePipeEndpoint endpoint) : super.fromEndpoint(endpoint); |
120 | 120 |
121 _HttpServerDelegateProxyControl.fromHandle( | 121 _HttpServerDelegateProxyControl.fromHandle( |
122 core.MojoHandle handle) : super.fromHandle(handle); | 122 core.MojoHandle handle) : super.fromHandle(handle); |
123 | 123 |
124 _HttpServerDelegateProxyControl.unbound() : super.unbound(); | 124 _HttpServerDelegateProxyControl.unbound() : super.unbound(); |
125 | 125 |
126 service_describer.ServiceDescription get serviceDescription => | 126 service_describer.ServiceDescription get serviceDescription => |
127 new _HttpServerDelegateServiceDescription(); | 127 new _HttpServerDelegateServiceDescription(); |
128 | 128 |
129 String get serviceName => HttpServerDelegate.serviceName; | 129 String get serviceName => HttpServerDelegate.serviceName; |
130 | 130 |
131 @override | |
132 void handleResponse(bindings.ServiceMessage message) { | 131 void handleResponse(bindings.ServiceMessage message) { |
133 switch (message.header.type) { | 132 switch (message.header.type) { |
134 default: | 133 default: |
135 proxyError("Unexpected message type: ${message.header.type}"); | 134 proxyError("Unexpected message type: ${message.header.type}"); |
136 close(immediate: true); | 135 close(immediate: true); |
137 break; | 136 break; |
138 } | 137 } |
139 } | 138 } |
140 | 139 |
141 @override | 140 @override |
142 String toString() { | 141 String toString() { |
143 var superString = super.toString(); | 142 var superString = super.toString(); |
144 return "_HttpServerDelegateProxyControl($superString)"; | 143 return "_HttpServerDelegateProxyControl($superString)"; |
145 } | 144 } |
146 } | 145 } |
147 | 146 |
148 | 147 class HttpServerDelegateProxy |
149 class HttpServerDelegateProxy extends bindings.Proxy | 148 extends bindings.Proxy |
150 implements HttpServerDelegate { | 149 implements HttpServerDelegate { |
151 HttpServerDelegateProxy.fromEndpoint( | 150 HttpServerDelegateProxy.fromEndpoint( |
152 core.MojoMessagePipeEndpoint endpoint) | 151 core.MojoMessagePipeEndpoint endpoint) |
153 : super(new _HttpServerDelegateProxyControl.fromEndpoint(endpoint)); | 152 : super(new _HttpServerDelegateProxyControl.fromEndpoint(endpoint)); |
154 | 153 |
155 HttpServerDelegateProxy.fromHandle(core.MojoHandle handle) | 154 HttpServerDelegateProxy.fromHandle(core.MojoHandle handle) |
156 : super(new _HttpServerDelegateProxyControl.fromHandle(handle)); | 155 : super(new _HttpServerDelegateProxyControl.fromHandle(handle)); |
157 | 156 |
158 HttpServerDelegateProxy.unbound() | 157 HttpServerDelegateProxy.unbound() |
159 : super(new _HttpServerDelegateProxyControl.unbound()); | 158 : super(new _HttpServerDelegateProxyControl.unbound()); |
160 | 159 |
(...skipping 17 matching lines...) Expand all Loading... |
178 return; | 177 return; |
179 } | 178 } |
180 var params = new _HttpServerDelegateOnConnectedParams(); | 179 var params = new _HttpServerDelegateOnConnectedParams(); |
181 params.connection = connection; | 180 params.connection = connection; |
182 params.delegate = delegate; | 181 params.delegate = delegate; |
183 ctrl.sendMessage(params, | 182 ctrl.sendMessage(params, |
184 _httpServerDelegateMethodOnConnectedName); | 183 _httpServerDelegateMethodOnConnectedName); |
185 } | 184 } |
186 } | 185 } |
187 | 186 |
188 | 187 class _HttpServerDelegateStubControl |
189 class HttpServerDelegateStub extends bindings.Stub { | 188 extends bindings.StubMessageHandler |
| 189 implements bindings.StubControl<HttpServerDelegate> { |
190 HttpServerDelegate _impl; | 190 HttpServerDelegate _impl; |
191 | 191 |
192 HttpServerDelegateStub.fromEndpoint( | 192 _HttpServerDelegateStubControl.fromEndpoint( |
193 core.MojoMessagePipeEndpoint endpoint, [HttpServerDelegate impl]) | 193 core.MojoMessagePipeEndpoint endpoint, [HttpServerDelegate impl]) |
194 : super.fromEndpoint(endpoint, autoBegin: impl != null) { | 194 : super.fromEndpoint(endpoint, autoBegin: impl != null) { |
195 _impl = impl; | 195 _impl = impl; |
196 } | 196 } |
197 | 197 |
198 HttpServerDelegateStub.fromHandle( | 198 _HttpServerDelegateStubControl.fromHandle( |
199 core.MojoHandle handle, [HttpServerDelegate impl]) | 199 core.MojoHandle handle, [HttpServerDelegate impl]) |
200 : super.fromHandle(handle, autoBegin: impl != null) { | 200 : super.fromHandle(handle, autoBegin: impl != null) { |
201 _impl = impl; | 201 _impl = impl; |
202 } | 202 } |
203 | 203 |
204 HttpServerDelegateStub.unbound([this._impl]) : super.unbound(); | 204 _HttpServerDelegateStubControl.unbound([this._impl]) : super.unbound(); |
205 | |
206 static HttpServerDelegateStub newFromEndpoint( | |
207 core.MojoMessagePipeEndpoint endpoint) { | |
208 assert(endpoint.setDescription("For HttpServerDelegateStub")); | |
209 return new HttpServerDelegateStub.fromEndpoint(endpoint); | |
210 } | |
211 | 205 |
212 | 206 |
213 | 207 |
214 dynamic handleMessage(bindings.ServiceMessage message) { | 208 dynamic handleMessage(bindings.ServiceMessage message) { |
215 if (bindings.ControlMessageHandler.isControlMessage(message)) { | 209 if (bindings.ControlMessageHandler.isControlMessage(message)) { |
216 return bindings.ControlMessageHandler.handleMessage(this, | 210 return bindings.ControlMessageHandler.handleMessage(this, |
217 0, | 211 0, |
218 message); | 212 message); |
219 } | 213 } |
220 if (_impl == null) { | 214 if (_impl == null) { |
(...skipping 24 matching lines...) Expand all Loading... |
245 } | 239 } |
246 | 240 |
247 @override | 241 @override |
248 void bind(core.MojoMessagePipeEndpoint endpoint) { | 242 void bind(core.MojoMessagePipeEndpoint endpoint) { |
249 super.bind(endpoint); | 243 super.bind(endpoint); |
250 if (!isOpen && (_impl != null)) { | 244 if (!isOpen && (_impl != null)) { |
251 beginHandlingEvents(); | 245 beginHandlingEvents(); |
252 } | 246 } |
253 } | 247 } |
254 | 248 |
| 249 @override |
255 String toString() { | 250 String toString() { |
256 var superString = super.toString(); | 251 var superString = super.toString(); |
257 return "HttpServerDelegateStub($superString)"; | 252 return "_HttpServerDelegateStubControl($superString)"; |
258 } | 253 } |
259 | 254 |
260 int get version => 0; | 255 int get version => 0; |
261 | 256 |
262 static service_describer.ServiceDescription _cachedServiceDescription; | 257 static service_describer.ServiceDescription _cachedServiceDescription; |
263 static service_describer.ServiceDescription get serviceDescription { | 258 static service_describer.ServiceDescription get serviceDescription { |
264 if (_cachedServiceDescription == null) { | 259 if (_cachedServiceDescription == null) { |
265 _cachedServiceDescription = new _HttpServerDelegateServiceDescription(); | 260 _cachedServiceDescription = new _HttpServerDelegateServiceDescription(); |
266 } | 261 } |
267 return _cachedServiceDescription; | 262 return _cachedServiceDescription; |
268 } | 263 } |
269 } | 264 } |
270 | 265 |
| 266 class HttpServerDelegateStub |
| 267 extends bindings.Stub<HttpServerDelegate> |
| 268 implements HttpServerDelegate { |
| 269 HttpServerDelegateStub.fromEndpoint( |
| 270 core.MojoMessagePipeEndpoint endpoint, [HttpServerDelegate impl]) |
| 271 : super(new _HttpServerDelegateStubControl.fromEndpoint(endpoint, impl)); |
| 272 |
| 273 HttpServerDelegateStub.fromHandle( |
| 274 core.MojoHandle handle, [HttpServerDelegate impl]) |
| 275 : super(new _HttpServerDelegateStubControl.fromHandle(handle, impl)); |
| 276 |
| 277 HttpServerDelegateStub.unbound([HttpServerDelegate impl]) |
| 278 : super(new _HttpServerDelegateStubControl.unbound(impl)); |
| 279 |
| 280 static HttpServerDelegateStub newFromEndpoint( |
| 281 core.MojoMessagePipeEndpoint endpoint) { |
| 282 assert(endpoint.setDescription("For HttpServerDelegateStub")); |
| 283 return new HttpServerDelegateStub.fromEndpoint(endpoint); |
| 284 } |
| 285 |
| 286 static service_describer.ServiceDescription get serviceDescription => |
| 287 _HttpServerDelegateStubControl.serviceDescription; |
| 288 |
| 289 |
| 290 void onConnected(Object connection, Object delegate) { |
| 291 return impl.onConnected(connection, delegate); |
| 292 } |
| 293 } |
| 294 |
271 | 295 |
272 | 296 |
OLD | NEW |