Skip to content
Open
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
25 changes: 11 additions & 14 deletions ros2topic/ros2topic/verb/hz.py
Original file line number Diff line number Diff line change
Expand Up @@ -129,27 +129,24 @@ def _setup_safe_eval(safe_eval_model, msg_class, topic):

def main(args):
with DirectNode(args) as node:
topics = args.topic_name
topic = args.topic_name
filter_expr = None
# set up custom safe eval model for filter expression
if args.filter_expr:
safe_eval_model = _setup_base_safe_eval()
for topic in topics:
msg_class = get_msg_class(
node, topic, blocking=True, include_hidden_topics=True)
if msg_class is None:
continue

msg_class = get_msg_class(
node, topic, blocking=True, include_hidden_topics=True)
if msg_class is not None:
safe_eval_model = _setup_safe_eval(safe_eval_model, msg_class, topic)

def expr_eval(expr):
def eval_fn(m):
safe_expression = Expr(expr, model=safe_eval_model)
return eval(safe_expression.code)
return eval_fn
filter_expr = expr_eval(args.filter_expr)
def expr_eval(expr):
def eval_fn(m):
safe_expression = Expr(expr, model=safe_eval_model)
return eval(safe_expression.code)
return eval_fn
filter_expr = expr_eval(args.filter_expr)

_rostopic_hz(node.node, topics, qos_args=args, window_size=args.window_size,
_rostopic_hz(node.node, topic, window_size=args.window_size,
filter_expr=filter_expr, use_wtime=args.use_wtime)


Expand Down