Class: LogCourier::ExtendedTCPServer

Inherits:
TCPServer
  • Object
show all
Defined in:
lib/log-courier/server_tcp.rb

Overview

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

Instance Attribute Summary collapse

Instance Method Summary collapse

Instance Attribute Details

#peer ⇒ Object (readonly)

Returns the value of attribute peer.



27
28
29
 
# File 'lib/log-courier/server_tcp.rb', line 27

def peer
  @peer
end

Instance Method Details

#accept ⇒ Object

Save the peer



35
36
37
38
39
40
41
42
43
44
45
46
 
# File 'lib/log-courier/server_tcp.rb', line 35

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]}"
  return sock
end

#initialise ⇒ Object 



29
30
31
32
 
# File 'lib/log-courier/server_tcp.rb', line 29

def initialise
  reset_peer
  super
end

#reset_peer ⇒ Object 



48
49
50
51
 
# File 'lib/log-courier/server_tcp.rb', line 48

def reset_peer
  @peer = 'unknown'
  return
end