Repository: trafficserver Updated Branches: refs/heads/6.1.x e222cd58e -> f3d9594b0
TS-4009: take continuation mutexes in stale_while_revalidate Project: http://git-wip-us.apache.org/repos/asf/trafficserver/repo Commit: http://git-wip-us.apache.org/repos/asf/trafficserver/commit/f3d9594b Tree: http://git-wip-us.apache.org/repos/asf/trafficserver/tree/f3d9594b Diff: http://git-wip-us.apache.org/repos/asf/trafficserver/diff/f3d9594b Branch: refs/heads/6.1.x Commit: f3d9594b06823a51ed6486ee399c33259d8c9f69 Parents: e222cd5 Author: Christoph Keller <[email protected]> Authored: Mon Dec 28 10:14:44 2015 +0100 Committer: James Peach <[email protected]> Committed: Mon Dec 28 11:34:44 2015 -0800 ---------------------------------------------------------------------- .../stale_while_revalidate/stale_while_revalidate.c | 6 +++--- 1 file changed, 3 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/trafficserver/blob/f3d9594b/plugins/experimental/stale_while_revalidate/stale_while_revalidate.c ---------------------------------------------------------------------- diff --git a/plugins/experimental/stale_while_revalidate/stale_while_revalidate.c b/plugins/experimental/stale_while_revalidate/stale_while_revalidate.c index c130af4..8422602 100644 --- a/plugins/experimental/stale_while_revalidate/stale_while_revalidate.c +++ b/plugins/experimental/stale_while_revalidate/stale_while_revalidate.c @@ -392,7 +392,7 @@ fetch_resource(TSCont cont, TSEvent event ATS_UNUSED, void *edata ATS_UNUSED) if (state) { TSDebug(PLUGIN_NAME, "Lets do the lookup"); - consume_cont = TSContCreate(consume_resource, NULL); + consume_cont = TSContCreate(consume_resource, TSMutexCreate()); TSContDataSet(consume_cont, (void *)state); if (state->async_req) { @@ -528,7 +528,7 @@ main_plugin(TSCont cont, TSEvent event, void *edata) state->async_req = true; TSHttpTxnCacheLookupStatusSet(txn, TS_CACHE_LOOKUP_HIT_FRESH); // TSHttpTxnReenable(txn, TS_EVENT_HTTP_CONTINUE); - fetch_cont = TSContCreate(fetch_resource, NULL); + fetch_cont = TSContCreate(fetch_resource, TSMutexCreate()); TSContDataSet(fetch_cont, (void *)state); TSContSchedule(fetch_cont, 0, TS_THREAD_POOL_TASK); TSHttpTxnReenable(txn, TS_EVENT_HTTP_CONTINUE); @@ -541,7 +541,7 @@ main_plugin(TSCont cont, TSEvent event, void *edata) state->async_req = false; state->txn = txn; state->main_cont = cont; // we need this for the warning header callback. not sure i like it, but it works. - fetch_cont = TSContCreate(fetch_resource, NULL); + fetch_cont = TSContCreate(fetch_resource, TSMutexCreate()); TSContDataSet(fetch_cont, (void *)state); TSContSchedule(fetch_cont, 0, TS_THREAD_POOL_NET); } else {
