Repository: trafficserver Updated Branches: refs/heads/master a8b4a90af -> e52f0606b
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/e52f0606 Tree: http://git-wip-us.apache.org/repos/asf/trafficserver/tree/e52f0606 Diff: http://git-wip-us.apache.org/repos/asf/trafficserver/diff/e52f0606 Branch: refs/heads/master Commit: e52f0606b65d6f0a7b430256d06123cc5f7145b6 Parents: a8b4a90 Author: Christoph Keller <[email protected]> Authored: Mon Dec 28 10:14:44 2015 +0100 Committer: James Peach <[email protected]> Committed: Mon Dec 28 11:32:29 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/e52f0606/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 {
