Class: ProcessWanker::TCPFilteredServer

Inherits:
TCPServer
  • Object
show all
Includes:
Log
Defined in:
lib/net/net_server.rb

Constant Summary

Constants included from Log

Log::DEBUG, Log::ERROR, Log::INFO, Log::WARN

Instance Method Summary collapse

Methods included from Log

debug, error, info, log, set_level, warn

Constructor Details

#initialize(hostname, port, auth) ⇒ TCPFilteredServer

Returns a new instance of TCPFilteredServer.



29
30
31
32
 
# File 'lib/net/net_server.rb', line 29

def initialize(hostname,port,auth)
	@auth=auth
	super(hostname,port)
end

Instance Method Details

#accept ⇒ Object 



34
35
36
37
38
39
40
41
42
43
 
# File 'lib/net/net_server.rb', line 34

def accept()
	while(true)
		con=super()
      debug("got TCP connection from #{con.peeraddr.inspect}")
		return(con) if(validate_auth(con))
		ProcessWanker::with_logged_rescue("accept - reject remote addr") do
			con.close()
		end
	end
end

#validate_auth(con) ⇒ Object 



45
46
47
48
49
50
51
52
53
54
55
56
 
# File 'lib/net/net_server.rb', line 45

def validate_auth(con)

	remote_addr=con.peeraddr[3]
	remote_addr=IPAddr.new(remote_addr)
	
	if(!@auth.allow_ip(remote_addr))
		info("reject ip #{remote_addr.inspect}")
		return(false)
	end
	
	true
end