void purgeEntriesByUrl(HttpRequest * req, const char *url);
Client::Client(FwdState *theFwdState): AsyncJob("Client"),
- completed(false),
- currentOffset(0),
- responseBodyBuffer(NULL),
- fwd(theFwdState),
- requestSender(NULL),
+ completed(false),
+ currentOffset(0),
+ responseBodyBuffer(NULL),
+ fwd(theFwdState),
+ requestSender(NULL),
#if USE_ADAPTATION
- adaptedHeadSource(NULL),
- adaptationAccessCheckPending(false),
- startedAdaptation(false),
+ adaptedHeadSource(NULL),
+ adaptationAccessCheckPending(false),
+ startedAdaptation(false),
#endif
- receivedWholeRequestBody(false),
- theVirginReply(NULL),
- theFinalReply(NULL)
+ receivedWholeRequestBody(false),
+ theVirginReply(NULL),
+ theFinalReply(NULL)
{
entry = fwd->entry;
entry->lock("Client");
}
size_t Client::replyBodySpace(const MemBuf &readBuf,
- const size_t minSpace) const
+ const size_t minSpace) const
{
size_t space = readBuf.spaceSize(); // available space w/o heroic measures
if (space < minSpace) {
#if USE_ADAPTATION
if (responseBodyBuffer) {
- return 0; // Stop reading if already overflowed waiting for ICAP to catch up
+ return 0; // Stop reading if already overflowed waiting for ICAP to catch up
}
if (virginBodyDestination != NULL) {
return space;
}
+