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
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
|
# frozen_string_literal: true
# rubocop:todo all
require 'spec_helper'
describe 'Connection pool timing test' do
require_stress
clean_slate_for_all
before(:all) do
# This set up is taken from the step_down_spec file. In a future PR, ClusterTools
# may be modified so this set up is no longer necessary.
if ClusterConfig.instance.fcv_ish >= '4.2' && ClusterConfig.instance.topology == :replica_set
ClusterTools.instance.set_election_timeout(5)
ClusterTools.instance.set_election_handoff(false)
end
end
after(:all) do
if ClusterConfig.instance.fcv_ish >= '4.2' && ClusterConfig.instance.topology == :replica_set
ClusterTools.instance.set_election_timeout(10)
ClusterTools.instance.set_election_handoff(true)
ClusterTools.instance.reset_priorities
end
end
let(:client) do
authorized_client.with(options.merge(monitoring_io: true))
end
let!(:collection) do
client[authorized_collection.name].tap do |collection|
collection.drop
collection.insert_many(documents)
end
end
let(:documents) do
[].tap do |documents|
10000.times do |i|
documents << { a: i}
end
end
end
let(:operation_threads) do
[].tap do |threads|
thread_count.times do |i|
threads << Thread.new do
100.times do |j|
collection.find(a: i+j).to_a
sleep 0.01
collection.find(a: i+j).to_a
end
end
end
end
end
let(:thread_count) { 5 }
context 'when there is no max idle time' do
let(:options) do
{ max_pool_size: 10, min_pool_size: 5 }
end
let(:threads) { operation_threads }
it 'does not error' do
start = Mongo::Utils.monotonic_time
expect {
threads.collect { |t| t.join }
}.not_to raise_error
puts "[Connection Pool Timing] Duration with no max idle time: #{Mongo::Utils.monotonic_time - start}"
end
end
context 'when there is a low max idle time' do
let(:options) do
{ max_pool_size: 10, min_pool_size: 5, max_idle_time: 0.1 }
end
let(:threads) { operation_threads }
it 'does not error' do
start = Mongo::Utils.monotonic_time
expect {
threads.collect { |t| t.join }
}.not_to raise_error
puts "[Connection Pool Timing] Duration with low max idle time: #{Mongo::Utils.monotonic_time - start}"
end
end
context 'when primary is changed, then more operations are performed' do
min_server_fcv '4.2'
require_topology :replica_set
let(:options) do
{ max_pool_size: 10, min_pool_size: 5 }
end
let(:more_threads) do
PossiblyConcurrentArray.new.tap do |more_threads|
5.times do |i|
more_threads << Thread.new do
10.times do |j|
collection.find(a: i+j).to_a
sleep 0.01
collection.find(a: i+j).to_a
end
end
end
end
end
let(:threads) do
threads = PossiblyConcurrentArray.new
5.times do |i|
threads << Thread.new do
10.times do |j|
collection.find(a: i+j).to_a
sleep 0.01
collection.find(a: i+j).to_a
end
end
end
threads << Thread.new do
# Wait for other threads to terminate first, otherwise we get an error
# when trying to perform operations during primary change
sleep 1
@primary_change_start = Mongo::Utils.monotonic_time
ClusterTools.instance.change_primary
@primary_change_end = Mongo::Utils.monotonic_time
# Primary change is complete; execute more operations
more_threads.collect { |t| t.join }
end
threads
end
# On JRuby, sometimes the following error is produced indicating
# possible data corruption or an interpreter bug:
# RSpec::Expectations::ExpectationNotMetError: expected no Exception, got #<Mongo::Error::OperationFailure: Invalid ns [ruby-driver.] (73) (on localhost:27018, modern retry, attempt 1) (on localhost:27018, modern retry, attempt 1)>
retry_test tries: (BSON::Environment.jruby? ? 3 : 1)
it 'does not error' do
threads
start = Mongo::Utils.monotonic_time
expect do
threads.each do |t|
t.join
end
end.not_to raise_error
puts "[Connection Pool Timing] Duration before primary change: #{@primary_change_start - start}. "\
"Duration after primary change: #{Mongo::Utils.monotonic_time - @primary_change_end}"
end
end
end
|
