Class: Packet::MetaPimp

Inherits:
Pimp
  • Object
show all
Defined in:
lib/packet/packet_meta_pimp.rb

Overview

Class acts as a pimp for workers, which doesn’t have a manually created pimp The idea behind a manually added pimp is to let client handle low level messaging beween workers. A meta pimp, does it for you.

Instance Attribute Summary collapse

Attributes inherited from Pimp

#fd_write_end, #lifeline, #outbound_data, #pid, #reactor, #signature, #workers

Instance Method Summary collapse

Methods inherited from Pimp

#initialize, #send_data, #send_fd

Methods included from ClassHelpers

iattr_accessor, inheritable_attribute, metaclass

Methods included from NbioHelper

#dump_object, #gen_worker_key, #object_dump, #packet_classify, #read_data, #write_and_schedule, #write_once

Constructor Details

This class inherits a constructor from Packet::Pimp

Instance Attribute Details

#callback_hash ⇒ Object

initializer of pimp



7
8
9
 
# File 'lib/packet/packet_meta_pimp.rb', line 7

def callback_hash
  @callback_hash
end

#worker_key ⇒ Object

Returns the value of attribute worker_key.



8
9
10
 
# File 'lib/packet/packet_meta_pimp.rb', line 8

def worker_key
  @worker_key
end

#worker_name ⇒ Object

Returns the value of attribute worker_name.



8
9
10
 
# File 'lib/packet/packet_meta_pimp.rb', line 8

def worker_name
  @worker_name
end

#worker_status ⇒ Object

Returns the value of attribute worker_status.



8
9
10
 
# File 'lib/packet/packet_meta_pimp.rb', line 8

def worker_status
  @worker_status
end

Instance Method Details

#handle_object(data_options = {}) ⇒ Object 



25
26
27
28
29
30
31
32
33
34
35
36
 
# File 'lib/packet/packet_meta_pimp.rb', line 25

def handle_object data_options = {}
  case data_options[:type]
  when :request
    process_request(data_options)
  when :response
    process_response(data_options)
  when :status
    save_worker_status(data_options)
  when :result
    save_worker_result(data_options)
  end
end

#pimp_init ⇒ Object 



9
10
11
12
13
14
15
 
# File 'lib/packet/packet_meta_pimp.rb', line 9

def pimp_init
  @callback_hash ||= {}
  @worker_status = nil
  @worker_result = nil
  @worker_key = nil
  @tokenizer = Packet::BinParser.new
end

#process_request(data_options = {}) ⇒ Object 



47
48
49
50
51
 
# File 'lib/packet/packet_meta_pimp.rb', line 47

def process_request(data_options = {})
  if((requested_worker = data_options[:requested_worker]) && (reactor.live_workers[requested_worker]))
    reactor.live_workers[requested_worker].send_request(data_options)
  end
end

#process_response(data_options = {}) ⇒ Object 



53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
 
# File 'lib/packet/packet_meta_pimp.rb', line 53

def process_response(data_options = {})
  if callback_signature = data_options[:callback_signature]
    callback = callback_hash[callback_signature]
    # there coule be bug when you are trying to send the data back to the client
    begin
      callback.invoke(data_options)
    rescue
    end
  elsif client_signature = data_options[:client_signature]
    begin
      reactor.connections[client_signature][:instance].worker_receive(data_options)
    rescue
    end
  end
end

#receive_data(p_data) ⇒ Object

will be invoked whenever there is a response from the worker



18
19
20
21
22
23
 
# File 'lib/packet/packet_meta_pimp.rb', line 18

def receive_data p_data
  @tokenizer.extract(p_data) do |b_data|
    t_data = Marshal.load(b_data)
    handle_object(t_data)
  end
end

#save_worker_result(data_options = { }) ⇒ Object 



38
39
40
 
# File 'lib/packet/packet_meta_pimp.rb', line 38

def save_worker_result(data_options = { })
  @worker_result = data_options[:data]
end

#save_worker_status(data_options = { }) ⇒ Object 



42
43
44
45
 
# File 'lib/packet/packet_meta_pimp.rb', line 42

def save_worker_status(data_options = { })
  # @worker_status = data_options[:data]
  reactor.update_result(worker_key,data_options[:data])
end

#send_request(data_options = { }) ⇒ Object

can be used to send request to correspoding worker



70
71
72
73
74
75
76
77
78
79
 
# File 'lib/packet/packet_meta_pimp.rb', line 70

def send_request(data_options = { })
  if callback = data_options[:callback]
    callback_hash[callback.signature] = callback
    data_options.delete(:callback)
    data_options[:callback_signature] = callback.signature
    send_data(data_options)
  else
    send_data(data_options)
  end
end