@@ -13,8 +13,8 @@ private static async Task Main()
1313 {
1414 Ip = "0.0.0.0" ,
1515 Port = 8080 ,
16- Backlog = 65535 ,
17- ReactorCount = 16 ,
16+ Backlog = 16384 ,
17+ ReactorCount = 64 ,
1818 AcceptorConfig = new AcceptorConfig (
1919 RingFlags : 0 ,
2020 SqCpuThread : - 1 ,
@@ -24,29 +24,21 @@ private static async Task Main()
2424 CqTimeout : 100_000_000 ,
2525 IPVersion : IPVersion . IPv4Only
2626 ) ,
27- ReactorConfigs = Enumerable . Range ( 0 , 16 ) . Select ( _ => new ReactorConfig (
27+ ReactorConfigs = Enumerable . Range ( 0 , 64 ) . Select ( _ => new ReactorConfig (
2828 RingFlags : ( 1u << 12 ) | ( 1u << 13 ) , // SINGLE_ISSUER | DEFER_TASKRUN
2929 SqCpuThread : - 1 ,
3030 SqThreadIdleMs : 100 ,
31- RingEntries : 1 * 1024 ,
31+ RingEntries : 16 * 1024 ,
3232 RecvBufferSize : 1 * 1024 ,
3333 BufferRingEntries : 16 * 1024 ,
3434 BatchCqes : 4096 ,
35- MaxConnectionsPerReactor : 1 * 384 ,
35+ MaxConnectionsPerReactor : 1 * 512 ,
3636 CqTimeout : 1_000_000 ,
37- ConnectionBufferRingEntries : 32 ,
37+ ConnectionBufferRingEntries : 128 ,
3838 IncrementalBufferConsumption : false
3939 ) ) . ToArray ( )
4040 } ,
4141 handler : new EchoHandlerPipelined ( ) ) ;
42-
43- /*
44- await using var server = new Dogrider(
45- ip: "0.0.0.0",
46- port: 8080,
47- reactorCount: Math.Max(1, 16),
48- handler: new EchoHandler());
49- */
5042
5143 server . Start ( ) ;
5244
@@ -67,9 +59,6 @@ private static async Task Main()
6759
6860internal sealed class EchoHandlerPipelined : Handler
6961{
70-
71- private static ReadOnlySpan < byte > _hello => "hello"u8 ;
72-
7362 public async ValueTask HandleAsync ( IConnection connection )
7463 {
7564 while ( true )
@@ -94,14 +83,12 @@ public async ValueTask HandleAsync(IConnection connection)
9483 {
9584 case FrameType . Text :
9685
97- //connection.Write(frame.Data);
98- connection . Write ( _hello ) ;
86+ connection . Write ( frame . Payload . FirstSpan ) ;
9987 break ;
10088
10189 case FrameType . Binary :
10290
103- //connection.Write(frame.Data, FrameType.Binary);
104- connection . Write ( _hello , FrameType . Binary ) ;
91+ connection . Write ( frame . Payload . FirstSpan ) ;
10592 break ;
10693
10794 case FrameType . Ping :
0 commit comments