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
|
# frozen_string_literal: true
require 'spec_helper'
describe Mongo::Server::ConnectionPool::GenerationManager do
describe '#close_all_pipes' do
let(:service_id) { 'test_service_id' }
let(:server) { instance_double(Mongo::Server) }
let(:manager) { described_class.new(server: server) }
before do
manager.pipe_fds(service_id: service_id)
end
it 'closes all pipes and removes them from the map' do
expect(manager.pipe_fds(service_id: service_id).size).to eq(2)
manager.instance_variable_get(:@pipe_fds)[service_id].each do |_gen, (r, w)|
expect(r).to receive(:close).and_call_original
expect(w).to receive(:close).and_call_original
end
manager.close_all_pipes
expect(manager.instance_variable_get(:@pipe_fds)).to be_empty
end
end
end
|
