@@ -1055,60 +1055,6 @@ public BufferSegment Append(ReadOnlyMemory<byte> memory)
1055
1055
}
1056
1056
}
1057
1057
1058
- [ Fact ]
1059
- [ OuterLoop ( "May take several seconds" ) ]
1060
- public async Task ByteMixingOrNativeAVE_MinimalFailingTest ( )
1061
- {
1062
- const int writeSize = 64 * 1024 ;
1063
- const int NumberOfWrites = 512 ;
1064
- byte [ ] data1 = new byte [ writeSize * NumberOfWrites ] ;
1065
- byte [ ] data2 = new byte [ writeSize * NumberOfWrites ] ;
1066
- Array . Fill ( data1 , ( byte ) 1 ) ;
1067
- Array . Fill ( data2 , ( byte ) 2 ) ;
1068
-
1069
- Task t1 = RunTest ( data1 ) ;
1070
- Task t2 = RunTest ( data2 ) ;
1071
-
1072
- async Task RunTest ( byte [ ] data )
1073
- {
1074
- await RunClientServer (
1075
- iterations : 20 ,
1076
- serverFunction : async connection =>
1077
- {
1078
- await using QuicStream stream = await connection . AcceptInboundStreamAsync ( ) ;
1079
-
1080
- byte [ ] buffer = new byte [ data . Length ] ;
1081
- int bytesRead = await ReadAll ( stream , buffer ) ;
1082
- Assert . Equal ( data . Length , bytesRead ) ;
1083
- AssertExtensions . SequenceEqual ( data , buffer ) ;
1084
-
1085
- for ( int pos = 0 ; pos < data . Length ; pos += writeSize )
1086
- {
1087
- await stream . WriteAsync ( data [ pos ..( pos + writeSize ) ] ) ;
1088
- }
1089
- await stream . WriteAsync ( Memory < byte > . Empty , completeWrites : true ) ;
1090
- } ,
1091
- clientFunction : async connection =>
1092
- {
1093
- await using QuicStream stream = await connection . OpenOutboundStreamAsync ( QuicStreamType . Bidirectional ) ;
1094
-
1095
- for ( int pos = 0 ; pos < data . Length ; pos += writeSize )
1096
- {
1097
- await stream . WriteAsync ( data [ pos ..( pos + writeSize ) ] ) ;
1098
- }
1099
- await stream . WriteAsync ( Memory < byte > . Empty , completeWrites : true ) ;
1100
-
1101
- byte [ ] buffer = new byte [ data . Length ] ;
1102
- int bytesRead = await ReadAll ( stream , buffer ) ;
1103
- Assert . Equal ( data . Length , bytesRead ) ;
1104
- AssertExtensions . SequenceEqual ( data , buffer ) ;
1105
- }
1106
- ) ;
1107
- }
1108
-
1109
- await ( new [ ] { t1 , t2 } ) . WhenAllOrAnyFailed ( millisecondsTimeout : 1000000 ) ;
1110
- }
1111
-
1112
1058
[ Fact ]
1113
1059
public async Task ManagedAVE_MinimalFailingTest ( )
1114
1060
{
0 commit comments