From 23aa6a623af2990f436fbbd1507b9d8cd59d05b5 Mon Sep 17 00:00:00 2001 From: Con Kolivas Date: Mon, 23 Feb 2015 12:18:42 +1100 Subject: [PATCH] Create two workqueues for the generator --- src/generator.c | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/generator.c b/src/generator.c index fe907444..bcf7ab78 100644 --- a/src/generator.c +++ b/src/generator.c @@ -146,6 +146,7 @@ struct generator_data { proxy_instance_t *dead_proxies; /* Disabled proxies */ int proxy_notify_id; // Globally increasing notify id ckmsgq_t *srvchk; // Server check message queue + ckwq_t *ckwqs; }; typedef struct generator_data gdata_t; @@ -2207,6 +2208,7 @@ int generator(proc_instance_t *pi) gdata = ckzalloc(sizeof(gdata_t)); ckp->data = gdata; gdata->ckp = ckp; + ckp->ckwqs = gdata->ckwqs = create_ckwqs(ckp, "gen", 2); if (ckp->proxy) { char *buf = NULL;