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
|
# Copyright (C) 2015-2017 MongoDB, Inc.
# Licensed under the Apache License, Version 2.0 (the "License");
# you may not use this file except in compliance with the License.
# You may obtain a copy of the License at
# http://www.apache.org/licenses/LICENSE-2.0
# Unless required by applicable law or agreed to in writing, software
# distributed under the License is distributed on an "AS IS" BASIS,
# WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
# See the License for the specific language governing permissions and
# limitations under the License.
module Mongo
class Server
# This provides common behaviour for connection objects.
#
# @since 2.0.0
module Connectable
# The ssl option prefix.
#
# @since 2.1.0
SSL = 'ssl'.freeze
# The default time in seconds to timeout an operation executed on a socket.
#
# @since 2.0.0
#
# @deprecated Timeouts on Ruby sockets aren't effective so this default option is
# no longer used.
# Will be removed in driver version 3.0.
TIMEOUT = 5.freeze
# @return [ Mongo::Address ] address The address to connect to.
attr_reader :address
# @return [ Hash ] options The passed in options.
attr_reader :options
# @return [ Integer ] pid The process id when the connection was created.
attr_reader :pid
# Determine if the server is connectable. This will check not only if the
# connection exists, but if messages can send to it successfully.
#
# @example Is the server connectable?
# connection.connectable?
#
# @return [ true, false ] If the connection is connectable.
#
# @since 2.1.0
def connectable?
begin; ping; rescue; false; end
end
# Determine if the connection is currently connected.
#
# @example Is the connection connected?
# connection.connected?
#
# @return [ true, false ] If connected.
#
# @deprecated Use #connectable? instead
def connected?
!!@socket && @socket.alive?
end
protected
attr_reader :socket
private
def ssl_options
@ssl_options[:ssl] == true ? @ssl_options : {}
end
def ensure_connected
ensure_same_process!
begin
connect!
result = yield socket
success = true
result
ensure
success or disconnect!
end
end
def ensure_same_process!
if pid != Process.pid
disconnect!
@pid = Process.pid
end
end
def read(request_id = nil)
ensure_connected do |socket|
Protocol::Message.deserialize(socket, max_message_size, request_id)
end
end
end
end
end
|
