OLD | NEW |
1 'use strict'; | 1 'use strict'; |
2 | 2 |
3 // Wraps callback and calls reject_func if callback throws an error. | 3 // Wraps callback and calls reject_func if callback throws an error. |
4 class CallbackWrapper { | 4 class CallbackWrapper { |
5 constructor(callback, reject_func) { | 5 constructor(callback, reject_func) { |
6 this.wrapper_func_ = (args) => { | 6 this.wrapper_func_ = (args) => { |
7 try { | 7 try { |
8 callback(args); | 8 callback(args); |
9 } catch(e) { | 9 } catch(e) { |
10 reject_func(); | 10 reject_func(); |
(...skipping 35 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
46 this.remove_configuration_called_ = null; | 46 this.remove_configuration_called_ = null; |
47 this.active_sensor_configurations_ = []; | 47 this.active_sensor_configurations_ = []; |
48 let rv = core.mapBuffer(handle, offset, size, | 48 let rv = core.mapBuffer(handle, offset, size, |
49 core.MAP_BUFFER_FLAG_NONE); | 49 core.MAP_BUFFER_FLAG_NONE); |
50 assert_equals(rv.result, core.RESULT_OK, "Failed to map shared buffer"); | 50 assert_equals(rv.result, core.RESULT_OK, "Failed to map shared buffer"); |
51 this.buffer_array_ = rv.buffer; | 51 this.buffer_array_ = rv.buffer; |
52 this.buffer_ = new Float64Array(this.buffer_array_); | 52 this.buffer_ = new Float64Array(this.buffer_array_); |
53 this.resetBuffer(); | 53 this.resetBuffer(); |
54 bindings.StubBindings(this.stub_).delegate = this; | 54 bindings.StubBindings(this.stub_).delegate = this; |
55 bindings.StubBindings(this.stub_).connectionErrorHandler = () => { | 55 bindings.StubBindings(this.stub_).connectionErrorHandler = () => { |
56 reset(); | 56 this.reset(); |
57 }; | 57 }; |
58 } | 58 } |
59 | 59 |
60 // Returns default configuration. | 60 // Returns default configuration. |
61 getDefaultConfiguration() { | 61 getDefaultConfiguration() { |
62 return Promise.resolve({frequency: 5}); | 62 return Promise.resolve({frequency: 5}); |
63 } | 63 } |
64 | 64 |
65 // Adds configuration for the sensor and starts reporting fake data | 65 // Adds configuration for the sensor and starts reporting fake data |
66 // through update_reading_function_ callback. | 66 // through update_reading_function_ callback. |
(...skipping 198 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
265 this.active_sensor_.client_ = proxy; | 265 this.active_sensor_.client_ = proxy; |
266 }, sensor.SensorClient); | 266 }, sensor.SensorClient); |
267 return getSensorResponse(init_params, client_handle); | 267 return getSensorResponse(init_params, client_handle); |
268 } | 268 } |
269 | 269 |
270 // Binds object to mojo message pipe | 270 // Binds object to mojo message pipe |
271 bindToPipe(pipe) { | 271 bindToPipe(pipe) { |
272 this.stub_ = connection.bindHandleToStub( | 272 this.stub_ = connection.bindHandleToStub( |
273 pipe, sensor_provider.SensorProvider); | 273 pipe, sensor_provider.SensorProvider); |
274 bindings.StubBindings(this.stub_).delegate = this; | 274 bindings.StubBindings(this.stub_).delegate = this; |
| 275 bindings.StubBindings(this.stub_).connectionErrorHandler = () => { |
| 276 this.reset(); |
| 277 }; |
275 } | 278 } |
276 | 279 |
277 // Mock functions | 280 // Mock functions |
278 | 281 |
279 // Resets state of mock SensorProvider between test runs. | 282 // Resets state of mock SensorProvider between test runs. |
280 reset() { | 283 reset() { |
281 if (this.active_sensor_ != null) { | 284 if (this.active_sensor_ != null) { |
282 this.active_sensor_.reset(); | 285 this.active_sensor_.reset(); |
283 this.active_sensor_ = null; | 286 this.active_sensor_ = null; |
284 } | 287 } |
285 | 288 |
286 this.get_sensor_should_fail_ = false; | 289 this.get_sensor_should_fail_ = false; |
287 this.resolve_func_ = null; | 290 this.resolve_func_ = null; |
288 this.max_frequency_ = 60; | 291 this.max_frequency_ = 60; |
| 292 if (this.stub_) |
| 293 bindings.StubBindings(this.stub_).close(); |
289 } | 294 } |
290 | 295 |
291 // Sets flag that forces mock SensorProvider to fail when getSensor() is | 296 // Sets flag that forces mock SensorProvider to fail when getSensor() is |
292 // invoked. | 297 // invoked. |
293 setGetSensorShouldFail(should_fail) { | 298 setGetSensorShouldFail(should_fail) { |
294 this.get_sensor_should_fail_ = should_fail; | 299 this.get_sensor_should_fail_ = should_fail; |
295 } | 300 } |
296 | 301 |
297 // Returns mock sensor that was created in getSensor to the layout test. | 302 // Returns mock sensor that was created in getSensor to the layout test. |
298 getCreatedSensor() { | 303 getCreatedSensor() { |
(...skipping 41 matching lines...) Expand 10 before | Expand all | Expand 10 after Loading... |
340 }; | 345 }; |
341 | 346 |
342 let onFailure = () => { | 347 let onFailure = () => { |
343 sensor.mockSensorProvider.reset(); | 348 sensor.mockSensorProvider.reset(); |
344 return new Promise((resolve, reject) => { setTimeout(reject, 0); }); | 349 return new Promise((resolve, reject) => { setTimeout(reject, 0); }); |
345 }; | 350 }; |
346 | 351 |
347 return Promise.resolve(func(sensor)).then(onSuccess, onFailure); | 352 return Promise.resolve(func(sensor)).then(onSuccess, onFailure); |
348 }), name, properties); | 353 }), name, properties); |
349 } | 354 } |
OLD | NEW |