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
|
module Celluloid
module Internals
class Stack
attr_accessor :actors, :threads
def initialize(threads)
@group = threads
@actors = []
@threads = []
end
def snapshot(backtrace = nil)
@group.each do |thread|
if thread.role == :actor
@actors << snapshot_actor(thread.actor, backtrace) if thread.actor
else
@threads << snapshot_thread(thread, backtrace)
end
end
end
def snapshot_actor(actor, backtrace = nil)
state = ActorState.new
state.id = actor.object_id
# TODO: delegate to the behavior
state.cell = snapshot_cell(actor.behavior) if actor.behavior.is_a?(Cell)
tasks = actor.tasks
if tasks.empty?
state.status = :idle
else
state.status = :running
state.tasks = tasks.to_a.map { |t| TaskState.new(t.class, t.type, t.meta, t.status, t.backtrace) }
end
state.backtrace = actor.thread.backtrace if backtrace && actor.thread
state
end
def snapshot_cell(behavior)
state = CellState.new
state.subject_id = behavior.subject.object_id
state.subject_class = behavior.subject.class
state
end
def snapshot_thread(thread, backtrace = nil)
if backtrace
backtrace = begin
thread.backtrace
rescue NoMethodError # for Rubinius < 2.5.2.c145
[]
end
end
ThreadState.new(thread.object_id, backtrace, thread.role)
end
def print(output = STDERR)
@actors.each do |actor|
output.print actor.dump
end
@threads.each do |thread|
output.print thread.dump
end
end
end
end
end
require "celluloid/internals/stack/states"
require "celluloid/internals/stack/dump"
require "celluloid/internals/stack/summary"
|
