ClientSocketContextPointer context = requests.front();
debugs(33, 3, "Pipeline " << (void*)this << " notify(" << xerrno << ") " << context);
context->noteIoError(xerrno);
- context->connIsFinished(); // cleanup and self-deregister
+ context->finished(); // cleanup and self-deregister
assert(context != requests.front());
}
}
}
void
-ClientSocketContext::connIsFinished()
+ClientSocketContext::finished()
{
assert (http);
assert (http->getConn() != NULL);
debugs(33, 5, conn << " Stream complete, keepalive is " << http->request->flags.proxyKeepalive);
if (!http->request->flags.proxyKeepalive)
clientConnection->close();
- connIsFinished();
+ finished();
return;
case STREAM_UNPLANNED_COMPLETE:
clientStreamNode * getTail() const;
clientStreamNode * getClientReplyContext() const;
ConnStateData *getConn() const;
- void connIsFinished();
+ void finished(); ///< cleanup when the transaction has finished
void deferRecipientForLater(clientStreamNode * node, HttpReply * rep, StoreIOBuffer receivedData);
bool multipartRangeRequest() const;
void registerWithConn();
changeState(fssConnected, "Ftp::Server::wroteReply");
if (bodyParser)
finishDechunkingRequest(false);
- context->connIsFinished();
+ context->finished();
return;
}
}
void ClientSocketContext::buildRangeHeader(HttpReply * rep) STUB
clientStreamNode * ClientSocketContext::getTail() const STUB_RETVAL(NULL)
clientStreamNode * ClientSocketContext::getClientReplyContext() const STUB_RETVAL(NULL)
-void ClientSocketContext::connIsFinished() STUB
+void ClientSocketContext::finished() STUB
void ClientSocketContext::deferRecipientForLater(clientStreamNode * node, HttpReply * rep, StoreIOBuffer receivedData) STUB
bool ClientSocketContext::multipartRangeRequest() const STUB_RETVAL(false)
void ClientSocketContext::registerWithConn() STUB