and rename clientHttpRequest to ClientHttpRequest everywhere.
/*
- * $Id: DelayId.cc,v 1.16 2005/06/09 16:04:30 serassio Exp $
+ * $Id: DelayId.cc,v 1.17 2005/09/09 17:31:33 wessels Exp $
*
* DEBUG: section 77 Delay Pools
* AUTHOR: Robert Collins <robertc@squid-cache.org>
/* create a delay Id for a given request */
DelayId
-DelayId::DelayClient(clientHttpRequest * http)
+DelayId::DelayClient(ClientHttpRequest * http)
{
HttpRequest *r;
unsigned short pool;
/*
- * $Id: ESI.cc,v 1.16 2005/09/01 18:53:51 serassio Exp $
+ * $Id: ESI.cc,v 1.17 2005/09/09 17:31:33 wessels Exp $
*
* DEBUG: section 86 ESI processing
* AUTHOR: Robert Collins
/* Local functions */
/* ESIContext */
-static ESIContext *ESIContextNew(HttpReply *, clientStreamNode *, clientHttpRequest *);
+static ESIContext *ESIContextNew(HttpReply *, clientStreamNode *, ClientHttpRequest *);
void *
/* request from downstream for more data
*/
void
-esiStreamRead (clientStreamNode *thisNode, clientHttpRequest *http)
+esiStreamRead (clientStreamNode *thisNode, ClientHttpRequest *http)
{
clientStreamNode *next;
/* Test preconditions */
}
clientStream_status_t
-esiStreamStatus (clientStreamNode *thisNode, clientHttpRequest *http)
+esiStreamStatus (clientStreamNode *thisNode, ClientHttpRequest *http)
{
/* Test preconditions */
assert (thisNode != NULL);
/* Detach event from a client Stream */
void
-esiStreamDetach (clientStreamNode *thisNode, clientHttpRequest *http)
+esiStreamDetach (clientStreamNode *thisNode, ClientHttpRequest *http)
{
/* if we have pending callbacks, tell them we're done. */
/* test preconditions */
* There is context data or a reply structure
*/
void
-esiProcessStream (clientStreamNode *thisNode, clientHttpRequest *http, HttpReply *rep, StoreIOBuffer recievedData)
+esiProcessStream (clientStreamNode *thisNode, ClientHttpRequest *http, HttpReply *rep, StoreIOBuffer recievedData)
{
/* test preconditions */
assert (thisNode != NULL);
}
ESIContext *
-ESIContextNew (HttpReply *rep, clientStreamNode *thisNode, clientHttpRequest *http)
+ESIContextNew (HttpReply *rep, clientStreamNode *thisNode, ClientHttpRequest *http)
{
assert (rep);
ESIContext *rv = new ESIContext;
/*
- * $Id: ESIInclude.cc,v 1.6 2005/07/03 15:25:08 serassio Exp $
+ * $Id: ESIInclude.cc,v 1.7 2005/09/09 17:31:33 wessels Exp $
*
* DEBUG: section 86 ESI processing
* AUTHOR: Robert Collins
/* Detach from a buffering stream
*/
void
-esiBufferDetach (clientStreamNode *node, clientHttpRequest *http)
+esiBufferDetach (clientStreamNode *node, ClientHttpRequest *http)
{
/* Detach ourselves */
clientStreamDetach (node, http);
* There are no more entries in the stream chain.
*/
void
-esiBufferRecipient (clientStreamNode *node, clientHttpRequest *http, HttpReply *rep, StoreIOBuffer recievedData)
+esiBufferRecipient (clientStreamNode *node, ClientHttpRequest *http, HttpReply *rep, StoreIOBuffer recievedData)
{
/* Test preconditions */
assert (node != NULL);
/*
- * $Id: clientStream.cc,v 1.11 2004/12/20 16:30:35 robertc Exp $
+ * $Id: clientStream.cc,v 1.12 2005/09/09 17:31:33 wessels Exp $
*
* DEBUG: section 87 Client-side Stream routines.
* AUTHOR: Robert Collins
* Callback the next node the in chain with it's requested data
*/
void
-clientStreamCallback(clientStreamNode * thisObject, clientHttpRequest * http,
+clientStreamCallback(clientStreamNode * thisObject, ClientHttpRequest * http,
HttpReply * rep, StoreIOBuffer replyBuffer)
{
clientStreamNode *next;
* Call the previous node in the chain to read some data
*/
void
-clientStreamRead(clientStreamNode * thisObject, clientHttpRequest * http,
+clientStreamRead(clientStreamNode * thisObject, ClientHttpRequest * http,
StoreIOBuffer readBuffer)
{
/* place the parameters on the 'stack' */
* Detach from the stream - only allowed for terminal members
*/
void
-clientStreamDetach(clientStreamNode * thisObject, clientHttpRequest * http)
+clientStreamDetach(clientStreamNode * thisObject, ClientHttpRequest * http)
{
clientStreamNode *temp = thisObject;
* Abort the stream - detach every node in the pipeline.
*/
void
-clientStreamAbort(clientStreamNode * thisObject, clientHttpRequest * http)
+clientStreamAbort(clientStreamNode * thisObject, ClientHttpRequest * http)
{
dlink_list *list;
* Call the upstream node to find it's status
*/
clientStream_status_t
-clientStreamStatus(clientStreamNode * thisObject, clientHttpRequest * http)
+clientStreamStatus(clientStreamNode * thisObject, ClientHttpRequest * http)
{
clientStreamNode *prev;
assert(thisObject && http && thisObject->node.prev);
/*
- * $Id: client_side.cc,v 1.690 2005/08/31 19:15:35 wessels Exp $
+ * $Id: client_side.cc,v 1.691 2005/09/09 17:31:33 wessels Exp $
*
* DEBUG: section 33 Client-side Routines
* AUTHOR: Duane Wessels
* data, or sending it.
*
* ClientKeepAliveNextRequest will then detect the presence of data in
- * the next clientHttpRequest, and will send it, restablishing the
+ * the next ClientHttpRequest, and will send it, restablishing the
* data flow.
*/
/* Local functions */
/* ClientSocketContext */
-static ClientSocketContext *ClientSocketContextNew(clientHttpRequest *);
+static ClientSocketContext *ClientSocketContextNew(ClientHttpRequest *);
/* other */
static CWCB clientWriteComplete;
static IOWCB clientWriteBodyComplete;
#endif
static CSCB clientSocketRecipient;
static CSD clientSocketDetach;
-static void clientSetKeepaliveFlag(clientHttpRequest *);
+static void clientSetKeepaliveFlag(ClientHttpRequest *);
static int clientIsContentLengthValid(HttpRequest * r);
static bool okToAccept();
static int clientIsRequestBodyValid(int bodyLength);
static void trimTrailingSpaces(char *aString, size_t len);
#endif
static ClientSocketContext *parseURIandHTTPVersion(char **url_p, HttpVersion * http_ver_p, ConnStateData::Pointer& conn, char *http_version_str);
-static void setLogUri(clientHttpRequest * http, char const *uri);
+static void setLogUri(ClientHttpRequest * http, char const *uri);
static int connReadWasError(ConnStateData::Pointer& conn, comm_err_t, int size, int xerrno);
static int connFinishedWithConn(ConnStateData::Pointer& conn, int size);
static void connNoteUseOfBuffer(ConnStateData::Pointer & conn, size_t byteCount);
}
ClientSocketContext *
-ClientSocketContextNew(clientHttpRequest * http)
+ClientSocketContextNew(ClientHttpRequest * http)
{
ClientSocketContext *newContext;
assert(http != NULL);
void
httpRequestFree(void *data)
{
- clientHttpRequest *http = (clientHttpRequest *)data;
+ ClientHttpRequest *http = (ClientHttpRequest *)data;
assert(http != NULL);
delete http;
}
* to handle hacks for broken servers and clients.
*/
static void
-clientSetKeepaliveFlag(clientHttpRequest * http)
+clientSetKeepaliveFlag(ClientHttpRequest * http)
{
HttpRequest *request = http->request;
const HttpHeader *req_hdr = &request->header;
* returns true if If-Range specs match reply, false otherwise
*/
static int
-clientIfRangeMatch(clientHttpRequest * http, HttpReply * rep)
+clientIfRangeMatch(ClientHttpRequest * http, HttpReply * rep)
{
const TimeOrTag spec = httpHeaderGetTimeOrTag(&http->request->header, HDR_IF_RANGE);
/* check for parsing falure */
* There are no more entries in the stream chain.
*/
static void
-clientSocketRecipient(clientStreamNode * node, clientHttpRequest * http,
+clientSocketRecipient(clientStreamNode * node, ClientHttpRequest * http,
HttpReply * rep, StoreIOBuffer recievedData)
{
int fd;
* only
*/
void
-clientSocketDetach(clientStreamNode * node, clientHttpRequest * http)
+clientSocketDetach(clientStreamNode * node, ClientHttpRequest * http)
{
/* Test preconditions */
assert(node != NULL);
static ClientSocketContext *
parseHttpRequestAbort(ConnStateData::Pointer & conn, const char *uri)
{
- clientHttpRequest *http;
+ ClientHttpRequest *http;
ClientSocketContext *context;
StoreIOBuffer tempBuffer;
http = new ClientHttpRequest;
}
void
-setLogUri(clientHttpRequest * http, char const *uri)
+setLogUri(ClientHttpRequest * http, char const *uri)
{
safe_free(http->log_uri);
}
static void
-prepareAcceleratedURL(ConnStateData::Pointer & conn, clientHttpRequest *http, char *url, const char *req_hdr)
+prepareAcceleratedURL(ConnStateData::Pointer & conn, ClientHttpRequest *http, char *url, const char *req_hdr)
{
int vhost = conn->port->vhost;
int vport = conn->port->vport;
}
static void
-prepareTransparentURL(ConnStateData::Pointer & conn, clientHttpRequest *http, char *url, const char *req_hdr)
+prepareTransparentURL(ConnStateData::Pointer & conn, ClientHttpRequest *http, char *url, const char *req_hdr)
{
char *host;
size_t header_sz; /* size of headers, not including first line */
size_t prefix_sz; /* size of whole request (req-line + headers) */
size_t req_sz;
- clientHttpRequest *http;
+ ClientHttpRequest *http;
ClientSocketContext *result;
StoreIOBuffer tempBuffer;
char *http_version;
static void
clientProcessRequest(ConnStateData::Pointer &conn, ClientSocketContext *context, method_t method, char *prefix, size_t req_line_sz)
{
- clientHttpRequest *http = context->http;
+ ClientHttpRequest *http = context->http;
HttpRequest *request = NULL;
/* We have an initial client stream in place should it be needed */
/* setup our private context */
/*
* Generate an error
*/
- clientHttpRequest **H;
+ ClientHttpRequest **H;
clientStreamNode *node;
- clientHttpRequest *http =
+ ClientHttpRequest *http =
parseHttpRequestAbort(conn, "error:Connection%20lifetime%20expired");
node = http->client_stream.tail->prev->data;
clientReplyContext *repContext = dynamic_cast<clientReplyContext *>(node->data.getRaw());
static void
clientLifetimeTimeout(int fd, void *data)
{
- clientHttpRequest *http = (clientHttpRequest *)data;
+ ClientHttpRequest *http = (ClientHttpRequest *)data;
debug(33,
1) ("WARNING: Closing client %s connection due to lifetime timeout\n",
inet_ntoa(http->getConn()->peer.sin_addr));
}
ACLChecklist *
-clientAclChecklistCreate(const acl_access * acl, clientHttpRequest * http)
+clientAclChecklistCreate(const acl_access * acl, ClientHttpRequest * http)
{
ACLChecklist *ch;
ConnStateData::Pointer conn = http->getConn();
/*
- * $Id: client_side_reply.cc,v 1.85 2005/08/14 20:34:54 serassio Exp $
+ * $Id: client_side_reply.cc,v 1.86 2005/09/09 17:31:33 wessels Exp $
*
* DEBUG: section 88 Client-side Reply Routines
* AUTHOR: Robert Collins (Originally Duane Wessels in client_side.c)
cbdataReferenceDone(http);
}
-clientReplyContext::clientReplyContext(clientHttpRequest *clientContext) : http (cbdataReference(clientContext)), old_entry (NULL), old_sc(NULL), deleting(false)
+clientReplyContext::clientReplyContext(ClientHttpRequest *clientContext) : http (cbdataReference(clientContext)), old_entry (NULL), old_sc(NULL), deleting(false)
{}
/* create an error in the store awaiting the client side to read it. */
*
*/
int
-clientHttpRequestStatus(int fd, clientHttpRequest const *http)
+clientHttpRequestStatus(int fd, ClientHttpRequest const *http)
{
#if SIZEOF_SIZE_T == 4
* of the object.
*/
clientStream_status_t
-clientReplyStatus(clientStreamNode * aNode, clientHttpRequest * http)
+clientReplyStatus(clientStreamNode * aNode, ClientHttpRequest * http)
{
clientReplyContext *context = dynamic_cast<clientReplyContext *>(aNode->data.getRaw());
assert (context);
* data context is not null
*/
void
-clientGetMoreData(clientStreamNode * aNode, clientHttpRequest * http)
+clientGetMoreData(clientStreamNode * aNode, ClientHttpRequest * http)
{
/* Test preconditions */
assert(aNode != NULL);
/* the next node has removed itself from the stream. */
void
-clientReplyDetach(clientStreamNode * node, clientHttpRequest * http)
+clientReplyDetach(clientStreamNode * node, ClientHttpRequest * http)
{
/* detach from the stream */
clientStreamDetach(node, http);
/*
- * $Id: client_side_reply.h,v 1.7 2005/04/18 21:52:42 hno Exp $
+ * $Id: client_side_reply.h,v 1.8 2005/09/09 17:31:33 wessels Exp $
*
*
* SQUID Web Proxy Cache http://www.squid-cache.org/
static STCB HandleIMSReply;
static STCB SendMoreData;
- clientReplyContext(clientHttpRequest *);
+ clientReplyContext(ClientHttpRequest *);
~clientReplyContext();
void saveState();
int lookingforstore;
virtual void created (StoreEntry *newEntry);
- clientHttpRequest *http;
+ ClientHttpRequest *http;
int headers_sz;
store_client *sc; /* The store_client we're using */
StoreIOBuffer tempBuffer; /* For use in validating requests via IMS */
/*
- * $Id: client_side_request.cc,v 1.44 2005/03/06 21:08:13 serassio Exp $
+ * $Id: client_side_request.cc,v 1.45 2005/09/09 17:31:33 wessels Exp $
*
* DEBUG: section 85 Client-side Request Routines
* AUTHOR: Robert Collins (Originally Duane Wessels in client_side.c)
ACLChecklist *acl_checklist; /* need ptr back so we can unreg if needed */
int redirect_state;
- clientHttpRequest *http;
+ ClientHttpRequest *http;
private:
CBDATA_CLASS(ClientRequestContext);
/* Local functions */
/* other */
static void clientAccessCheckDone(int, void *);
-static int clientCachable(clientHttpRequest * http);
-static int clientHierarchical(clientHttpRequest * http);
-static void clientInterpretRequestHeaders(clientHttpRequest * http);
+static int clientCachable(ClientHttpRequest * http);
+static int clientHierarchical(ClientHttpRequest * http);
+static void clientInterpretRequestHeaders(ClientHttpRequest * http);
static void clientRedirectStart(ClientRequestContext *context);
static RH clientRedirectDone;
extern "C" CSR clientGetMoreData;
{
size_t url_sz;
HttpVersion http_ver (1, 0);
- clientHttpRequest *http = new ClientHttpRequest;
+ ClientHttpRequest *http = new ClientHttpRequest;
HttpRequest *request;
StoreIOBuffer tempBuffer;
http->http_ver = http_ver;
ClientRequestContext *context = (ClientRequestContext *)data;
context->acl_checklist = NULL;
- clientHttpRequest *http_ = context->http;
+ ClientHttpRequest *http_ = context->http;
if (!cbdataReferenceValid (http_)) {
delete context;
return;
}
- clientHttpRequest *http = context->http;
+ ClientHttpRequest *http = context->http;
err_type page_id;
http_status status;
debug(85, 2) ("The request %s %s is %s, because it matched '%s'\n",
clientRedirectAccessCheckDone(int answer, void *data)
{
ClientRequestContext *context = (ClientRequestContext *)data;
- clientHttpRequest *http = context->http;
+ ClientHttpRequest *http = context->http;
context->acl_checklist = NULL;
if (answer == ACCESS_ALLOWED)
static void
clientRedirectStart(ClientRequestContext *context)
{
- clientHttpRequest *http = context->http;
+ ClientHttpRequest *http = context->http;
debug(33, 5) ("clientRedirectStart: '%s'\n", http->uri);
if (Config.Program.redirect == NULL) {
}
static int
-clientCachable(clientHttpRequest * http)
+clientCachable(ClientHttpRequest * http)
{
HttpRequest *req = http->request;
method_t method = req->method;
}
static int
-clientHierarchical(clientHttpRequest * http)
+clientHierarchical(ClientHttpRequest * http)
{
const char *url = http->uri;
HttpRequest *request = http->request;
static void
-clientInterpretRequestHeaders(clientHttpRequest * http)
+clientInterpretRequestHeaders(ClientHttpRequest * http)
{
HttpRequest *request = http->request;
const HttpHeader *req_hdr = &request->header;
clientRedirectDone(void *data, char *result)
{
ClientRequestContext *context = (ClientRequestContext *)data;
- clientHttpRequest *http_ = context->http;
+ ClientHttpRequest *http_ = context->http;
if (!cbdataReferenceValid (http_)) {
delete context;
return;
}
- clientHttpRequest *http = context->http;
+ ClientHttpRequest *http = context->http;
HttpRequest *new_request = NULL;
HttpRequest *old_request = http->request;
debug(85, 5) ("clientRedirectDone: '%s' result=%s\n", http->uri,
ClientRequestContext::checkNoCacheDone(int answer)
{
acl_checklist = NULL;
- clientHttpRequest *http_ = http;
+ ClientHttpRequest *http_ = http;
if (!cbdataReferenceValid (http_)) {
delete this;
/*
- * $Id: client_side_request.h,v 1.19 2003/09/01 03:49:38 robertc Exp $
+ * $Id: client_side_request.h,v 1.20 2005/09/09 17:31:33 wessels Exp $
*
*
* SQUID Web Proxy Cache http://www.squid-cache.org/
class MemObject;
-typedef class ClientHttpRequest clientHttpRequest;
-
class ConnStateData;
class ClientHttpRequest
};
/* client http based routines */
-SQUIDCEXTERN char *clientConstructTraceEcho(clientHttpRequest *);
+SQUIDCEXTERN char *clientConstructTraceEcho(ClientHttpRequest *);
SQUIDCEXTERN ACLChecklist *clientAclChecklistCreate(const acl_access * acl,ClientHttpRequest * http);
-SQUIDCEXTERN int clientHttpRequestStatus(int fd, clientHttpRequest const *http);
+SQUIDCEXTERN int clientHttpRequestStatus(int fd, ClientHttpRequest const *http);
SQUIDCEXTERN void clientAccessCheck(ClientHttpRequest *);
/* ones that should be elsewhere */
-SQUIDCEXTERN void redirectStart(clientHttpRequest *, RH *, void *);
+SQUIDCEXTERN void redirectStart(ClientHttpRequest *, RH *, void *);
-SQUIDCEXTERN void sslStart(clientHttpRequest *, size_t *, int *);
+SQUIDCEXTERN void sslStart(ClientHttpRequest *, size_t *, int *);
#ifdef _USE_INLINE_
#include "Store.h"
/*
- * $Id: redirect.cc,v 1.110 2005/04/18 21:52:43 hno Exp $
+ * $Id: redirect.cc,v 1.111 2005/09/09 17:31:33 wessels Exp $
*
* DEBUG: section 61 Redirector
* AUTHOR: Duane Wessels
/**** PUBLIC FUNCTIONS ****/
void
-redirectStart(clientHttpRequest * http, RH * handler, void *data)
+redirectStart(ClientHttpRequest * http, RH * handler, void *data)
{
ConnStateData::Pointer conn = http->getConn();
redirectStateData *r = NULL;
/*
- * $Id: stat.cc,v 1.389 2005/05/15 10:33:49 serassio Exp $
+ * $Id: stat.cc,v 1.390 2005/09/09 17:31:33 wessels Exp $
*
* DEBUG: section 18 Cache Manager Statistics
* AUTHOR: Harvest Derived
statClientRequests(StoreEntry * s)
{
dlink_node *i;
- clientHttpRequest *http;
+ ClientHttpRequest *http;
StoreEntry *e;
int fd;
for (i = ClientActiveRequests.head; i; i = i->next) {
- http = static_cast<clientHttpRequest *>(i->data);
+ http = static_cast<ClientHttpRequest *>(i->data);
assert(http);
ConnStateData::Pointer conn = http->getConn();
storeAppendPrintf(s, "Connection: %p\n", conn.getRaw());
/*
- * $Id: tunnel.cc,v 1.151 2005/08/31 19:15:36 wessels Exp $
+ * $Id: tunnel.cc,v 1.152 2005/09/09 17:31:33 wessels Exp $
*
* DEBUG: section 26 Secure Sockets Layer Proxy
* AUTHOR: Duane Wessels
}
void
-sslStart(clientHttpRequest * http, size_t * size_ptr, int *status_ptr)
+sslStart(ClientHttpRequest * http, size_t * size_ptr, int *status_ptr)
{
/* Create state structure. */
SslStateData *sslState = NULL;