Class: Mongrel::HttpServer

Inherits:
Object
  • Object
show all
Defined in:
lib/never_block/servers/mongrel.rb

Constant Summary collapse

DEFAULT_FIBER_POOL_SIZE = 
20

Instance Method Summary collapse

Constructor Details

#initialize(host, port, num_processors = 950, x = 0, y = nil) ⇒ HttpServer

Deal with Mongrel 1.0.1 or earlier, as well as later.



90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
 
# File 'lib/never_block/servers/mongrel.rb', line 90

def initialize(host, port, num_processors=950, x=0, y=nil) # Deal with Mongrel 1.0.1 or earlier, as well as later.
  @socket = nil
  @classifier = URIClassifier.new
  @host = host
  @port = port
  @workers = ThreadGroup.new
  if y
    @throttle = x
    @timeout = y || 60
  else
    @timeout = x
  end
  @num_processors = num_processors #num_processors is pointless for evented....
  @death_time = 60
  self.class.const_set(:Instance,self)
end

Instance Method Details

#dispatch_to_handlers(handlers, request, response) ⇒ Object 



161
162
163
164
165
166
 
# File 'lib/never_block/servers/mongrel.rb', line 161

def dispatch_to_handlers(handlers,request,response)
  handlers.each do |handler|
    handler.process(request, response)
    break if response.done
  end
end

#fiber_pool ⇒ Object 



107
108
109
 
# File 'lib/never_block/servers/mongrel.rb', line 107

def fiber_pool
  @fiber_pool ||= NB::Pool::FiberPool.new(DEFAULT_FIBER_POOL_SIZE)
end

#process_http_request(params, linebuffer, client) ⇒ Object 



127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
 
# File 'lib/never_block/servers/mongrel.rb', line 127

def process_http_request(params,linebuffer,client)
  if not params[Const::REQUEST_PATH]
    uri = URI.parse(params[Const::REQUEST_URI])
    params[Const::REQUEST_PATH] = uri.request_uri
  end

    raise "No REQUEST PATH" if not params[Const::REQUEST_PATH]

  script_name, path_info, handlers = @classifier.resolve(params[Const::REQUEST_PATH])

  if handlers
    notifiers = handlers.select { |h| h.request_notify }
    request = HttpRequest.new(params, linebuffer, notifiers)

    # request is good so far, continue processing the response
    response = HttpResponse.new(client)

    # Process each handler in registered order until we run out or one finalizes the response.
    fiber_pool.spawn do
      dispatch_to_handlers(handlers,request,response)
      end
    # And finally, if nobody closed the response off, we finalize it.
    unless response.done
      response.finished
    else
      response.close_connection_after_writing
    end
  else
    # Didn't find it, return a stock 404 response.
    client.send_data(Const::ERROR_404_RESPONSE)
    client.close_connection_after_writing
  end
end

#run ⇒ Object 



111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
 
# File 'lib/never_block/servers/mongrel.rb', line 111

def run
  trap('INT') { raise StopServer }
  trap('TERM') { raise StopServer }
  @acceptor = Thread.new do
    EventMachine.epoll
    EventMachine.set_descriptor_table_size(4096)
    EventMachine.run do
      begin
        EventMachine.start_server(@host,@port,MongrelProtocol)
      rescue StopServer
        EventMachine.stop_event_loop
      end
    end
  end
end