| 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 |