niklas/cyclonedds
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

subscriber threads in pubsub have no need for a timeout

Browse source 
... and periodic wakeups for no good reason are bad for power management

Signed-off-by: Erik Boasson <eb@ilities.com>
This commit is contained in:
Erik Boasson 2018-08-01 09:03:05 +02:00
parent 9cdba8a186
commit 7d22a343fc
1 changed files with 1 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

3
src/tools/pubsub/pubsub.c
View file

@ -1640,7 +1640,6 @@ static uint32_t subthread(void *vspec) {
void **mseq = (void **) dds_alloc(sizeof(void*) * (spec->read_maxsamples));
dds_sample_info_t *iseq = (dds_sample_info_t *) dds_alloc(sizeof(dds_sample_info_t) * spec->read_maxsamples);
dds_duration_t timeout = (uint64_t)100000000;
dds_attach_t *xs = dds_alloc(sizeof(dds_attach_t) * nxs);
dds_time_t tstart = 0, tfirst = 0, tprint = 0;
@ -1661,7 +1660,7 @@ static uint32_t subthread(void *vspec) {
if (spec->polling) {
dds_sleepfor(DDS_MSECS(1)); /* 1ms sleep interval, so a bit less than 1kHz poll freq */
} else {
rc = dds_waitset_wait(ws, xs, nxs, timeout);
rc = dds_waitset_wait(ws, xs, nxs, DDS_INFINITY);
if (rc < DDS_RETCODE_OK) {
printf ("wait: error %d\n", (int) rc);
break;