Class: Cocaine::WorkerDispatcher

Inherits:
Dispatcher show all
Defined in:
lib/cocaine/server/dispatcher.rb

Instance Method Summary collapse

Constructor Details

#initialize(worker, conn) ⇒ WorkerDispatcher

Returns a new instance of WorkerDispatcher.



9
10
11
12
13
14
15
 
# File 'lib/cocaine/server/dispatcher.rb', line 9

def initialize(worker, conn)
  super conn
  @worker = worker
  @health = Cocaine::HealthManager.new self
  @health.start
  @channels = {}
end

Instance Method Details

#send_choke(session) ⇒ Object 



37
38
39
 
# File 'lib/cocaine/server/dispatcher.rb', line 37

def send_choke(session)
  send Choke.new, session
end

#send_chunk(session, data) ⇒ Object 



29
30
31
 
# File 'lib/cocaine/server/dispatcher.rb', line 29

def send_chunk(session, data)
  send Chunk.new(data), session
end

#send_error(session, errno, reason) ⇒ Object 



33
34
35
 
# File 'lib/cocaine/server/dispatcher.rb', line 33

def send_error(session, errno, reason)
  send Error.new(errno, reason), session
end

#send_handshake(session, uuid) ⇒ Object 



17
18
19
 
# File 'lib/cocaine/server/dispatcher.rb', line 17

def send_handshake(session, uuid)
  send Handshake.new(uuid), session
end

#send_heartbeat(session) ⇒ Object 



21
22
23
 
# File 'lib/cocaine/server/dispatcher.rb', line 21

def send_heartbeat(session)
  send Heartbeat.new, session
end

#send_terminate(session, errno, reason) ⇒ Object 



25
26
27
 
# File 'lib/cocaine/server/dispatcher.rb', line 25

def send_terminate(session, errno, reason)
  send Terminate.new(errno, reason), session
end