Contents

module Shadowsocks
  class Connection < EventMachine::Connection
    BackpressureLevel = 2097152 # 2m

    private

    def over_pressure?
      remote.get_outbound_data_size > BackpressureLevel
    end

    def outbound_checker
      if over_pressure?
        pause unless paused?
        EM.add_timer(1) { outbound_checker }
      else
        resume if paused?
      end
    end
  end
end

Version data entries

1 entries across 1 versions & 1 rubygems

Version	Path
shadowsocks-0.3	lib/shadowsocks/connection.rb