Class: Mongo::Socket Private

Inherits:
Object
  • Object
show all
Includes:
Socket::Constants
Defined in:
lib/mongo/socket.rb,
lib/mongo/socket/ssl.rb,
lib/mongo/socket/tcp.rb,
lib/mongo/socket/unix.rb

Overview

This class is part of a private API. You should avoid using this class if possible, as it may be removed or be changed in the future.

Provides additional data around sockets for the driver’s use.

Since:

  • 2.0.0

Direct Known Subclasses

SSL, TCP, Unix

Defined Under Namespace

Classes: SSL, TCP, Unix

Constant Summary collapse

SSL_ERROR =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

Error message for SSL related exceptions.

Since:

  • 2.0.0

'MongoDB may not be configured with SSL support'.freeze
TIMEOUT_ERROR =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

Deprecated.

Error message for timeouts on socket calls.

Since:

  • 2.0.0

'Socket request timed out'.freeze
TIMEOUT_PACK =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

The pack directive for timeouts.

Since:

  • 2.0.0

'l_2'.freeze
WRITE_CHUNK_SIZE =

This constant is part of a private API. You should avoid using this constant if possible, as it may be removed or be changed in the future.

Write data to the socket in chunks of this size.

Since:

  • 2.0.0

65536

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(timeout, options) ⇒ Socket

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Initializes common socket attributes.

Parameters:

  • timeout (Float) —

    The socket timeout value.

  • options (Hash) —

    The options.

Options Hash (options):

  • :connect_timeout (Float) —

    Connect timeout.

  • :connection_address (Address) —

    Address of the connection that created this socket.

  • :connection_generation (Integer) —

    Generation of the connection (for non-monitoring connections) that created this socket.

  • :monitor (true | false) —

    Whether this socket was created by a monitoring connection.

Since:

  • 2.0.0



63
64
65
66
 
# File 'lib/mongo/socket.rb', line 63

def initialize(timeout, options)
  @timeout = timeout
  @options = options
end

Instance Attribute Details

#family ⇒ Integer (readonly)

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns family The type of host family.

Returns:

  • (Integer) —

    family The type of host family.

Since:

  • 2.0.0



69
70
71
 
# File 'lib/mongo/socket.rb', line 69

def family
  @family
end

#options ⇒ Hash (readonly)

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns The options.

Returns:

  • (Hash) —

    The options.

Since:

  • 2.0.0



75
76
77
 
# File 'lib/mongo/socket.rb', line 75

def options
  @options
end

#socket ⇒ Socket (readonly)

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns socket The wrapped socket.

Returns:

  • (Socket) —

    socket The wrapped socket.

Since:

  • 2.0.0



72
73
74
 
# File 'lib/mongo/socket.rb', line 72

def socket
  @socket
end

#timeout ⇒ Float (readonly)

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns timeout The socket timeout.

Returns:

  • (Float) —

    timeout The socket timeout.

Since:

  • 2.0.0



78
79
80
 
# File 'lib/mongo/socket.rb', line 78

def timeout
  @timeout
end

Instance Method Details

#alive? ⇒ true, false

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Deprecated.

Use #connectable? on the connection instead.

Is the socket connection alive?

Examples:

Is the socket alive?

socket.alive?

Returns:

  • (true, false) —

    If the socket is alive.

Since:

  • 2.0.0



128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
 
# File 'lib/mongo/socket.rb', line 128

def alive?
  sock_arr = [ @socket ]
  if Kernel::select(sock_arr, nil, sock_arr, 0)
    # The eof? call is supposed to return immediately since select
    # indicated the socket is readable. However, if @socket is an SSL
    # socket, eof? can block anyway - see RUBY-2140.
    begin
      Timeout.timeout(0.1) do
        eof?
      end
    rescue ::Timeout::Error
      true
    end
  else
    true
  end
end

#close ⇒ true

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Close the socket.

Examples:

Close the socket.

socket.close

Returns:

  • (true) —

    Always true.

Since:

  • 2.0.0



154
155
156
157
 
# File 'lib/mongo/socket.rb', line 154

def close
  @socket.close rescue nil
  true
end

#connectable? ⇒ true

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Deprecated.

For backwards compatibilty only, do not use.

Returns:

  • (true) —

    Always true.

Since:

  • 2.0.0



247
248
249
 
# File 'lib/mongo/socket.rb', line 247

def connectable?
  true
end

