ensure that call option timeout is included in export calls

Author: bryce-b

Package.swift

@@ -34,14 +34,14 @@ let package = Package(
         .executable(name: "loggingTracer", targets: ["LoggingTracer"]),
     ],
     dependencies: [
-        .package(name: "Opentracing", url: "https://github.com/undefinedlabs/opentracing-objc", from: "0.5.2"),
-        .package(name: "Thrift", url: "https://github.com/undefinedlabs/Thrift-Swift", from: "1.1.1"),
-        .package(name: "swift-nio", url: "https://github.com/apple/swift-nio.git", from: "2.0.0"),
-        .package(name: "grpc-swift", url: "https://github.com/grpc/grpc-swift.git", from: "1.0.0"),
-        .package(name: "swift-protobuf", url: "https://github.com/apple/swift-protobuf.git", from: "1.20.2"),
-        .package(name: "swift-log", url: "https://github.com/apple/swift-log.git", from: "1.4.4"),
-        .package(name: "swift-metrics", url: "https://github.com/apple/swift-metrics.git", from: "2.1.1"),
-        .package(name: "Reachability.swift", url: "https://github.com/ashleymills/Reachability.swift", from: "5.1.0")
+        .package(name: "Opentracing", url: "https://github.com/undefinedlabs/opentracing-objc", exact: "0.5.2"),
+        .package(name: "Thrift", url: "https://github.com/undefinedlabs/Thrift-Swift", exact: "1.1.1"),
+        .package(name: "swift-nio", url: "https://github.com/apple/swift-nio.git", exact: "2.0.0"),
+        .package(name: "grpc-swift", url: "https://github.com/grpc/grpc-swift.git", exact: "1.0.0"),
+        .package(name: "swift-protobuf", url: "https://github.com/apple/swift-protobuf.git", exact: "1.20.2"),
+        .package(name: "swift-log", url: "https://github.com/apple/swift-log.git", exact: "1.4.4"),
+        .package(name: "swift-metrics", url: "https://github.com/apple/swift-metrics.git", exact: "2.1.1"),
+        .package(name: "Reachability.swift", url: "https://github.com/ashleymills/Reachability.swift", exact: "5.1.0")
     ],
     targets: [
         .target(name: "OpenTelemetryApi",

Sources/Exporters/OpenTelemetryProtocolGrpc/logs/OtlpLogExporter.swift

@@ -16,7 +16,7 @@ public class OtlpLogExporter : LogRecordExporter {
     let channel : GRPCChannel
     var logClient : Opentelemetry_Proto_Collector_Logs_V1_LogsServiceNIOClient
     let config : OtlpConfiguration
-    var callOptions : CallOptions? = nil
+    var callOptions : CallOptions
 
     public init(channel: GRPCChannel,
                 config: OtlpConfiguration = OtlpConfiguration(),
@@ -46,6 +46,12 @@ public class OtlpLogExporter : LogRecordExporter {
         let logRequest = Opentelemetry_Proto_Collector_Logs_V1_ExportLogsServiceRequest.with { request in
             request.resourceLogs = LogRecordAdapter.toProtoResourceRecordLog(logRecordList: logRecords)
         }
+      
+        if config.timeout > 0 {
+          callOptions.timeLimit = TimeLimit.timeout(TimeAmount.nanoseconds(Int64(config.timeout.toNanoseconds)))
+        }
+
+      
         let export = logClient.export(logRequest, callOptions: callOptions)
         do {
             _ = try export.response.wait()

Sources/Exporters/OpenTelemetryProtocolGrpc/trace/OtlpTraceExporter.swift

@@ -16,7 +16,7 @@ public class OtlpTraceExporter: SpanExporter {
     let channel: GRPCChannel
     var traceClient: Opentelemetry_Proto_Collector_Trace_V1_TraceServiceNIOClient
     let config : OtlpConfiguration
-    var callOptions : CallOptions? = nil
+    var callOptions : CallOptions
 
     public init(channel: GRPCChannel, config: OtlpConfiguration = OtlpConfiguration(), logger: Logging.Logger = Logging.Logger(label: "io.grpc", factory: { _ in SwiftLogNoOpLogHandler() }), envVarHeaders: [(String,String)]? = EnvVarHeaders.attributes) {
         self.channel = channel
@@ -44,7 +44,7 @@ public class OtlpTraceExporter: SpanExporter {
         }
 
         if config.timeout > 0 {
-            traceClient.defaultCallOptions.timeLimit = TimeLimit.timeout(TimeAmount.nanoseconds(Int64(config.timeout.toNanoseconds)))
+           callOptions.timeLimit = TimeLimit.timeout(TimeAmount.nanoseconds(Int64(config.timeout.toNanoseconds)))
         }
 
         let export = traceClient.export(exportRequest, callOptions: callOptions)

Sources/OpenTelemetrySdk/Trace/SpanProcessors/BatchSpanProcessor.swift

@@ -134,7 +134,10 @@ private class BatchWorker: Thread {
       self?.exportAction(spanList: spanList)
     }
     let timeoutTimer = DispatchSource.makeTimerSource(queue: DispatchQueue.global())
-    timeoutTimer.setEventHandler { exportOperation.cancel() }
+    timeoutTimer.setEventHandler {
+      exportOperation.cancel()
+      
+    }
     let maxTimeOut = min(explicitTimeout ?? TimeInterval.greatestFiniteMagnitude, exportTimeout)
     timeoutTimer.schedule(deadline: .now() + .milliseconds(Int(maxTimeOut.toMilliseconds)), leeway: .milliseconds(1))
     timeoutTimer.activate()