aboutsummaryrefslogtreecommitdiff
path: root/src/util/mq.c
diff options
context:
space:
mode:
authorChristian Grothoff <christian@grothoff.org>2018-04-30 10:55:26 +0200
committerChristian Grothoff <christian@grothoff.org>2018-04-30 10:55:26 +0200
commit7fef1456bd44bacaf5aa927c89282a31e89bdcf7 (patch)
tree4718a868fe624a2d7a78f580f33f5f4bf0d6ab1a /src/util/mq.c
parentbdf8e76fc9b72f2000e33f479a15919811a5f312 (diff)
downloadgnunet-7fef1456bd44bacaf5aa927c89282a31e89bdcf7.tar.gz
gnunet-7fef1456bd44bacaf5aa927c89282a31e89bdcf7.zip
enable more parallelism with DHT queue, but limit to 1000 entries, then kill hard
Diffstat (limited to 'src/util/mq.c')
-rw-r--r--src/util/mq.c4
1 files changed, 1 insertions, 3 deletions
diff --git a/src/util/mq.c b/src/util/mq.c
index af700836c..0f9ad9a12 100644
--- a/src/util/mq.c
+++ b/src/util/mq.c
@@ -578,11 +578,9 @@ void
578GNUNET_MQ_set_handlers_closure (struct GNUNET_MQ_Handle *mq, 578GNUNET_MQ_set_handlers_closure (struct GNUNET_MQ_Handle *mq,
579 void *handlers_cls) 579 void *handlers_cls)
580{ 580{
581 unsigned int i;
582
583 if (NULL == mq->handlers) 581 if (NULL == mq->handlers)
584 return; 582 return;
585 for (i=0;NULL != mq->handlers[i].cb; i++) 583 for (unsigned int i=0;NULL != mq->handlers[i].cb; i++)
586 mq->handlers[i].cls = handlers_cls; 584 mq->handlers[i].cls = handlers_cls;
587} 585}
588 586