Questions tagged [queue]
The queue tag has no usage guidance.
21 questions
0
votes
1
answer
65
views
remove old messages from topic
Hi all,
I am using ROS kinetic on Ubuntu 16.04.
I have a topic that I publish movement instructions to. At some point in my code I want to make a long rospy.sleep but sometimes I will publish to the ...
0
votes
1
answer
5
views
RS232 Queue System in ROS
Using ROS Kinetic and primarily python. I have a driver that subscribes to several topics including /cmd_vel and a bunch of other commands which interact with a control board via RS232.
One problem I ...
0
votes
1
answer
10
views
How to pull a message from queue with time interval?
When I subscribe my node, I set messages queue size and callback function:
...
0
votes
3
answers
25
views
How to Detect Subscriber Drops a Message
I made a subscriber which reads LIDAR data from rosbag-play. I use C++(roscpp).
But when I do rosbag-play with normal speed, subscriber's callback function cannot catch up with
LIDAR stream speed, ...
0
votes
1
answer
6
views
Which data is thrown away in queue if publish and spinonce rate is different?
I read that SpinOnce does not only make callback, but it will also clean the queue if possible. is that right?
Let's say publisher publish alphabets (a,b,c,...) at 9hz, and subscriber call Spinonce at ...
0
votes
1
answer
71
views
Multiple subscriber queue allocation using the same callback
I am creating multiple subscribers using the same callback function as in this post, the code is here.
Basically is this:
...
0
votes
1
answer
36
views
When to use publisher queue size vs. subscriber queue size
Although most tutorials only discuss the publisher queue size, a subscriber has such a parameter as well. So I'm wondering: When to use which queue size?
Actually the subscriber seems to be the ...
0
votes
1
answer
2
views
Queueing positions for the robot to move to
Hi,
I would like to have the robot move to point a->b->c in order and am not sure how to do this using a simple action client. I'm using movebase for this. When I add a second position for the ...
0
votes
1
answer
2
views
roscpp: requesting current queue state of subscriber
I have a node, where I would like a subscriber to have a high queue size during initialization of some internal processors (during which my node intentionally lacks calling into ros spinner) to avoid ...
0
votes
1
answer
5
views
simple FIFO stack (queue) for MoveIt in ROS
Hi,
I want to use a simple queue (FIFO stack) to give a list of waypoints to MoveIt. I looked at the tutorial : Callbacks_and_Spinning and the class CallbackQueue but it looks like we can use it only ...
0
votes
1
answer
4
views
Current pub/sub queue length
Dear all,
what if I would like to know how many objects are currently in the publisher's queue or in one of the subscribers' queue? I would like to monitor if they gets too long (and, e.g., some ...
0
votes
1
answer
1
view
Subscriber data not up to date
I have written a subscriber to one of the image topics and I have set my buffer to 1 using:
subscriber =rospy.Subscriber("/camera/rgb/image_mono/compressed",CompressedImage, callback, ...
0
votes
1
answer
16
views
how are threads used to service callbacks in nodelets?
I have several nodelets, each subscribes to different messages (using the single threaded node handle). However, I realized one of my nodes, which subscribes to images and to odometry messages, and ...
0
votes
1
answer
21
views
Can you check how many messages are in a subscriber's Queue?
For testing purposes, I want to plot the number of messages waiting in a subscriber's topic Queue over time.
Having too many old messages is undesirable since up to date information is critical. ...
0
votes
1
answer
7
views
Queued messages do not get sent when shutting down a publisher
I noticed that when calling publisher.shutdown(), the messages that are queued for publishing simply get destroyed with the publisher. I could not find any ...
0
votes
1
answer
5
views
subscriber queue length
I understand that ROS queues all incoming messages until nodes are able to service those callbacks and that this queue length is specified in the constructor of a subscriber.
But what I would like to ...
0
votes
1
answer
108
views
RVIZ Message Filter Queue Size
I have a setup where my pose information is greatly delayed ~0.5s from my PointCloud data. Because of this, my TF timestamps lag behind by about the same 0.5s.
When I attempt to visualize this in ...
0
votes
1
answer
27
views
Know if you are dropping messages from a subscriber queue?
Is there a way to know when or how many messages are being dropped from a subscriber queue?
I'm mostly interested in occasionally reporting that node foo has dropped N packets since execution began.
...
0
votes
2
answers
2
views
What happens is a node receives a message while it's in the middle of a callback?
I'm thinking of having a node send a message to another node as part of a callback function. It should receive a message from another node at about this time as well, before it finishes the callback ...
0
votes
1
answer
7
views
Do subscribers work on a FIFO queue?
Do the queues used in ros::Subscriber behave like FIFO queues?
In particular, if I use a message_filters::Synchronizer that, in approximately equal time increments, invokes a callback function for a ...
0
votes
1
answer
1
view
how does second term of advertise
Hello.
I'm writing a program that reads data from a laser. This information is published by stage or a bag file.
I know that the second parameter of the function advertise() or subscribe() is the size ...