1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
|
require "celluloid"
# !!! DO NOT INTRODUCE ADDITIONAL GLOBAL VARIABLES !!!
# rubocop:disable Style/GlobalVars
$CELLULOID_MONITORING = true
# rubocop:enable Style/GlobalVars
module Celluloid
class Probe
include Celluloid
include Celluloid::Notifications
NOTIFICATIONS_TOPIC_BASE = "celluloid.events.%s".freeze
EVENTS_BUFFER = Queue.new
class << self
def run
# spawn the actor if not found
supervise_as(:probe_actor) unless Actor[:probe_actor] && Actor[:probe_actor].alive?
end
def run_without_supervision
Actor[:probe_actor] = Celluloid::Probe.new
end
def actor_created(actor)
trigger_event(:actor_created, actor)
end
def actor_named(actor)
trigger_event(:actor_named, actor)
end
def actor_died(actor)
trigger_event(:actor_died, actor)
end
def actors_linked(a, b)
a = find_actor(a)
b = find_actor(b)
trigger_event(:actors_linked, a, b)
end
private
def trigger_event(name, *args)
# !!! DO NOT INTRODUCE ADDITIONAL GLOBAL VARIABLES !!!
# rubocop:disable Style/GlobalVars
return unless $CELLULOID_MONITORING
# rubocop:enable Style/GlobalVars
EVENTS_BUFFER << [name, args]
probe_actor = Actor[:probe_actor]
probe_actor.async.process_queue if probe_actor
end
def find_actor(obj)
if obj.__send__(:class) == Actor
obj
elsif owner = obj.instance_variable_get(OWNER_IVAR)
owner
end
end
end
def initialize
async.process_queue
end
def process_queue
until EVENTS_BUFFER.empty?
event = EVENTS_BUFFER.pop
dispatch_event(*event)
end
end
def dispatch_event(cmd, args)
publish(NOTIFICATIONS_TOPIC_BASE % cmd, args)
end
end
end
|
