@@ -395,40 +395,40 @@ public void Does_throw_TimeoutException_when_PoolTimeout_exceeded()
395
395
}
396
396
}
397
397
398
- [ Explicit , Ignore ( "tempromental integration test" ) ]
399
- [ Test ]
400
- public void Can_support_64_threads_using_the_client_simultaneously ( )
401
- {
402
- const int noOfConcurrentClients = 64 ; //WaitHandle.WaitAll limit is <= 64
403
- var clientUsageMap = new Dictionary < string , int > ( ) ;
404
-
405
- var clientAsyncResults = new List < IAsyncResult > ( ) ;
406
- using ( var manager = CreateAndStartManager ( ) )
407
- {
408
- for ( var i = 0 ; i < noOfConcurrentClients ; i ++ )
409
- {
410
- var clientNo = i ;
411
- var action = ( Action ) ( ( ) => UseClient ( manager , clientNo , clientUsageMap ) ) ;
412
- clientAsyncResults . Add ( action . BeginInvoke ( null , null ) ) ;
413
- }
414
- }
415
-
416
- WaitHandle . WaitAll ( clientAsyncResults . ConvertAll ( x => x . AsyncWaitHandle ) . ToArray ( ) ) ;
417
-
418
- RedisStats . ToDictionary ( ) . PrintDump ( ) ;
419
-
420
- Debug . WriteLine ( TypeSerializer . SerializeToString ( clientUsageMap ) ) ;
421
-
422
- var hostCount = 0 ;
423
- foreach ( var entry in clientUsageMap )
424
- {
425
- Assert . That ( entry . Value , Is . GreaterThanOrEqualTo ( 2 ) , "Host has unproportianate distribution: " + entry . Value ) ;
426
- Assert . That ( entry . Value , Is . LessThanOrEqualTo ( 30 ) , "Host has unproportianate distribution: " + entry . Value ) ;
427
- hostCount += entry . Value ;
428
- }
429
-
430
- Assert . That ( hostCount , Is . EqualTo ( noOfConcurrentClients ) , "Invalid no of clients used" ) ;
431
- }
398
+ // [Explicit,Ignore("tempromental integration test")]
399
+ // [Test]
400
+ // public void Can_support_64_threads_using_the_client_simultaneously()
401
+ // {
402
+ // const int noOfConcurrentClients = 64; //WaitHandle.WaitAll limit is <= 64
403
+ // var clientUsageMap = new Dictionary<string, int>();
404
+
405
+ // var clientAsyncResults = new List<IAsyncResult>();
406
+ // using (var manager = CreateAndStartManager())
407
+ // {
408
+ // for (var i = 0; i < noOfConcurrentClients; i++)
409
+ // {
410
+ // var clientNo = i;
411
+ // var action = (Action)(() => UseClient(manager, clientNo, clientUsageMap));
412
+ // clientAsyncResults.Add(action.BeginInvoke(null, null));
413
+ // }
414
+ // }
415
+
416
+ // WaitHandle.WaitAll(clientAsyncResults.ConvertAll(x => x.AsyncWaitHandle).ToArray());
417
+
418
+ // RedisStats.ToDictionary().PrintDump();
419
+
420
+ // Debug.WriteLine(TypeSerializer.SerializeToString(clientUsageMap));
421
+
422
+ // var hostCount = 0;
423
+ // foreach (var entry in clientUsageMap)
424
+ // {
425
+ // Assert.That(entry.Value, Is.GreaterThanOrEqualTo(2), "Host has unproportianate distribution: " + entry.Value);
426
+ // Assert.That(entry.Value, Is.LessThanOrEqualTo(30), "Host has unproportianate distribution: " + entry.Value);
427
+ // hostCount += entry.Value;
428
+ // }
429
+
430
+ // Assert.That(hostCount, Is.EqualTo(noOfConcurrentClients), "Invalid no of clients used");
431
+ // }
432
432
433
433
private static void UseClient ( IRedisClientsManager manager , int clientNo , Dictionary < string , int > hostCountMap )
434
434
{
0 commit comments