@@ -1204,61 +1204,6 @@ public BufferSegment Append(ReadOnlyMemory<byte> memory)
1204
1204
}
1205
1205
}
1206
1206
1207
- [ Fact ]
1208
- [ OuterLoop ( "May take several seconds" ) ]
1209
- [ ActiveIssue ( "https://github.com/dotnet/runtime/issues/85331" , typeof ( PlatformDetection ) , nameof ( PlatformDetection . IsWindows10Version20348OrLower ) ) ]
1210
- public async Task ByteMixingOrNativeAVE_MinimalFailingTest ( )
1211
- {
1212
- const int writeSize = 64 * 1024 ;
1213
- const int NumberOfWrites = 512 ;
1214
- byte [ ] data1 = new byte [ writeSize * NumberOfWrites ] ;
1215
- byte [ ] data2 = new byte [ writeSize * NumberOfWrites ] ;
1216
- Array . Fill ( data1 , ( byte ) 1 ) ;
1217
- Array . Fill ( data2 , ( byte ) 2 ) ;
1218
-
1219
- Task t1 = RunTest ( data1 ) ;
1220
- Task t2 = RunTest ( data2 ) ;
1221
-
1222
- async Task RunTest ( byte [ ] data )
1223
- {
1224
- await RunClientServer (
1225
- iterations : 20 ,
1226
- serverFunction : async connection =>
1227
- {
1228
- await using QuicStream stream = await connection . AcceptInboundStreamAsync ( ) ;
1229
-
1230
- byte [ ] buffer = new byte [ data . Length ] ;
1231
- int bytesRead = await ReadAll ( stream , buffer ) ;
1232
- Assert . Equal ( data . Length , bytesRead ) ;
1233
- AssertExtensions . SequenceEqual ( data , buffer ) ;
1234
-
1235
- for ( int pos = 0 ; pos < data . Length ; pos += writeSize )
1236
- {
1237
- await stream . WriteAsync ( data [ pos ..( pos + writeSize ) ] ) ;
1238
- }
1239
- await stream . WriteAsync ( Memory < byte > . Empty , completeWrites : true ) ;
1240
- } ,
1241
- clientFunction : async connection =>
1242
- {
1243
- await using QuicStream stream = await connection . OpenOutboundStreamAsync ( QuicStreamType . Bidirectional ) ;
1244
-
1245
- for ( int pos = 0 ; pos < data . Length ; pos += writeSize )
1246
- {
1247
- await stream . WriteAsync ( data [ pos ..( pos + writeSize ) ] ) ;
1248
- }
1249
- await stream . WriteAsync ( Memory < byte > . Empty , completeWrites : true ) ;
1250
-
1251
- byte [ ] buffer = new byte [ data . Length ] ;
1252
- int bytesRead = await ReadAll ( stream , buffer ) ;
1253
- Assert . Equal ( data . Length , bytesRead ) ;
1254
- AssertExtensions . SequenceEqual ( data , buffer ) ;
1255
- }
1256
- ) ;
1257
- }
1258
-
1259
- await ( new [ ] { t1 , t2 } ) . WhenAllOrAnyFailed ( millisecondsTimeout : 1000000 ) ;
1260
- }
1261
-
1262
1207
[ Fact ]
1263
1208
public async Task ManagedAVE_MinimalFailingTest ( )
1264
1209
{
0 commit comments