avoid log data cloning

opentelemetry-sdk/src/logs/log_emitter.rs

@@ -209,16 +209,33 @@ impl opentelemetry::logs::Logger for Logger {
             cx.has_active_span()
                 .then(|| TraceContext::from(cx.span().span_context()))
         });
-        for p in processors {
-            let mut record = record.clone();
-            if let Some(ref trace_context) = trace_context {
-                record.trace_context = Some(trace_context.clone())
+        // Prioritize the scenario where there is likely to be only one processor.
+        if processors.len() == 1 {
+            // If there is exactly one processor, use the record directly.
+            if let Some(p) = processors.first() {
+                let mut record = record; // Move the record directly, avoiding clone.
+                if let Some(ref trace_context) = trace_context {
+                    record.trace_context = Some(trace_context.clone());
+                }
+                let data = LogData {
+                    record,
+                    instrumentation: self.instrumentation_library().clone(),
+                };
+                p.emit(data);
+            }
+        } else {
+            // For multiple processors, clone the record for each.
+            for p in processors {
+                let mut cloned_record = record.clone();
+                if let Some(ref trace_context) = trace_context {
+                    cloned_record.trace_context = Some(trace_context.clone());
+                }
+                let data = LogData {
+                    record: cloned_record,
+                    instrumentation: self.instrumentation_library().clone(),
+                };
+                p.emit(data);
             }
-            let data = LogData {
-                record,
-                instrumentation: self.instrumentation_library().clone(),
-            };
-            p.emit(data);
         }
     }
 

stress/Cargo.toml

@@ -23,8 +23,8 @@ doc = false
 ctrlc = "3.2.5"
 lazy_static = "1.4.0"
 num_cpus = "1.15.0"
-opentelemetry = { path = "../opentelemetry", features = ["metrics", "logs", "trace"] }
-opentelemetry_sdk = { path = "../opentelemetry-sdk", features = ["metrics", "logs", "trace"] }
+opentelemetry = { path = "../opentelemetry", features = ["metrics", "logs", "trace", "logs_level_enabled"] }
+opentelemetry_sdk = { path = "../opentelemetry-sdk", features = ["metrics", "logs", "trace", "logs_level_enabled"] }
 opentelemetry-appender-tracing = { path = "../opentelemetry-appender-tracing"}
 rand = { version = "0.8.4", features = ["small_rng"] }
 tracing = { workspace = true, features = ["std"]}