@@ -3,6 +3,7 @@ require 'tunnel_splitter' module TunnelSplitter class Server attr_reader :host, :port, :tunnel_group + attr_accessor :auto_pong def initialize(listen_addr, connect_addr) @listen_host, @listen_port = listen_addr.split(/:/) @@ -102,7 +103,7 @@ module TunnelSplitter end def receive_data(data) - handle_pings(data) + handle_pings(data) if @server.auto_pong until data.empty? piece = data.slice!(0, 2**16-1) lib/tunnel_splitter/server.rb @@ -3,13 +3,19 @@ require 'tunnel_splitter' require 'optparse' p = nil +i = false opts = OptionParser.new do |o| o.on "-p", "--max-pending-acks N" do |p| p = p.to_i end + + o.on "-i", "--auto-pong" do + i = true + end end opts.parse! rescue (puts opts; exit 1) server = TunnelSplitter::Server.new(ARGV[0].dup, ARGV[1].dup) server.max_pending_acks = p if p +server.auto_pong = i EventMachine.run { server.start } ts_server.rb 330c677e6aad1bd161a2940390ae74ff8a646965 steve coderrr.contact@gmail.com http://github.com/coderrr/tunnel_splitter/commit/5dad9dc9636f40d25d6c85407a3dc6ede80b254e 5dad9dc9636f40d25d6c85407a3dc6ede80b254e 2009-06-13T17:44:36-07:00 2009-06-13T17:44:36-07:00 only auto pong if setting is enabled d5e3aab05b9b243464c07ceeacc97674341aa681 steve coderrr.contact@gmail.com