return;
}
+ assert(context->http);
+ context->http->out.size += size;
+
switch (context->socketState()) {
case STREAM_NONE:
debugs(33, 3, "Keep going");
}
ConnStateData *const connState = static_cast<ConnStateData*>(data);
+ ClientSocketContext::Pointer context = connState->getCurrentContext();
+ if (context != NULL && context->http) {
+ context->http->out.size += size;
+ context->http->out.headers_sz += size;
+ }
+
connState->flags.readMore = true;
connState->readSomeData();
}
static_cast<ClientSocketContext*>(data);
ConnStateData *const connState = context->getConn();
+ assert(context->http);
+ context->http->out.size += size;
+ context->http->out.headers_sz += size;
+
if (connState->ftp.state == ConnStateData::FTP_ERROR) {
debugs(33, 5, "closing on FTP server error");
conn->close();