From 06e4cac4f3f1fe05c71bce3764bc557b6680a4a9 Mon Sep 17 00:00:00 2001 From: Kerry Jiang Date: Sun, 10 Mar 2024 22:46:36 -0700 Subject: [PATCH] fixed the build of SuperSocket.Benchmarks --- test/SuperSocket.Benchmarks/CurrentSend.cs | 8 ++++---- ...sparentPipeChannel.cs => TransparentPipeConnection.cs} | 6 +++--- 2 files changed, 7 insertions(+), 7 deletions(-) rename test/SuperSocket.Benchmarks/{TransparentPipeChannel.cs => TransparentPipeConnection.cs} (81%) diff --git a/test/SuperSocket.Benchmarks/CurrentSend.cs b/test/SuperSocket.Benchmarks/CurrentSend.cs index 2ae95893e..883825b8a 100644 --- a/test/SuperSocket.Benchmarks/CurrentSend.cs +++ b/test/SuperSocket.Benchmarks/CurrentSend.cs @@ -4,7 +4,7 @@ using System.Threading.Tasks; using BenchmarkDotNet; using BenchmarkDotNet.Attributes; -using SuperSocket.Channel; +using SuperSocket.Connection; using SuperSocket.ProtoBase; namespace SuperSocket.Benchmarks @@ -27,15 +27,15 @@ public async Task SendTest() for (var i = 0; i < ConcurrentLevel; i++) { - tasks[i] = Send(pool, new ChannelOptions(), Iteration); + tasks[i] = Send(pool, new ConnectionOptions(), Iteration); } await Task.WhenAll(tasks); } - private async Task Send(ArrayPool pool, ChannelOptions options, int iteration) + private async Task Send(ArrayPool pool, ConnectionOptions options, int iteration) { - var channel = new TransparentPipeChannel(new CommandLinePipelineFilter(), options); + var channel = new TransparentPipeConnection(new CommandLinePipelineFilter(), options); channel.Start(); for (var i = 0; i < iteration; i++) diff --git a/test/SuperSocket.Benchmarks/TransparentPipeChannel.cs b/test/SuperSocket.Benchmarks/TransparentPipeConnection.cs similarity index 81% rename from test/SuperSocket.Benchmarks/TransparentPipeChannel.cs rename to test/SuperSocket.Benchmarks/TransparentPipeConnection.cs index 4a373b23d..9ef9c5e1d 100644 --- a/test/SuperSocket.Benchmarks/TransparentPipeChannel.cs +++ b/test/SuperSocket.Benchmarks/TransparentPipeConnection.cs @@ -2,17 +2,17 @@ using System.Buffers; using System.Threading; using System.Threading.Tasks; -using SuperSocket.Channel; +using SuperSocket.Connection; using SuperSocket.ProtoBase; namespace SuperSocket.Benchmarks { - public class TransparentPipeChannel : PipeChannel + public class TransparentPipeConnection : PipeConnection { private TaskCompletionSource _tcs; private Task _channelTask; - public TransparentPipeChannel(IPipelineFilter pipelineFilter, ChannelOptions options) + public TransparentPipeConnection(IPipelineFilter pipelineFilter, ConnectionOptions options) : base(pipelineFilter, options) { _tcs = new TaskCompletionSource();