Classe: Mongo::Socket::TCP Private

Herda:
Soquete
  • Objeto
mostrar tudo
Definido em:
lib/mongo/socket/tcp.rb

Visão geral

Esta classe faz parte de uma API privada. Evite usar essa classe, se possível, pois ela pode ser removida ou alterada no futuro.

Encapsulador para soquetes TCP.

Desde:

  • 2.0.0

Recolhimento do Resumo do atributo de instância

Recolhimento do Resumo do método de instância

Detalhes do construtor

#inicializar(host, porta, tempo limite, família, opções = {}) ➤ TCP

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Inicia um novo soquete TCP.

Exemplos:

Crie o soquete TCP.

TCP.new('::1', 27017, 30, Socket::PF_INET)
TCP.new('127.0.0.1', 27017, 30, Socket::PF_INET)

Parâmetros:

  • Anfitrião (string) —

    O nome do host ou endereço IP.

  • Porta (Inteiro) —

    O número da porta.

  • timeout (Flutuante) —

    O valor de tempo limite do soquete.

  • família (Inteiro) —

    A família do soquete.

  • opções (Hash) (padrão para: {}) —

    As opções.

Hash de opções (opções):

  • :connect_timeout (Flutuante) —

    Tempo limite de conexão.

  • :connection_address (Endereço) —

    Endereço da conexão que criou este soquete.

  • :connection_generação (Inteiro) —

    Geração da conexão (para conexões não monitoradas) que criou esse soquete.

  • :monitor (verdadeiro | falso) —

    Se esse soquete foi criado por uma conexão de monitoramento.

Aumenta:

  • (ArgumentError)

Desde:

  • 2.0.0



45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
 
# Arquivo 'lib/mongo/socket/tcp.rb', linha 45

def inicializar(Anfitrião, Porta, timeout, família, opções = {})
  aumentar ArgumentError, ' afamília deve ser especificada' se família.nada?

  super(timeout, opções)
  @host, @port = Anfitrião, Porta
  @family = família
  @socket = ::Soquete.Novo(família, SOCK_STREAM, 0)
  começar
    set_socket_options(@socket)
    Conecte-se!
  salvar StandardError
    @socket.Fechar
    aumentar
  end
end

Detalhes do atributo da instância

#host ➤ string (somente leitura)

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Retorna host O host ao qual se conectar.

Retorna:

  • (string) —

    host O host ao qual se conectar.

Desde:

  • 2.0.0



62
63
64
 
# Arquivo 'lib/mongo/socket/tcp.rb', linha 62

def Anfitrião
  @host
end

#porta ➤ inteiro (somente leitura)

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Retorna porta A porta à qual se conectar.

Retorna:

  • (Inteiro) —

    porta A porta à qual se conectar.

Desde:

  • 2.0.0



65
66
67
 
# Arquivo 'lib/mongo/socket/tcp.rb', linha 65

def Porta
  @port
end

Detalhes do método de instância

#connect! ➤ TCP

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Observação:

Este método muta o objeto definindo o soquete internamente.

Estabelece uma conexão de soquete.

Exemplos:

Conecte o soquete.

sock.connect!

Retorna:

  • (TCP) —

    A instância do soquete conectado.

Desde:

  • 2.0.0



79
80
81
82
83
84
85
86
87
88
89
90
91
 
# Arquivo 'lib/mongo/socket/tcp.rb', linha 79

def Conecte-se!
  soquete.setsockopt(IPPROTO_TCP, TCP_NODELEY, 1)
  sockaddr = ::Soquete.pack_sockaddr_in(Porta, Anfitrião)
  connect_timeout = opções[:connect_timeout]
  map_Exceptions fazer
    se connect_timeout && connect_timeout != 0
      connect_with_timeout(sockaddr, connect_timeout)
    mais
      connect_without_timeout(sockaddr)
    end
  end
  auto
end

#connect_with_timeout(sockaddr, connect_timeout) ➤ Objeto

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Desde:

  • 2.0.0



99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
 
# Arquivo 'lib/mongo/socket/tcp.rb', linha 99

def connect_with_timeout(sockaddr, connect_timeout)
  se connect_timeout <= 0
    aumentar Erro::SocketTimeoutError, "O soquete levou mais de #{connect_timeout} segundos para conectar"
  end

  prazo = Utilidades.monotonic_time + connect_timeout
  começar
    soquete.connect_nonblock(sockaddr)
  salvar IO::WaitWritable
    select_timeout = prazo - Utilidades.monotonic_time
    se select_timeout <= 0
      aumentar Erro::SocketTimeoutError, "O soquete levou mais de #{connect_timeout} segundos para conectar"
    end

    se IO.selecione(nada, [ soquete ], nada, select_timeout)
      tentar novamente
    mais
      soquete.Fechar
      aumentar Erro::SocketTimeoutError, "O soquete levou mais de #{connect_timeout} segundos para conectar"
    end
  salvar Errno::EISCONN
    # O soquete está conectado, nada mais a fazer
  end
end

#connect_without_timeout(sockaddr) ➤ Objeto

Este método faz parte de uma API privada. Evite usar esse método, se possível, pois ele pode ser removido ou alterado no futuro.

Desde:

  • 2.0.0



94
95
96
 
# Arquivo 'lib/mongo/socket/tcp.rb', linha 94

def connect_without_timeout(sockaddr)
  soquete.Conecte(sockaddr)
end