fix(tracing): make spans resilient to performance clock drift

CHANGELOG.md

@@ -22,6 +22,7 @@ For experimental package changes, see the [experimental CHANGELOG](experimental/
     * `telemetry.sdk.name`
     * `telemetry.sdk.language`
     * `telemetry.sdk.version`
+* fix(sdk-trace): make spans resilient to clock drift [#3434](https://github.com/open-telemetry/opentelemetry-js/pull/3434) @dyladan
 * fix(selenium-tests): updated webpack version for selenium test issue [#3456](https://github.com/open-telemetry/opentelemetry-js/issues/3456) @SaumyaBhushan
 * fix(sdk-metrics): fix duplicated registration of metrics for collectors [#3488](https://github.com/open-telemetry/opentelemetry-js/pull/3488) @legendecas
 * fix(core): fix precision loss in numberToHrtime [#3480](https://github.com/open-telemetry/opentelemetry-js/pull/3480) @legendecas

experimental/CHANGELOG.md

@@ -23,6 +23,7 @@ All notable changes to experimental packages in this project will be documented
 * fix(prometheus-sanitization): replace repeated `_` with a single `_` [3470](https://github.com/open-telemetry/opentelemetry-js/pull/3470) @samimusallam
 * fix(prometheus-serializer): correct string used for NaN [#3477](https://github.com/open-telemetry/opentelemetry-js/pull/3477) @JacksonWeber
 * fix(instrumentation-http): close server span when response finishes [#3407](https://github.com/open-telemetry/opentelemetry-js/pull/3407) @legendecas
+* fix(fetch): make spans resilient to clock drift by using Date.now [#3434](https://github.com/open-telemetry/opentelemetry-js/pull/3434) @dyladan
 * fix(sdk-node): fix exporter to be read only OTEL_TRACES_EXPORTER is set to a valid exporter [3492] @svetlanabrennan
 
 ### :books: (Refine Doc)

experimental/packages/opentelemetry-instrumentation-fetch/src/fetch.ts

@@ -276,12 +276,13 @@ export class FetchInstrumentation extends InstrumentationBase<
     spanData: SpanData,
     response: FetchResponse
   ) {
-    const endTime = core.hrTime();
+    const endTime = core.epochMillisToHrTime(Date.now());
+    const performanceEndTime = core.hrTime();
     this._addFinalSpanAttributes(span, response);
 
     setTimeout(() => {
       spanData.observer?.disconnect();
-      this._findResourceAndAddNetworkEvents(span, spanData, endTime);
+      this._findResourceAndAddNetworkEvents(span, spanData, performanceEndTime);
       this._tasksCount--;
       this._clearResources();
       span.end(endTime);

packages/opentelemetry-core/src/common/time.ts

@@ -27,7 +27,7 @@ const SECOND_TO_NANOSECONDS = Math.pow(10, NANOSECOND_DIGITS);
  * Converts a number of milliseconds from epoch to HrTime([seconds, remainder in nanoseconds]).
  * @param epochMillis
  */
-function numberToHrtime(epochMillis: number): api.HrTime {
+export function epochMillisToHrTime(epochMillis: number): api.HrTime {
   const epochSeconds = epochMillis / 1000;
   // Decimals only.
   const seconds = Math.trunc(epochSeconds);
@@ -36,7 +36,7 @@ function numberToHrtime(epochMillis: number): api.HrTime {
   return [seconds, nanos];
 }
 
-function getTimeOrigin(): number {
+export function getTimeOrigin(): number {
   let timeOrigin = performance.timeOrigin;
   if (typeof timeOrigin !== 'number') {
     const perf: TimeOriginLegacy = performance as unknown as TimeOriginLegacy;
@@ -50,21 +50,12 @@ function getTimeOrigin(): number {
  * @param performanceNow
  */
 export function hrTime(performanceNow?: number): api.HrTime {
-  const timeOrigin = numberToHrtime(getTimeOrigin());
-  const now = numberToHrtime(
+  const timeOrigin = epochMillisToHrTime(getTimeOrigin());
+  const now = epochMillisToHrTime(
     typeof performanceNow === 'number' ? performanceNow : performance.now()
   );
 
-  let seconds = timeOrigin[0] + now[0];
-  let nanos = timeOrigin[1] + now[1];
-
-  // Nanoseconds
-  if (nanos > SECOND_TO_NANOSECONDS) {
-    nanos -= SECOND_TO_NANOSECONDS;
-    seconds += 1;
-  }
-
-  return [seconds, nanos];
+  return addHrTimes(timeOrigin, now);
 }
 
 /**
@@ -82,10 +73,10 @@ export function timeInputToHrTime(time: api.TimeInput): api.HrTime {
       return hrTime(time);
     } else {
       // epoch milliseconds or performance.timeOrigin
-      return numberToHrtime(time);
+      return epochMillisToHrTime(time);
     }
   } else if (time instanceof Date) {
-    return numberToHrtime(time.getTime());
+    return epochMillisToHrTime(time.getTime());
   } else {
     throw TypeError('Invalid input type');
   }
@@ -175,3 +166,14 @@ export function isTimeInput(
     value instanceof Date
   );
 }
+
+export function addHrTimes(time1: api.HrTime, time2: api.HrTime): api.HrTime {
+  const out: api.HrTime = [time1[0] + time2[0], time1[1] + time2[1]];
+
+  if (out[1] > SECOND_TO_NANOSECONDS) {
+    out[0] = out[0] + Math.floor(out[1] / SECOND_TO_NANOSECONDS);
+    out[1] = out[1] % SECOND_TO_NANOSECONDS;
+  }
+
+  return out;
+}

packages/opentelemetry-core/test/common/time.test.ts

@@ -27,6 +27,7 @@ import {
   hrTimeToMicroseconds,
   hrTimeToTimeStamp,
   isTimeInput,
+  addHrTimes,
 } from '../../src/common/time';
 
 describe('time', () => {
@@ -224,4 +225,34 @@ describe('time', () => {
       assert.strictEqual(isTimeInput(undefined), false);
     });
   });
+
+  describe('#addHrTimes', () => {
+    const NANOSECOND_DIGITS = 9;
+    const SECOND_TO_NANOSECONDS = Math.pow(10, NANOSECOND_DIGITS);
+
+    it('should add two positive times', () => {
+      const output = addHrTimes([10, 20], [30, 40]);
+      assert.deepStrictEqual(output, [40, 60]);
+    });
+    it('should add two negative times', () => {
+      const output = addHrTimes([-10, 20], [-30, 40]);
+      assert.deepStrictEqual(output, [-40, 60]);
+    });
+    it('should add a positive and negative time (result positive)', () => {
+      const output = addHrTimes([-10, 20], [30, 40]);
+      assert.deepStrictEqual(output, [20, 60]);
+    });
+    it('should add a positive and negative time (result negative)', () => {
+      const output = addHrTimes([10, 20], [-30, 40]);
+      assert.deepStrictEqual(output, [-20, 60]);
+    });
+    it('should overflow nanoseconds to seconds', () => {
+      const output = addHrTimes([10, SECOND_TO_NANOSECONDS - 10], [10, 20]);
+      assert.deepStrictEqual(output, [21, 10]);
+    });
+    it('should overflow nanoseconds to seconds (negative)', () => {
+      const output = addHrTimes([-10, SECOND_TO_NANOSECONDS - 10], [-10, 20]);
+      assert.deepStrictEqual(output, [-19, 10]);
+    });
+  });
 });