class LogCourier::ExtendedTCPServer

Wrap around TCPServer to grab last error for use in reporting which peer had an error

Attributes

peer[R]

Public Instance Methods

accept() click to toggle source

Save the peer

Calls superclass method
# File lib/log-courier/server_tcp.rb, line 32
def accept
  sock = super
  # Prevent reverse lookup by passing false
  begin
    peer = sock.peeraddr(false)
  rescue ArgumentError
    # Logstash <= 1.5.0 has a patch that blocks parameters (elastic/logstash#3364)
    peer = sock.peeraddr
  end
  @peer = "#{peer[2]}:#{peer[1]}"
  sock
end
initialise() click to toggle source
Calls superclass method
# File lib/log-courier/server_tcp.rb, line 26
def initialise
  reset_peer
  super
end
reset_peer() click to toggle source
# File lib/log-courier/server_tcp.rb, line 45
def reset_peer
  @peer = 'unknown'
  nil
end