more

Author: externl

swift/test/Ice/location/Server.swift

@@ -1,9 +1,25 @@
 // Copyright (c) ZeroC, Inc.
 
-import Dispatch
 import Ice
 import TestCommon
 
+
+struct DispatchWrapper: Dispatcher {
+    let dispatcher: Dispatcher
+
+    func dispatch(_ request: sending IncomingRequest) async throws -> OutgoingResponse {
+        let startTime = ContinuousClock.now
+        let response = try await dispatcher.dispatch(request)
+        let endTime = ContinuousClock.now
+        let elapsed = startTime.duration(to: endTime)
+
+        let logger = request.current.adapter.getCommunicator().getLogger()
+        logger.print("Swift Dispatch: identity=\(request.current.id) operation=\(request.current.operation) duration=\(Double(elapsed.components.attoseconds) / 1_000_000_000_000_000.0) ms")
+
+        return response
+    }
+}
+
 class Server: TestHelperI, @unchecked Sendable {
     override public func run(args: [String]) async throws {
         //
@@ -13,8 +29,6 @@ class Server: TestHelperI, @unchecked Sendable {
         //
 
         let properties = try createTestProperties(args)
-        properties.setProperty(key: "Ice.Trace.Dispatch", value: "1")
-        properties.setProperty(key: "Ice.Trace.Network", value: "3")
         properties.setProperty(key: "Ice.ThreadPool.Server.Size", value: "2")
         let communicator = try initialize(Ice.InitializationData(properties: properties))
         defer {
@@ -35,7 +49,7 @@ class Server: TestHelperI, @unchecked Sendable {
         // Make sure we use a separate copy of the properties as the servant modifies them.
         let object = ServerManagerI(registry: registry, properties: properties.clone(), helper: self)
 
-        try adapter.add(servant: object, id: Ice.stringToIdentity("ServerManager"))
+        try adapter.add(servant: DispatchWrapper(dispatcher: object), id: Ice.stringToIdentity("ServerManager"))
         try await registry.addObject(adapter.createProxy(Ice.stringToIdentity("ServerManager")))
 
         let registryPrx = try uncheckedCast(
@@ -45,7 +59,7 @@ class Server: TestHelperI, @unchecked Sendable {
             type: Ice.LocatorRegistryPrx.self)
 
         let locator = ServerLocator(registry: registry, registryPrx: registryPrx)
-        try adapter.add(servant: locator, id: Ice.stringToIdentity("locator"))
+        try adapter.add(servant: DispatchWrapper(dispatcher: locator), id: Ice.stringToIdentity("locator"))
 
         try adapter.activate()
         serverReady()