Class: Dizby::ConnectionWorker

Inherits:
Object
  • Object
show all
Defined in:
lib/dizby/worker/connection.rb

Instance Method Summary collapse

Constructor Details

#initialize(server, conn) ⇒ ConnectionWorker 



8
9
10
11
12
13
 
# File 'lib/dizby/worker/connection.rb', line 8

def initialize(server, conn)
  @server = server
  @conn = conn

  @thread = Thread.start { process_requests }
end

Instance Method Details

#close 



15
16
17
18
19
20
 
# File 'lib/dizby/worker/connection.rb', line 15

def close
  @conn.close unless @conn.closed?

  # TODO: @thread gets set to nil for some reason...
  @thread.join if @thread
end

#process_request (private) 



32
33
34
35
36
37
38
39
40
41
42
43
44
 
# File 'lib/dizby/worker/connection.rb', line 32

def process_request
  succ, result = InvokeMethod.new(@server, *@conn.recv_request).perform

  @server.log.backtrace(result) unless succ

  begin
    @conn.send_reply(succ, result)
  rescue
    @server.log.backtrace($!)
  end

  succ
end

#process_requests (private) 



24
25
26
27
28
29
30
 
# File 'lib/dizby/worker/connection.rb', line 24

def process_requests
  loop { break unless process_request }
rescue RemoteServerShutdown
  @server.log.debug("lost connection to server at #{@conn.remote_uri}")
ensure
  @conn.close unless @conn.closed?
end