Class: Roby::Log::EventMatcher

Inherits:
Object
  • Object
show all
Defined in:
lib/roby/app/scripts/generate/bookmarks.rb

Instance Attribute Summary collapse

Instance Method Summary collapse

Constructor Details

#initialize ⇒ EventMatcher

Returns a new instance of EventMatcher.



10
11
12
13
14
 
# File 'lib/roby/app/scripts/generate/bookmarks.rb', line 10

def initialize
	@remote_ids = Hash.new
	@notifications = Hash.new
	@predicate_id = 0
end

Instance Attribute Details

#notifications ⇒ Object (readonly)

Returns the value of attribute notifications.



9
10
11
 
# File 'lib/roby/app/scripts/generate/bookmarks.rb', line 9

def notifications
  @notifications
end

#predicate_id ⇒ Object (readonly)

Returns the value of attribute predicate_id.



8
9
10
 
# File 'lib/roby/app/scripts/generate/bookmarks.rb', line 8

def predicate_id
  @predicate_id
end

#remote_ids ⇒ Object (readonly)

Returns the value of attribute remote_ids.



7
8
9
 
# File 'lib/roby/app/scripts/generate/bookmarks.rb', line 7

def remote_ids
  @remote_ids
end

Instance Method Details

#event(m, sec, usec, args) ⇒ Object 



35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
 
# File 'lib/roby/app/scripts/generate/bookmarks.rb', line 35

def event(m, sec, usec, args)
	if m == :discovered_tasks || m == :discovered_events
 objects = args[1]
 for object in objects
		for remote_id in object.remote_siblings.values
  remote_ids[remote_id] = object
		end
 end

	elsif m == :finalized_task || m == :finalized_event
 object = args[1]
 remote_ids.delete(object)
	end

	time = nil
	if predicate_set = notifications[m]
 for p, callback in predicate_set
		if p.call(args)
  time ||= Time.at(sec, usec)
  callback.call(time, args)
		end
 end
	end
end

#filter(log) ⇒ Object 



27
28
29
30
31
32
33
 
# File 'lib/roby/app/scripts/generate/bookmarks.rb', line 27

def filter(log)
	while log.has_sample?
 log.read_and_decode.each_slice(4) do |m, sec, usec, args|
		event(m, sec, usec, args)
 end
	end
end

#local_object(remote_id) ⇒ Object 



16
17
18
19
20
21
22
23
24
25
 
# File 'lib/roby/app/scripts/generate/bookmarks.rb', line 16

def local_object(remote_id)
	if remote_id.kind_of?(Roby::Distributed::RemoteID)
 unless obj = remote_ids[remote_id]
		raise "no object for #{remote_id}: #{remote_ids.keys}"
 end
 obj
	else
 remote_id
	end
end

#parse(expr, &block) ⇒ Object 



60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
 
# File 'lib/roby/app/scripts/generate/bookmarks.rb', line 60

def parse(expr, &block)
	case expr
	when /^(\w+)\((.*)\)$/
 method = :generator_fired
 task_model = Regexp.new($2)
 symbol = $1.to_sym
 predicate = lambda do |args|
		generator = local_object(args[0])
		if generator.respond_to?(:task) && generator.symbol == symbol
  task = local_object(generator.task)
  Regexp.new(task_model) === local_object(task).model.ancestors[0][0]
		end
 end
	end

	if predicate
 notifications[method] ||= Array.new
 notifications[method] << [predicate, block]
	end
end