Commit 7f4784f1 authored by Gwendal Grignou's avatar Gwendal Grignou Committed by Enric Balletbo i Serra

platform/chrome: cros_ec_sensorhub: Simplify legacy timestamp spreading

On some machines (nami), interrupt latency cause samples to appear
to be from the future and are pegged to the current time.
We would see samples with this pattern:

[t, t + ~5ms, t + ~10ms, t + ~10ms + 100us, t + ~10ms + 200us],
                             (current now)      (current now)
(t is the last timestamp time)

Last 2 samples would be barely spread, causing applications to
complain.

We now spread the entire sequence. This is not great: in the example
the sensor was supposed to send samples every 5ms, it now appears to
send one every 2.5ms, but it is slightly closer to reality:

sampling time in the example above
At sensor level

1             2             3             4            5
+-----5ms-----+-----5ms-----+-----5ms-----+----5ms-----+---> t

Before, at host level
                       1             2             3 4 5
--interrupt delay------+-----5ms-----+-----5ms-----+-+-+---> t

Afer, at host level
                       1       2       3       4       5
--interrupt delay------+-2.5ms-+-2.5ms-+-2.5ms-+-2.5ms-+---> t
Signed-off-by: default avatarGwendal Grignou <gwendal@chromium.org>
Signed-off-by: default avatarEnric Balletbo i Serra <enric.balletbo@collabora.com>
parent c1e18d4f
...@@ -673,29 +673,22 @@ cros_ec_sensor_ring_spread_add(struct cros_ec_sensorhub *sensorhub, ...@@ -673,29 +673,22 @@ cros_ec_sensor_ring_spread_add(struct cros_ec_sensorhub *sensorhub,
* cros_ec_sensor_ring_spread_add_legacy: Calculate proper timestamps then * cros_ec_sensor_ring_spread_add_legacy: Calculate proper timestamps then
* add to ringbuffer (legacy). * add to ringbuffer (legacy).
* *
* Note: This assumes we're running old firmware, where every sample's timestamp * Note: This assumes we're running old firmware, where timestamp
* is after the sample. Run if tight_timestamps == false. * is inserted after its sample(s)e. There can be several samples between
* * timestamps, so several samples can have the same timestamp.
* If there is a sample with a proper timestamp
* *
* timestamp | count * timestamp | count
* ----------------- * -----------------
* older_unprocess_out --> TS1 | 1 * 1st sample --> TS1 | 1
* TS1 | 2 * TS2 | 2
* out --> TS1 | 3 * TS2 | 3
* next_out --> TS2 | * TS3 | 4
* * last_out -->
* We spread time for the samples [older_unprocess_out .. out]
* between TS1 and TS2: [TS1+1/4, TS1+2/4, TS1+3/4, TS2].
* *
* If we reach the end of the samples, we compare with the
* current timestamp:
* *
* older_unprocess_out --> TS1 | 1 * We spread time for the samples using perod p = (current - TS1)/4.
* TS1 | 2 * between TS1 and TS2: [TS1+p/4, TS1+2p/4, TS1+3p/4, current_timestamp].
* out --> TS1 | 3
* *
* We know have [TS1+1/3, TS1+2/3, current timestamp]
*/ */
static void static void
cros_ec_sensor_ring_spread_add_legacy(struct cros_ec_sensorhub *sensorhub, cros_ec_sensor_ring_spread_add_legacy(struct cros_ec_sensorhub *sensorhub,
...@@ -708,58 +701,37 @@ cros_ec_sensor_ring_spread_add_legacy(struct cros_ec_sensorhub *sensorhub, ...@@ -708,58 +701,37 @@ cros_ec_sensor_ring_spread_add_legacy(struct cros_ec_sensorhub *sensorhub,
int i; int i;
for_each_set_bit(i, &sensor_mask, sensorhub->sensor_num) { for_each_set_bit(i, &sensor_mask, sensorhub->sensor_num) {
s64 older_timestamp;
s64 timestamp; s64 timestamp;
struct cros_ec_sensors_ring_sample *older_unprocess_out = int count = 0;
sensorhub->ring;
struct cros_ec_sensors_ring_sample *next_out;
int count = 1;
for (out = sensorhub->ring; out < last_out; out = next_out) {
s64 time_period; s64 time_period;
next_out = out + 1; for (out = sensorhub->ring; out < last_out; out++) {
if (out->sensor_id != i) if (out->sensor_id != i)
continue; continue;
/* Timestamp to start with */ /* Timestamp to start with */
older_timestamp = out->timestamp; timestamp = out->timestamp;
out++;
/* Find next sample. */ count = 1;
while (next_out < last_out && next_out->sensor_id != i) break;
next_out++;
if (next_out >= last_out) {
timestamp = current_timestamp;
} else {
timestamp = next_out->timestamp;
if (timestamp == older_timestamp) {
count++;
continue;
} }
for (; out < last_out; out++) {
/* Find last sample. */
if (out->sensor_id != i)
continue;
count++;
} }
if (count == 0)
continue;
/* /* Spread uniformly between the first and last samples. */
* The next sample has a new timestamp, spread the time_period = div_s64(current_timestamp - timestamp, count);
* unprocessed samples.
*/
if (next_out < last_out)
count++;
time_period = div_s64(timestamp - older_timestamp,
count);
for (; older_unprocess_out <= out; for (out = sensorhub->ring; out < last_out; out++) {
older_unprocess_out++) { if (out->sensor_id != i)
if (older_unprocess_out->sensor_id != i)
continue; continue;
older_timestamp += time_period; timestamp += time_period;
older_unprocess_out->timestamp = out->timestamp = timestamp;
older_timestamp;
}
count = 1;
/* The next_out sample has a valid timestamp, skip. */
next_out++;
older_unprocess_out = next_out;
} }
} }
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment