fix(patch): [sc-13510] Remove dependency on latency timer. (#93)

* fix(patch): [sc-13510] Remove dependency on latency timer.

* Remove dependency.

Author: ser-0xff

Benchmarks/DistributedSystem/DistributedSystemBenchmarks.swift

@@ -3,7 +3,6 @@ import Dispatch
 import Distributed
 import DistributedSystem
 import class Foundation.ProcessInfo
-import LatencyTimer
 import Logging
 import TestMessages
 

Benchmarks/DistributedSystem/ServerAndClient.swift

@@ -1,6 +1,5 @@
 import Benchmark
 import DistributedSystem
-import LatencyTimer
 import Logging
 import TestMessages
 internal import struct NIOConcurrencyHelpers.NIOLock

Package.swift

@@ -17,7 +17,6 @@ let externalDependencies: [String: Range<Version>] = [
 let internalDependencies: [String: Range<Version>] = [
     "package-benchmark": .upToNextMajor(from: "1.0.0"),
     "package-consul": .upToNextMajor(from: "7.0.0"),
-    "package-latency-tools": .upToNextMajor(from: "1.0.0")
 ]
 
 #if swift(>=6.0)
@@ -119,7 +118,6 @@ let package = Package(
                 "TestMessages",
                 .product(name: "ArgumentParser", package: "swift-argument-parser"),
                 .product(name: "Lifecycle", package: "swift-service-lifecycle_1.0"),
-                .product(name: "LatencyTimer", package: "package-latency-tools")
             ],
             path: "Sources/ForTesting/TestClient",
             swiftSettings: [
@@ -133,7 +131,6 @@ let package = Package(
                 "TestMessages",
                 .product(name: "Benchmark", package: "package-benchmark"),
                 .product(name: "BenchmarkPlugin", package: "package-benchmark"),
-                .product(name: "LatencyTimer", package: "package-latency-tools")
             ],
             path: "Benchmarks/DistributedSystem",
             swiftSettings: [

Sources/ForTesting/TestClient/TestClient.swift

@@ -3,7 +3,6 @@ import Dispatch
 import Distributed
 import DistributedSystem
 import class Foundation.ProcessInfo
-import LatencyTimer
 import Lifecycle
 import Logging
 import TestMessages
@@ -40,7 +39,7 @@ public struct ClientStarter: AsyncParsableCommand {
 public class TestClient: TestableClient, @unchecked Sendable {
     private let actorSystem: DistributedSystem
 
-    private var start: UInt64 = 0
+    private var start: ContinuousClock.Instant?
     private var received = 0
     private var expected = 0
 
@@ -60,12 +59,14 @@ public class TestClient: TestableClient, @unchecked Sendable {
     }
 
     public func snapshotDone(for _: Stream) async {
-        let finish = LatencyTimer.getTimestamp()
+        let finish = ContinuousClock.now
         if received != expected {
             logger.error("MISBEHAVIOR: received \(received) monsters, but expected \(expected)")
         }
-        let timePassed = finish - start
-        logger.info("Stream snapshot done in \(timePassed) usec, received \(received) monsters")
+        if let start {
+            let duration = start.duration(to: finish)
+            logger.info("Stream snapshot done in \(duration), received \(received) monsters")
+        }
     }
 
     public func handleConnectionState(_ state: ConnectionState) async {
@@ -85,7 +86,7 @@ public class TestClient: TestableClient, @unchecked Sendable {
             )
 
             let openRequest = _OpenRequestStruct(requestIdentifier: 1)
-            start = LatencyTimer.getTimestamp()
+            start = ContinuousClock.now
 
             try await serverEndpoint.openStream(byRequest: OpenRequest(openRequest))
         } catch {