Haarslev's profile - activity

Hello,

I'm currently working on a project where I use a network written in TensorFlow to segment some point clouds. I have created a node which subscribes to the point cloud topic. The callback function then passes the point cloud through the network, and publishes the results on a different topic.

This all works well, but I have a problem:

The time it takes to run the point cloud through the network is greater than the publish rate of the LiDAR. This creates an ever increasing delay between the input and the output of the node, as a new thread is created for each callback function, which then waits until the network is available.

I would therefore like a way to cancel all callbacks until the network is available again, so all other point clouds than the latest gets discarded.

Currently I do the following

# Callback
def segment(pointcloud):
    feed_dict = {ops['pointclouds_pl']: pointcloud,
                ops['is_training_pl']: False}
    labels = sess.run(ops['pred'], feed_dict=feed_dict)
    publisher.publish(labels)

The subscriber is declared like this

subscriber = rospy.Subscriber('aligned_pointcloud', PointCloud2, segment, queue_size=1)

I would assume that setting the queue_size to one would do the trick but that is not the case.

 while not rospy.is_shutdown():
        pc = rospy.wait_for_message('aligned_pointcloud', PointCloud2)
        segment(pc)

The above code is also a possibility I have tried which sorta work. The problem is that it first listens for messages after the function has terminated, instead of keeping the latest ready. So if a message is published right before segment() terminates, the message is not received and the node waits for the next message to be published.

As pointed out by gvdhoorn, the fix was to set queue_size=None subscriber = rospy.Subscriber('aligned_pointcloud', Poin

I'll try as soon as I'm near my workstation again, thank you

In the bottom example I have not declared a subscriber. I simply wait for a message on the topic, and call the function

How to set callback queue size in rospy Hello, I'm currently working on a project where I use a network written in Tens

How to set callback queue size in rospy Hello, I'm currently working on a project where I use a network written in Tens

rospy subscriber queue Hello, I'm currently working on a project where I use a network written in TensorFlow to segment