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