From ad4c1c7172f9daea0721eeb315dd41dde33ac876 Mon Sep 17 00:00:00 2001 From: MahdiBM Date: Sat, 11 Jan 2025 22:06:51 +0330 Subject: [PATCH] adjust benchmarks --- Benchmarks/Parser/Parser.swift | 7 ++++--- Benchmarks/Serializer/Serializer.swift | 6 ++++-- 2 files changed, 8 insertions(+), 5 deletions(-) diff --git a/Benchmarks/Parser/Parser.swift b/Benchmarks/Parser/Parser.swift index 9dbf9a34..97ec5701 100644 --- a/Benchmarks/Parser/Parser.swift +++ b/Benchmarks/Parser/Parser.swift @@ -8,9 +8,6 @@ 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( @@ -18,6 +15,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) } @@ -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 index 10fe5980..01e72292 100644 --- 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) } }