1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
|
---
description: connectTimeoutMS
schemaVersion: "1.10"
runOnRequirements:
# failCommand appName requirements
- minServerVersion: "4.4"
serverless: forbid
topologies: [ single, replicaset, sharded ]
createEntities:
- client:
id: &setupClient setupClient
useMultipleMongoses: false
initialData: &initialData
- collectionName: &collectionName connectTimeoutMS
databaseName: &databaseName sdam-tests
documents: []
tests:
- description: connectTimeoutMS=0
operations:
- name: createEntities
object: testRunner
arguments:
entities:
- client:
id: &client client
observeEvents:
- commandStartedEvent
- serverDescriptionChangedEvent
- poolClearedEvent
uriOptions:
retryWrites: false
connectTimeoutMS: 0
heartbeatFrequencyMS: 500
appname: connectTimeoutMS=0
useMultipleMongoses: false
- database:
id: &database database
client: *client
databaseName: *databaseName
- collection:
id: &collection collection
database: *database
collectionName: *collectionName
# Perform an operation to ensure the node is discovered.
- name: insertMany
object: *collection
arguments:
documents:
- _id: 1
- _id: 2
# Block the next streaming hello check for longer than
# heartbeatFrequencyMS to ensure that the connection timeout remains
# unlimited.
- name: failPoint
object: testRunner
arguments:
failPoint:
configureFailPoint: failCommand
mode:
times: 2
data:
failCommands:
- hello
- isMaster
appName: connectTimeoutMS=0
blockConnection: true
blockTimeMS: 550
client: *setupClient
- name: wait
object: testRunner
arguments:
ms: 750
# Perform an operation to ensure the node is still selectable.
- name: insertMany
object: *collection
arguments:
documents:
- _id: 3
- _id: 4
# Assert that the server was never marked Unknown and the pool was never
# cleared.
- name: assertEventCount
object: testRunner
arguments:
client: *client
event:
serverDescriptionChangedEvent:
newDescription:
type: Unknown
count: 0
- name: assertEventCount
object: testRunner
arguments:
client: *client
event:
poolClearedEvent: {}
count: 0
expectEvents:
- client: *client
eventType: command
events:
- commandStartedEvent:
command:
insert: connectTimeoutMS
documents:
- _id: 1
- _id: 2
commandName: insert
databaseName: *databaseName
- commandStartedEvent:
command:
insert: connectTimeoutMS
documents:
- _id: 3
- _id: 4
commandName: insert
databaseName: *databaseName
outcome:
- collectionName: *collectionName
databaseName: *databaseName
documents:
- _id: 1
- _id: 2
- _id: 3
- _id: 4
|
