Official code forgot to start the BodySink job

The code probably worked fine because BodySink::start() does nothing
as the job is a passive consumer.

Discovered due to the new started_ assertion in AsyncJob::callEnd().

diff --git a/src/BodyPipe.cc b/src/BodyPipe.cc
index 012ecb984a233b9cd8ac100aaea7e4871d38b142..96c78e11f14f1b6684820028a268b83eedf84d39 100644 (file)
--- a/src/BodyPipe.cc
+++ b/src/BodyPipe.cc
@@ -335,6 +335,7 @@ BodyPipe::startAutoConsumptionIfNeeded()
         return;
 
     theConsumer = new BodySink(this);
+    AsyncJob::Start(theConsumer);
     debugs(91,7, HERE << "starting auto consumption" << status());
     scheduleBodyDataNotification();
 }