def initialize(server, port, host, sendq_delay=2, sendq_burst=4, brt="400/2")
@timer = Timer::Timer.new
@timer.add(0.2) do
spool
end
@server = server.dup
@port = port.to_i
@host = host
@sock = nil
@spooler = false
@lines_sent = 0
@lines_received = 0
if sendq_delay
@sendq_delay = sendq_delay.to_f
else
@sendq_delay = 2
end
@last_send = Time.new - @sendq_delay
@last_throttle = Time.new
@burst = 0
if sendq_burst
@sendq_burst = sendq_burst.to_i
else
@sendq_burst = 4
end
@bytes_per = 400
@seconds_per = 2
@throttle_bytes = 0
@throttle_div = 1
setbyterate(brt)
end