Class: Rack::Handler::LSWS
- Inherits:
-
Object
- Object
- Rack::Handler::LSWS
- Defined in:
- rack/rack/handler/lsws.rb
Class Method Summary (collapse)
- + (void) run(app, options = nil)
- + (void) send_body(body)
- + (void) send_headers(status, headers)
- + (void) serve(app)
Class Method Details
+ (void) run(app, options = nil)
8 9 10 11 12 |
# File 'rack/rack/handler/lsws.rb', line 8 def self.run(app, =nil) while LSAPI.accept != nil serve app end end |
+ (void) send_body(body)
53 54 55 56 57 58 |
# File 'rack/rack/handler/lsws.rb', line 53 def self.send_body(body) body.each { |part| print part STDOUT.flush } end |
+ (void) send_headers(status, headers)
43 44 45 46 47 48 49 50 51 52 |
# File 'rack/rack/handler/lsws.rb', line 43 def self.send_headers(status, headers) print "Status: #{status}\r\n" headers.each { |k, vs| vs.split("\n").each { |v| print "#{k}: #{v}\r\n" } } print "\r\n" STDOUT.flush end |
+ (void) serve(app)
13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 |
# File 'rack/rack/handler/lsws.rb', line 13 def self.serve(app) env = ENV.to_hash env.delete "HTTP_CONTENT_LENGTH" env["SCRIPT_NAME"] = "" if env["SCRIPT_NAME"] == "/" rack_input = RewindableInput.new($stdin.read.to_s) env.update( "rack.version" => Rack::VERSION, "rack.input" => rack_input, "rack.errors" => $stderr, "rack.multithread" => false, "rack.multiprocess" => true, "rack.run_once" => false, "rack.url_scheme" => ["yes", "on", "1"].include?(ENV["HTTPS"]) ? "https" : "http" ) env["QUERY_STRING"] ||= "" env["HTTP_VERSION"] ||= env["SERVER_PROTOCOL"] env["REQUEST_PATH"] ||= "/" status, headers, body = app.call(env) begin send_headers status, headers send_body body ensure body.close if body.respond_to? :close end ensure rack_input.close end |