#connection_address ⇒ Address

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns Address of the connection that created this socket.

Returns:

  • (Address) —

    Address of the connection that created this socket.

Since:

  • 2.0.0



83
84
85
 
# File 'lib/mongo/socket.rb', line 83

def connection_address
  options[:connection_address]
end

#connection_generation ⇒ Integer

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns Generation of the connection (for non-monitoring connections) that created this socket.

Returns:

  • (Integer) —

    Generation of the connection (for non-monitoring connections) that created this socket.

Since:

  • 2.0.0



91
92
93
 
# File 'lib/mongo/socket.rb', line 91

def connection_generation
  options[:connection_generation]
end

#eof? ⇒ Boolean

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Tests if this socket has reached EOF. Primarily used for liveness checks.

Returns:

  • (Boolean)

Since:

  • 2.0.5



236
237
238
239
240
 
# File 'lib/mongo/socket.rb', line 236

def eof?
  @socket.eof?
rescue IOError, SystemCallError
  true
end

#gets(*args) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Delegates gets to the underlying socket.

Examples:

Get the next line.

socket.gets(10)

Parameters:

  • args (Array<Object>) —

    The arguments to pass through.

Returns:

  • (Object) —

    The returned bytes.

Since:

  • 2.0.0



169
170
171
172
173
 
# File 'lib/mongo/socket.rb', line 169

def gets(*args)
  map_exceptions do
    @socket.gets(*args)
  end
end

#monitor? ⇒ true | false

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns Whether this socket was created by a monitoring connection.

Returns:

  • (true | false) —

    Whether this socket was created by a monitoring connection.

Since:

  • 2.0.0



99
100
101
 
# File 'lib/mongo/socket.rb', line 99

def monitor?
  !!options[:monitor]
end

#read(length, timeout: nil) ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Will read all data from the socket for the provided number of bytes. If no data is returned, an exception will be raised.

Examples:

Read all the requested data from the socket.

socket.read(4096)

Parameters:

  • length (Integer) —

    The number of bytes to read.

  • timeout (Numeric) (defaults to: nil) —

    The timeout to use for each chunk read.

Returns:

  • (Object) —

    The data from the socket.

Raises:

  • (Mongo::SocketError) —

    If not all data is returned.

Since:

  • 2.0.0



189
190
191
192
193
194
195
196
197
198
199
200
201
202
203
204
 
# File 'lib/mongo/socket.rb', line 189

def read(length, timeout: nil)
  map_exceptions do
    data = read_from_socket(length, timeout: timeout)
    unless (data.length > 0 || length == 0)
      raise IOError, "Expected to read > 0 bytes but read 0 bytes"
    end
    while data.length < length
      chunk = read_from_socket(length - data.length, timeout: timeout)
      unless (chunk.length > 0 || length == 0)
        raise IOError, "Expected to read > 0 bytes but read 0 bytes"
      end
      data << chunk
    end
    data
  end
end

#readbyte ⇒ Object

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Read a single byte from the socket.

Examples:

Read a single byte.

socket.readbyte

Returns:

  • (Object) —

    The read byte.

Since:

  • 2.0.0



214
215
216
217
218
 
# File 'lib/mongo/socket.rb', line 214

def readbyte
  map_exceptions do
    @socket.readbyte
  end
end

#summary ⇒ String

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Returns Human-readable summary of the socket for debugging.

Returns:

  • (String) —

    Human-readable summary of the socket for debugging.

Since:

  • 2.0.0



106
107
108
109
110
111
112
113
114
115
116
117
118
 
# File 'lib/mongo/socket.rb', line 106

def summary
  fileno = @socket&.fileno rescue '<no socket>' || '<no socket>'
  if monitor?
    indicator = if options[:push]
      'pm'
    else
      'm'
    end
    "#{connection_address};#{indicator};fd=#{fileno}"
  else
    "#{connection_address};c:#{connection_generation};fd=#{fileno}"
  end
end

#write(*args) ⇒ Integer

This method is part of a private API. You should avoid using this method if possible, as it may be removed or be changed in the future.

Writes data to the socket instance.

Parameters:

  • args (Array<Object>) —

    The data to be written.

Returns:

  • (Integer) —

    The length of bytes written to the socket.

Since:

  • 2.0.0



227
228
229
230
231
 
# File 'lib/mongo/socket.rb', line 227

def write(*args)
  map_exceptions do
    do_write(*args)
  end
end