Class: Mongo::Server::Connection

# File 'lib/mongo/server/connection.rb', line 154

def connected?
  !closed? && !error? && !interrupted? && !!@socket
end

# File 'lib/mongo/server/connection.rb', line 186

def error?
  !!@error
end

# File 'lib/mongo/server/connection.rb', line 140

attr_reader :global_id

# File 'lib/mongo/server/connection.rb', line 136

attr_reader :id

# File 'lib/mongo/server/connection.rb', line 176

def interrupted?
  !!@interrupted
end

# File 'lib/mongo/server/connection.rb', line 130

attr_reader :last_checkin

# File 'lib/mongo/server/connection.rb', line 198

def pinned?
  @pinned
end

# File 'lib/mongo/server/connection.rb', line 146

def connection_pool
  options[:connection_pool]
end

# File 'lib/mongo/server/connection.rb', line 259

private def create_socket(context = nil)
  add_server_diagnostics do
    opts = ssl_options.merge(
      connection_address: address,
      connection_generation: generation,
      pipe: options[:pipe],
      connect_timeout: context&.remaining_timeout_sec,
      csot: !!context&.csot?
    )
    address.socket(socket_timeout, opts)
  end
end

# File 'lib/mongo/server/connection.rb', line 393

def deliver(message, client, options = {})
  handle_errors do
    super
  end
end

# File 'lib/mongo/server/connection.rb', line 311

def disconnect!(options = nil)
  # Note: @closed may be true here but we also may have a socket.
  # Check the socket and not @closed flag.
  @auth_mechanism = nil
  @last_checkin = nil
  if socket
    socket.close rescue nil
    @socket = nil
  end
  @closed = true
  interrupted! if options && options[:interrupted]

  # To satisfy CMAP spec tests, publish close events even if the
  # socket was never connected (and thus the ready event was never
  # published). But track whether we published close event and do not
  # publish it multiple times, unless the socket was reconnected -
  # in that case publish the close event once per socket close.
  unless @close_event_published
    reason = options && options[:reason]
    publish_cmap_event(
      Monitoring::Event::Cmap::ConnectionClosed.new(
        address,
        id,
        reason,
      ),
    )
    @close_event_published = true
  end

  true
end

# File 'lib/mongo/server/connection.rb', line 277

private def do_connect
  raise_if_closed!
  begin
    pending_connection = PendingConnection.new(
      socket, @server, monitoring, options.merge(id: id))
    pending_connection.handshake_and_authenticate!
  rescue Exception
    socket&.close
    @socket = nil
    raise
  end

  [pending_connection.description, pending_connection.compressor]
end

# File 'lib/mongo/server/connection.rb', line 399

def handle_errors
  begin
    yield
  rescue Error::SocketError => e
    @error = e
    @server.unknown!(
      generation: e.generation,
      # or description.service_id?
      service_id: e.service_id,
      stop_push_monitor: true,
    )
    raise
  rescue Error::SocketTimeoutError => e
    @error = e
    raise
  end
end

# File 'lib/mongo/server/connection.rb', line 181

def interrupted!
  @interrupted = true
end

# File 'lib/mongo/server/connection.rb', line 205

def pin
  @pinned = true
end

# File 'lib/mongo/server/connection.rb', line 356

def ping
  bytes = features.op_msg_enabled? ? PING_OP_MSG_BYTES : PING_BYTES
  ensure_connected do |socket|
    reply = add_server_diagnostics do
      socket.write(bytes)
      Protocol::Message.deserialize(socket, max_message_size)
    end
    reply.documents[0][Operation::Result::OK] == 1
  end
end

# File 'lib/mongo/server/connection.rb', line 417

def raise_if_closed!
  if error?
    raise Error::ConnectionPerished, "Connection #{generation}:#{id} for #{address.seed} is perished. Reconnecting closed or errored connections is no longer supported"
  end

  if closed?
    raise Error::ConnectionPerished, "Connection #{generation}:#{id} for #{address.seed} is closed. Reconnecting closed or errored connections is no longer supported"
  end
end

# File 'lib/mongo/server/connection.rb', line 386

def record_checkin!
  @last_checkin = Time.now
  self
end

# File 'lib/mongo/server/connection.rb', line 372

def socket_timeout
  @timeout ||= options[:socket_timeout]
end

# File 'lib/mongo/server/connection.rb', line 376

alias :timeout :socket_timeout

# File 'lib/mongo/server/connection.rb', line 212

def unpin
  @pinned = false
end