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 2014/03/29 00:31:33 UTC
[11/13] git commit: TS-2675: metalink: Send our own
TS_EVENT_VCONN_WRITE_COMPLETE event upstream
TS-2675: metalink: Send our own TS_EVENT_VCONN_WRITE_COMPLETE event upstream
Send our own TS_EVENT_VCONN_WRITE_COMPLETE event upstream when the
input is complete otherwise HttpSM::update_stats() won't get called
and the transaction won't get logged. (If there are upstream
transformations they won't get a chance to clean up otherwise!)
Project: http://git-wip-us.apache.org/repos/asf/trafficserver/repo
Commit: http://git-wip-us.apache.org/repos/asf/trafficserver/commit/f88a7260
Tree: http://git-wip-us.apache.org/repos/asf/trafficserver/tree/f88a7260
Diff: http://git-wip-us.apache.org/repos/asf/trafficserver/diff/f88a7260
Branch: refs/heads/master
Commit: f88a72606610ee79c458cee32b9ea34c16695c6b
Parents: ccc549e
Author: Jack Bates <ja...@nottheoilrig.com>
Authored: Thu Mar 13 14:02:19 2014 -0700
Committer: James Peach <jp...@apache.org>
Committed: Fri Mar 28 16:23:54 2014 -0700
----------------------------------------------------------------------
plugins/experimental/metalink/metalink.cc | 4 ++++
1 file changed, 4 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/trafficserver/blob/f88a7260/plugins/experimental/metalink/metalink.cc
----------------------------------------------------------------------
diff --git a/plugins/experimental/metalink/metalink.cc b/plugins/experimental/metalink/metalink.cc
index 8ebd2cc..c7fafcc 100644
--- a/plugins/experimental/metalink/metalink.cc
+++ b/plugins/experimental/metalink/metalink.cc
@@ -338,6 +338,10 @@ vconn_write_ready(TSCont contp, void * /* edata ATS_UNUSED */)
TSVIOReenable(transform_data->output_viop);
+ if (readerp) {
+ TSContCall(TSVIOContGet(input_viop), TS_EVENT_VCONN_WRITE_COMPLETE, input_viop);
+ }
+
/* Write the digest to the cache */
SHA256_Final((unsigned char *) digest, &transform_data->c);