Contents

module Shadowsocks
  class Connection < EventMachine::Connection
    BackpressureLevel = 524288 # 512k

    attr_accessor :crypto

    private

    def encrypt(buf)
      crypto.encrypt(buf)
    end

    def decrypt(buf)
      crypto.decrypt(buf)
    end

    def over_pressure?
      remote.get_outbound_data_size > BackpressureLevel
    end

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

Version data entries

7 entries across 7 versions & 1 rubygems

Version	Path
shadowsocks-0.12	lib/shadowsocks/connection.rb
shadowsocks-0.11	lib/shadowsocks/connection.rb
shadowsocks-0.10	lib/shadowsocks/connection.rb
shadowsocks-0.9	lib/shadowsocks/connection.rb
shadowsocks-0.8	lib/shadowsocks/connection.rb
shadowsocks-0.7	lib/shadowsocks/connection.rb
shadowsocks-0.6	lib/shadowsocks/connection.rb