You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@trafficserver.apache.org by jp...@apache.org on 2015/12/28 20:33:23 UTC
trafficserver git commit: TS-4009: take continuation mutexes in
stale_while_revalidate
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 <ke...@gmail.com>
Authored: Mon Dec 28 10:14:44 2015 +0100
Committer: James Peach <jp...@apache.org>
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 {