class Dalli::Socket::TCP

A standard TCP socket between the Dalli client and the Memcached server.

Attributes

options[RW]

options - supports enhanced logging in the case of a timeout

Public Class Methods

init_socket_options(sock, options) click to toggle source
# File lib/dalli/socket.rb, line 100
def self.init_socket_options(sock, options)
  sock.setsockopt(::Socket::IPPROTO_TCP, ::Socket::TCP_NODELAY, true)
  sock.setsockopt(::Socket::SOL_SOCKET, ::Socket::SO_KEEPALIVE, true) if options[:keepalive]
  sock.setsockopt(::Socket::SOL_SOCKET, ::Socket::SO_RCVBUF, options[:rcvbuf]) if options[:rcvbuf]
  sock.setsockopt(::Socket::SOL_SOCKET, ::Socket::SO_SNDBUF, options[:sndbuf]) if options[:sndbuf]
end
open(host, port, options = {}) click to toggle source
# File lib/dalli/socket.rb, line 90
def self.open(host, port, options = {})
  Timeout.timeout(options[:socket_timeout]) do
    sock = new(host, port)
    sock.options = { host: host, port: port }.merge(options)
    init_socket_options(sock, options)

    options[:ssl_context] ? wrapping_ssl_socket(sock, host, options[:ssl_context]) : sock
  end
end
wrapping_ssl_socket(tcp_socket, host, ssl_context) click to toggle source
# File lib/dalli/socket.rb, line 107
def self.wrapping_ssl_socket(tcp_socket, host, ssl_context)
  ssl_socket = Dalli::Socket::SSLSocket.new(tcp_socket, ssl_context)
  ssl_socket.hostname = host
  ssl_socket.sync_close = true
  ssl_socket.connect
  ssl_socket
end