diff --git a/src/publisher.c b/src/publisher.c index ce6a022..bf1d480 100644 --- a/src/publisher.c +++ b/src/publisher.c @@ -155,10 +155,11 @@ void *publisher(void *zmq_publisher) { int queue_id = 0; while (!__stop) { if (queues[queue_id].issending) { + long long startat=TIMESTAMP(); printf("Publishing..."); zmq_send(zmq_publisher, queues[queue_id].msg, queues[queue_id].size, 0); queues[queue_id].issending = 0; - printf("done\n"); + printf("done (duration %lld)\n",TIMESTAMP()-startat); } else { #if LOG_DELAY > 0 usleep(LOG_DELAY * 1000);