@@ -587,7 +587,7 @@ describe('CSOT driver tests', metadata, () => {
587
587
data : {
588
588
failCommands : [ 'aggregate' , 'find' ] ,
589
589
blockConnection : true ,
590
- blockTimeMS : 50
590
+ blockTimeMS : 100
591
591
}
592
592
} ;
593
593
@@ -636,7 +636,7 @@ describe('CSOT driver tests', metadata, () => {
636
636
cursor = client
637
637
. db ( 'db' )
638
638
. collection ( 'coll' )
639
- . find ( { } , { timeoutMS : 30 , tailable : true , awaitData : true , batchSize : 1 } ) ;
639
+ . find ( { } , { timeoutMS : 50 , tailable : true , awaitData : true , batchSize : 1 } ) ;
640
640
const maybeError = await cursor . next ( ) . then (
641
641
( ) => null ,
642
642
e => e
@@ -648,9 +648,9 @@ describe('CSOT driver tests', metadata, () => {
648
648
cursor = client
649
649
. db ( 'db' )
650
650
. collection ( 'coll' )
651
- . find ( { } , { timeoutMS : 100 , tailable : true , awaitData : true , batchSize : 1 } ) ;
651
+ . find ( { } , { timeoutMS : 150 , tailable : true , awaitData : true , batchSize : 1 } ) ;
652
652
for ( let i = 0 ; i < 5 ; i ++ ) {
653
- // Iterate cursor 5 times (server would have blocked for 250ms overall, but client
653
+ // Iterate cursor 5 times (server would have blocked for 500ms overall, but client
654
654
// should not throw
655
655
await cursor . next ( ) ;
656
656
}
@@ -711,7 +711,7 @@ describe('CSOT driver tests', metadata, () => {
711
711
cursor = client
712
712
. db ( 'db' )
713
713
. collection ( 'coll' )
714
- . find ( { } , { timeoutMS : 30 , tailable : true , batchSize : 1 } ) ;
714
+ . find ( { } , { timeoutMS : 50 , tailable : true , batchSize : 1 } ) ;
715
715
const maybeError = await cursor . next ( ) . then (
716
716
( ) => null ,
717
717
e => e
@@ -723,9 +723,9 @@ describe('CSOT driver tests', metadata, () => {
723
723
cursor = client
724
724
. db ( 'db' )
725
725
. collection ( 'coll' )
726
- . find ( { } , { timeoutMS : 100 , tailable : true , batchSize : 1 } ) ;
726
+ . find ( { } , { timeoutMS : 150 , tailable : true , batchSize : 1 } ) ;
727
727
for ( let i = 0 ; i < 5 ; i ++ ) {
728
- // Iterate cursor 5 times (server would have blocked for 250ms overall, but client
728
+ // Iterate cursor 5 times (server would have blocked for 500ms overall, but client
729
729
// should not throw
730
730
await cursor . next ( ) ;
731
731
}
0 commit comments