import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
public void onServiceConnected(ComponentName className, IBinder service) {
    Log.i(TAG, "Bound to VehicleManager");
    // When the VehicleManager starts up, we store a reference to it
    // here in "mVehicleManager" so we can call functions on it
    // elsewhere in our code.
    mVehicleManager = ((VehicleManager.VehicleBinder) service)
            .getService();

    // We want to receive updates whenever the EngineSpeed changes. We
    // have an EngineSpeed.Listener (see above, mSpeedListener) and here
    // we request that the VehicleManager call its receive() method
    // whenever the EngineSpeed changes
    mVehicleManager.addListener(EngineSpeed.class, mSpeedListener);
    mVehicleManager.addListener(VehicleSpeed.class, mVehicleSpeedListener);
    //mVehicleManager.addListener(Longitude.class,longitudeListener);
    //mVehicleManager.addListener(Latitude.class,latitudeListener);

    setConnectionState(openXcState, true);


}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@MediumTest
public void testLocationWhenAllPresent() throws InterruptedException {
    prepareServices();
    source.inject(Latitude.ID, latitude);
    source.inject(Longitude.ID, longitude);
    source.inject(VehicleSpeed.ID, speed);
    TestUtils.pause(1000);

    // LocationManager just does *not* seem to work on a 2.3.x emulator
    if(android.os.Build.VERSION.SDK_INT >=
            android.os.Build.VERSION_CODES.HONEYCOMB) {
        Location lastVehicleLocation = mLocationManager.getLastKnownLocation(
                VehicleLocationProvider.VEHICLE_LOCATION_PROVIDER);
        assertThat(lastVehicleLocation, notNullValue());
        assertThat(lastVehicleLocation.getLatitude(), equalTo(latitude));
        assertThat(lastVehicleLocation.getLongitude(), equalTo(longitude));
        assertThat(lastVehicleLocation.getSpeed(), equalTo(speed.floatValue()));
    }
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@MediumTest
public void testOverwritesNativeGps() throws InterruptedException {
    prepareServices();
    source.inject(Latitude.ID, latitude);
    source.inject(Longitude.ID, longitude);
    source.inject(VehicleSpeed.ID, speed);
    TestUtils.pause(1000);

    // LocationManager just does *not* seem to work on a 2.3.x emulator
    if(android.os.Build.VERSION.SDK_INT >=
            android.os.Build.VERSION_CODES.HONEYCOMB) {
        Location lastAndroidLocation = mLocationManager.getLastKnownLocation(
                LocationManager.GPS_PROVIDER);
        assertThat(lastAndroidLocation, notNullValue());
        assertThat(lastAndroidLocation.getLatitude(), equalTo(latitude));
        assertThat(lastAndroidLocation.getLongitude(), equalTo(longitude));
        assertThat(lastAndroidLocation.getSpeed(), equalTo(speed.floatValue()));
    }
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
/**
 * Enable or disable overwriting Android's native GPS values with those from
 * the vehicle.
 *
 * If enabled, the GPS_PROVIDER from Android will respond with data taken
 * from the vehicle interface. The native GPS values will be used until GPS
 * data is actually received from the vehicle, so if the specific car you're
 * plugged into doesn't have GPS then the values will not be overwritten,
 * regardless of this setting.
 */
public void setOverwritingStatus(boolean enabled) {
    mOverwriteNativeStatus = enabled;
    mNativeGpsOverridden = false;
    if(mLocationManager != null && !enabled) {
        try {
            mLocationManager.removeTestProvider(
                    LocationManager.GPS_PROVIDER);
            Log.d(TAG, "Disabled overwriting native GPS with OpenXC GPS");
        } catch(IllegalArgumentException e) {
            Log.d(TAG, "Unable to remove GPS test provider - " +
                    "probably wasn't added yet");
        }

        mVehicleManager.removeListener(Latitude.class, this);
        mVehicleManager.removeListener(Longitude.class, this);
        mVehicleManager.removeListener(VehicleSpeed.class, this);
    } else {
        Log.d(TAG, "Enabled overwriting native GPS with OpenXC GPS");

        mVehicleManager.addListener(Latitude.class, this);
        mVehicleManager.addListener(Longitude.class, this);
        mVehicleManager.addListener(VehicleSpeed.class, this);
    }
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@Override
public void receive(Measurement measurement) {
    final VehicleSpeed speed = (VehicleSpeed) measurement;
    final float speedy = (float) speed.getValue().doubleValue();
    Log.i(TAG, "Vehicle Speed Simulation: " + speedy);
    mIgniteHandler.setSpeedData(speedy);


    runOnUiThread(new Runnable() {
        @Override
        public void run() {
            mSpeedView.speedTo(speedy, 500);
        }
    });
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@MediumTest
public void testNotOverwrittenWhenDisabled() {
    prepareServices();
    locationProvider.setOverwritingStatus(false);
    source.inject(Latitude.ID, latitude + 1);
    source.inject(Longitude.ID, longitude);
    source.inject(VehicleSpeed.ID, speed);
    TestUtils.pause(100);
    Location lastAndroidLocation = mLocationManager.getLastKnownLocation(
            LocationManager.GPS_PROVIDER);
    if(lastAndroidLocation != null) {
        assertTrue(lastAndroidLocation.getLatitude() != latitude + 1);
    }
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@MediumTest
public void testListenForMeasurement() throws VehicleServiceException,
        UnrecognizedMeasurementTypeException {
    prepareServices();
    service.addListener(VehicleSpeed.class, speedListener);
    source.inject(VehicleSpeed.ID, 42.0);
    assertNotNull(speedReceived);
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@MediumTest
public void testCustomSink() throws DataSourceException {
    prepareServices();
    assertNull(receivedMessageId);
    service.addSink(mCustomSink);
    source.inject(VehicleSpeed.ID, 42.0);
    assertNotNull(receivedMessageId);
    service.removeSink(mCustomSink);
    receivedMessageId = null;
    source.inject(VehicleSpeed.ID, 42.0);
    assertNull(receivedMessageId);
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@MediumTest
public void testAddListenersTwoMeasurements()
        throws VehicleServiceException,
        UnrecognizedMeasurementTypeException {
    prepareServices();
    service.addListener(VehicleSpeed.class, speedListener);
    service.addListener(SteeringWheelAngle.class, steeringWheelListener);
    source.inject(VehicleSpeed.ID, 42.0);
    source.inject(SteeringWheelAngle.ID, 12.1);
    assertNotNull(steeringAngleReceived);
    assertNotNull(speedReceived);
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@MediumTest
public void testRemoveMeasurementListener() throws VehicleServiceException,
        UnrecognizedMeasurementTypeException {
    prepareServices();
    service.addListener(VehicleSpeed.class, speedListener);
    source.inject(VehicleSpeed.ID, 42.0);
    service.removeListener(VehicleSpeed.class, speedListener);
    speedReceived = null;
    source.inject(VehicleSpeed.ID, 42.0);
    TestUtils.pause(10);
    assertNull(speedReceived);
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@MediumTest
public void testRemoveWithoutListening()
        throws VehicleServiceException,
        UnrecognizedMeasurementTypeException {
    prepareServices();
    service.removeListener(VehicleSpeed.class, speedListener);
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@MediumTest
public void testRemoveOneMeasurementListener()
        throws VehicleServiceException,
        UnrecognizedMeasurementTypeException {
    prepareServices();
    service.addListener(VehicleSpeed.class, speedListener);
    service.addListener(SteeringWheelAngle.class, steeringWheelListener);
    source.inject(VehicleSpeed.ID, 42.0);
    service.removeListener(VehicleSpeed.class, speedListener);
    speedReceived = null;
    source.inject(VehicleSpeed.ID, 42.0);
    TestUtils.pause(10);
    assertNull(speedReceived);
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@MediumTest
public void testConsistentAge()
        throws UnrecognizedMeasurementTypeException,
        NoValueException, VehicleServiceException, DataSourceException {
    prepareServices();
    source.inject(VehicleSpeed.ID, 42.0);
    TestUtils.pause(1);
    Measurement measurement = service.get(VehicleSpeed.class);
    long age = measurement.getAge();
    assertTrue("Measurement age (" + age + ") should be > 5ms",
            age > 5);
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@MediumTest
public void testGetMeasurement() throws UnrecognizedMeasurementTypeException,
        NoValueException {
    prepareServices();
    source.inject(VehicleSpeed.ID, 42.0);
    VehicleSpeed measurement = (VehicleSpeed)
            service.get(VehicleSpeed.class);
    assertNotNull(measurement);
    assertEquals(measurement.getValue().doubleValue(), 42.0);
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
public void stop() {
    if(mVehicleManager != null) {
        mVehicleManager.removeListener(Latitude.class, this);
        mVehicleManager.removeListener(Longitude.class, this);
        mVehicleManager.removeListener(VehicleSpeed.class, this);
    }

    if(mLocationManager != null && mLocationManager.getProvider(
                VEHICLE_LOCATION_PROVIDER) != null) {
        mLocationManager.removeTestProvider(VEHICLE_LOCATION_PROVIDER);
    }
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@Override
public void receive(Measurement measurement) {
    if(measurement instanceof Latitude || measurement instanceof Longitude
            || measurement instanceof VehicleSpeed) {
        // To keep down the number of times we touch the Android location
        // system to update the location, only update if we have a change in
        // the measurements we use.
        updateLocation();
    }
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@Test
public void receiveNonMatchingMeasurementNotPropagated() throws
        DataSinkException, UnrecognizedMeasurementTypeException {
    VehicleSpeed speed = new VehicleSpeed(42.0);
    sink.register(speed.getClass(), speedListener);
    SteeringWheelAngle angle = new SteeringWheelAngle(10.1);
    sink.receive(angle.toVehicleMessage());
    sink.clearQueue();
    assertThat(speedReceived, nullValue());
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@Test
public void listenerReceivesMeasurement() throws DataSinkException,
       UnrecognizedMeasurementTypeException {
    VehicleSpeed speed = new VehicleSpeed(42.0);
    sink.register(speed.getClass(), speedListener);
    sink.receive(speed.toVehicleMessage());
    sink.clearQueue();
    assertThat(speedReceived, notNullValue());
    assertEquals(speedReceived, speed);
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@Test
public void removeMeasurementListenerByClass()
        throws UnrecognizedMeasurementTypeException, DataSinkException {
    VehicleSpeed speed = new VehicleSpeed(42.0);
    sink.register(speed.getClass(), speedListener);
    sink.unregister(speed.getClass(), speedListener);
    sink.receive(speed.toVehicleMessage());
    sink.clearQueue();
    assertThat(speedReceived, nullValue());
}
 

import com.openxc.measurements.VehicleSpeed; //导入依赖的package包/类
@Test
public void removeMeasurementListener()
        throws UnrecognizedMeasurementTypeException, DataSinkException {
    VehicleSpeed speed = new VehicleSpeed(42.0);
    sink.register(speed.getClass(), speedListener);
    sink.unregister(speed.getClass(), speedListener);
    sink.receive(speed.toVehicleMessage());
    sink.clearQueue();
    assertThat(speedReceived, nullValue());
}