---------------------
PatchSet 6207 
Date: 2007/11/29 20:39:37
Author: rousskov
Branch: async-calls
Tag: (none) 
Log:
Synced after s/scheduleJobCall/ScheduleCallHere/

Members: 
	src/BodyPipe.cc:1.7.4.6->1.7.4.7 

Index: squid3/src/BodyPipe.cc
===================================================================
RCS file: /cvsroot/squid-sf//squid3/src/BodyPipe.cc,v
retrieving revision 1.7.4.6
retrieving revision 1.7.4.7
diff -u -r1.7.4.6 -r1.7.4.7
--- squid3/src/BodyPipe.cc	28 Nov 2007 21:12:52 -0000	1.7.4.6
+++ squid3/src/BodyPipe.cc	29 Nov 2007 20:39:37 -0000	1.7.4.7
@@ -242,7 +242,7 @@
 		theCCallsToSkip = theCCallsPending; // skip all pending consumer calls
 		if (consumedSize() && !exhausted()){
 		    AsyncCall *call= new BodyProducerCall(theProducer, &BodyProducer::noteBodyConsumerAborted, this, "BodyProducer::noteBodyConsumerAborted");
-		    scheduleJobCall(91,5, call);
+		    ScheduleCallHere(call);
 		}
 	}
 }
@@ -324,7 +324,7 @@
 	debugs(91,7, HERE << "consumed " << size << " bytes" << status());
 	if (mayNeedMoreData()){
 	    AsyncCall *call= new BodyProducerCall(theProducer, &BodyProducer::noteMoreBodySpaceAvailable, this, "BodyProducer::noteMoreBodySpaceAvailable");
-	    scheduleJobCall(91,5, call);
+	    ScheduleCallHere(call);
 	}
 }
 
@@ -349,7 +349,7 @@
 	if (theConsumer || mustAutoConsume) {
 		++theCCallsPending;
 		AsyncCall *call= new BodyConsumerCall(theConsumer, &BodyConsumer::noteMoreBodyDataAvailable, this, "BodyConsumer::noteMoreBodyDataAvailable");
-		scheduleJobCall(91,5, call);
+		ScheduleCallHere(call);
 	}
 }
 
@@ -360,11 +360,11 @@
 		++theCCallsPending;
 		if (bodySizeKnown() && bodySize() == thePutSize) {
 		    AsyncCall *call= new BodyConsumerCall(theConsumer, &BodyConsumer::noteBodyProductionEnded, this, "BodyConsumer::noteBodyProductionEnded");
-		    scheduleJobCall(91,5, call);
+		    ScheduleCallHere(call);
 		}
 		else{
 		    AsyncCall *call= new BodyConsumerCall(theConsumer, &BodyConsumer::noteBodyProducerAborted, this, "BodyConsumer::noteBodyProducerAborted");
-		    scheduleJobCall(91,5, call);
+		    ScheduleCallHere(call);
 		}
 	}
 }