adjust benchmarks

vapor · Jan 11, 2025 · ad4c1c7 · ad4c1c7
1 parent 86b00c7
commit ad4c1c7
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 5 deletions.
diff --git a/Benchmarks/Parser/Parser.swift b/Benchmarks/Parser/Parser.swift
@@ -8,16 +8,14 @@ let benchmarks: @Sendable () -> Void = {
     let bigMessage = makeMessage(boundary: boundary, size: 1 << 24) // 400MiB: Big message
     let bigMessageStream = makeParsingStream(for: bigMessage, chunkSize: 1 << 14) // 16KiB: Realistic streaming chunk size
 
-    let streamingSequence = StreamingMultipartParserAsyncSequence(boundary: boundary, buffer: bigMessageStream)
-    let sequence = MultipartParserAsyncSequence(boundary: boundary, buffer: bigMessageStream)
-
     Benchmark(
         "StreamingParserAllocations",
         configuration: .init(
             metrics: [.mallocCountTotal]
         )
     ) { benchmark in
         for _ in benchmark.scaledIterations {
+            let streamingSequence = StreamingMultipartParserAsyncSequence(boundary: boundary, buffer: bigMessageStream)
             for try await element in streamingSequence {
                 blackHole(element)
             }
@@ -31,6 +29,7 @@ let benchmarks: @Sendable () -> Void = {
         )
     ) { benchmark in
         for _ in benchmark.scaledIterations {
+            let streamingSequence = StreamingMultipartParserAsyncSequence(boundary: boundary, buffer: bigMessageStream)
             for try await element in streamingSequence {
                 blackHole(element)
             }
@@ -44,6 +43,7 @@ let benchmarks: @Sendable () -> Void = {
         )
     ) { benchmark in
         for _ in benchmark.scaledIterations {
+            let sequence = MultipartParserAsyncSequence(boundary: boundary, buffer: bigMessageStream)
             for try await element in sequence {
                 blackHole(element)
             }
@@ -57,6 +57,7 @@ let benchmarks: @Sendable () -> Void = {
         )
     ) { benchmark in
         for _ in benchmark.scaledIterations {
+            let sequence = MultipartParserAsyncSequence(boundary: boundary, buffer: bigMessageStream)
             for try await element in sequence {
                 blackHole(element)
             }

diff --git a/Benchmarks/Serializer/Serializer.swift b/Benchmarks/Serializer/Serializer.swift
@@ -19,7 +19,8 @@ let benchmarks: @Sendable () -> Void = {
         )
     ) { benchmark in
         for _ in benchmark.scaledIterations {
-            let seriliazed = try MultipartSerializer(boundary: "boundary123").serialize(parts: onePart)
+            let serializer = MultipartSerializer(boundary: "boundary123")
+            let seriliazed = try serializer.serialize(parts: onePart)
             blackHole(seriliazed)
         }
     }
@@ -31,7 +32,8 @@ let benchmarks: @Sendable () -> Void = {
         )
     ) { benchmark in
         for _ in benchmark.scaledIterations {
-            let seriliazed = try MultipartSerializer(boundary: "boundary123").serialize(parts: repeatedParts)
+            let serializer = MultipartSerializer(boundary: "boundary123")
+            let seriliazed = try serializer.serialize(parts: repeatedParts)
             blackHole(seriliazed)
         }
     }