Class: Pitchfork::HttpServer::TimeoutHandler

Inherits:
Object
  • Object
show all
Defined in:
lib/pitchfork/http_server.rb

Defined Under Namespace

Classes: Info

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize(server, worker, callback) ⇒ TimeoutHandler

:nodoc:



39
40
41
42
43
44
45
 
# File 'lib/pitchfork/http_server.rb', line 39

def initialize(server, worker, callback) # :nodoc:
  @server = server
  @worker = worker
  @callback = callback
  @rack_env = nil
  @timeout_request = nil
end

Instance Attribute Details

#rack_env=(value) ⇒ Object (writeonly)

:nodoc:



37
38
39
 
# File 'lib/pitchfork/http_server.rb', line 37

def rack_env=(value)
  @rack_env = value
end

#timeout_request=(value) ⇒ Object (writeonly)

:nodoc:



37
38
39
 
# File 'lib/pitchfork/http_server.rb', line 37

def timeout_request=(value)
  @timeout_request = value
end

Instance Method Details

#call(original_thread) ⇒ Object

:nodoc:



51
52
53
54
55
56
57
58
59
60
61
 
# File 'lib/pitchfork/http_server.rb', line 51

def call(original_thread) # :nodoc:
  begin
    @server.logger.error("worker=#{@worker.nr} pid=#{@worker.pid} timed out, exiting")
    if @callback
      @callback.call(@server, @worker, Info.new(original_thread, @rack_env))
    end
  rescue => error
    Pitchfork.log_error(@server.logger, "after_worker_timeout error", error)
  end
  @server.worker_exit(@worker)
end

#deadline ⇒ Object 



67
68
69
 
# File 'lib/pitchfork/http_server.rb', line 67

def deadline
  @timeout_request.deadline
end

#extend_deadline(extra_time) ⇒ Object 



71
72
73
74
75
76
 
# File 'lib/pitchfork/http_server.rb', line 71

def extend_deadline(extra_time)
  extra_time = Integer(extra_time)
  @worker.deadline += extra_time
  @timeout_request.extend_deadline(extra_time)
  self
end

#finished ⇒ Object

:nodoc:



63
64
65
 
# File 'lib/pitchfork/http_server.rb', line 63

def finished # :nodoc:
  @timeout_request.finished
end

#inspect ⇒ Object 



47
48
49
 
# File 'lib/pitchfork/http_server.rb', line 47

def inspect
  "#<Pitchfork::HttpServer::TimeoutHandler##{object_id}>"
end