@@ -67,12 +67,12 @@ tests:
67
67
data :
68
68
failCommands : ["aggregate"]
69
69
blockConnection : true
70
- blockTimeMS : 55
70
+ blockTimeMS : 250
71
71
- name : createChangeStream
72
72
object : *collection
73
73
arguments :
74
74
pipeline : []
75
- timeoutMS : 50
75
+ timeoutMS : 200
76
76
expectError :
77
77
isTimeoutError : true
78
78
expectEvents :
@@ -142,12 +142,12 @@ tests:
142
142
data :
143
143
failCommands : ["aggregate", "getMore"]
144
144
blockConnection : true
145
- blockTimeMS : 15
145
+ blockTimeMS : 150
146
146
- name : createChangeStream
147
147
object : *collection
148
148
arguments :
149
149
pipeline : []
150
- timeoutMS : 20
150
+ timeoutMS : 200
151
151
batchSize : 2
152
152
maxAwaitTimeMS : 1
153
153
saveResultAsEntity : &changeStream changeStream
@@ -171,16 +171,16 @@ tests:
171
171
maxTimeMS : 1
172
172
173
173
# The timeout should be applied to the entire resume attempt, not individually to each command. The test creates a
174
- # change stream with timeoutMS=20 which returns an empty initial batch and then sets a fail point to block both
175
- # getMore and aggregate for 12ms each and fail with a resumable error. When the resume attempt happens, the getMore
176
- # and aggregate block for longer than 20ms total, so it times out.
174
+ # change stream with timeoutMS=200 which returns an empty initial batch and then sets a fail point to block both
175
+ # getMore and aggregate for 120ms each and fail with a resumable error. When the resume attempt happens, the getMore
176
+ # and aggregate block for longer than 200ms total, so it times out.
177
177
- description : " timeoutMS applies to full resume attempt in a next call"
178
178
operations :
179
179
- name : createChangeStream
180
180
object : *collection
181
181
arguments :
182
182
pipeline : []
183
- timeoutMS : 20
183
+ timeoutMS : 200
184
184
saveResultAsEntity : &changeStream changeStream
185
185
- name : failPoint
186
186
object : testRunner
@@ -192,7 +192,7 @@ tests:
192
192
data :
193
193
failCommands : ["getMore", "aggregate"]
194
194
blockConnection : true
195
- blockTimeMS : 12
195
+ blockTimeMS : 120
196
196
errorCode : 7 # HostNotFound - resumable but does not require an SDAM state change.
197
197
# failCommand doesn't correctly add the ResumableChangeStreamError by default. It needs to be specified
198
198
# manually here so the error is considered resumable. The failGetMoreAfterCursorCheckout fail point
@@ -234,9 +234,9 @@ tests:
234
234
# Specify a short maxAwaitTimeMS because otherwise the getMore on the new cursor will wait for 1000ms and
235
235
# time out.
236
236
maxAwaitTimeMS : 1
237
- timeoutMS : 100
237
+ timeoutMS : 200
238
238
saveResultAsEntity : &changeStream changeStream
239
- # Block getMore for 150ms to force the next() call to time out.
239
+ # Block getMore for 250ms to force the next() call to time out.
240
240
- name : failPoint
241
241
object : testRunner
242
242
arguments :
@@ -247,7 +247,7 @@ tests:
247
247
data :
248
248
failCommands : ["getMore"]
249
249
blockConnection : true
250
- blockTimeMS : 150
250
+ blockTimeMS : 250
251
251
# The original aggregate didn't return any events so this should do a getMore and return a timeout error.
252
252
- name : iterateUntilDocumentOrError
253
253
object : *changeStream
@@ -290,7 +290,7 @@ tests:
290
290
collection : *collectionName
291
291
292
292
# The timeoutMS value should be refreshed for getMore's. This is a failure test. The createChangeStream operation
293
- # sets timeoutMS=10 and the getMore blocks for 15ms , causing iteration to fail with a timeout error.
293
+ # sets timeoutMS=200 and the getMore blocks for 250ms , causing iteration to fail with a timeout error.
294
294
- description : " timeoutMS is refreshed for getMore - failure"
295
295
operations :
296
296
- name : failPoint
@@ -303,12 +303,12 @@ tests:
303
303
data :
304
304
failCommands : ["getMore"]
305
305
blockConnection : true
306
- blockTimeMS : 15
306
+ blockTimeMS : 250
307
307
- name : createChangeStream
308
308
object : *collection
309
309
arguments :
310
310
pipeline : []
311
- timeoutMS : 10
311
+ timeoutMS : 200
312
312
saveResultAsEntity : &changeStream changeStream
313
313
# The first iteration should do a getMore
314
314
- name : iterateUntilDocumentOrError
0 commit comments