// -*- mode: cpp; mode: fold -*-
-// Description /*{{{*/// $Id: http.h,v 1.6 1998/12/10 05:39:56 jgg Exp $
+// Description /*{{{*/// $Id: http.h,v 1.12 2002/04/18 05:09:38 jgg Exp $
+// $Id: http.h,v 1.12 2002/04/18 05:09:38 jgg Exp $
/* ######################################################################
- HTTP Aquire Method - This is the HTTP aquire method for APT.
+ HTTP Acquire Method - This is the HTTP aquire method for APT.
##################################################################### */
/*}}}*/
#define MAXLEN 360
+#include <iostream>
+
+using std::cout;
+using std::endl;
+
class HttpMethod;
class CircleBuf
unsigned long MaxGet;
struct timeval Start;
+ static unsigned long BwReadLimit;
+ static unsigned long BwTickReadData;
+ static struct timeval BwReadTick;
+ static const unsigned int BW_HZ;
+
unsigned long LeftRead()
{
unsigned long Sz = Size - (InP - OutP);
public:
- MD5Summation *MD5;
+ Hashes *Hash;
// Read data in
bool Read(int Fd);
void Stats();
CircleBuf(unsigned long Size);
- ~CircleBuf() {delete [] Buf;};
+ ~CircleBuf() {delete [] Buf; delete Hash;};
};
struct ServerState
bool HaveContent;
enum {Chunked,Stream,Closes} Encoding;
enum {Header, Data} State;
+ bool Persistent;
+
+ // This is a Persistent attribute of the server itself.
+ bool Pipeline;
HttpMethod *Owner;
bool HeaderLine(string Line);
bool Comp(URI Other) {return Other.Host == ServerName.Host && Other.Port == ServerName.Port;};
void Reset() {Major = 0; Minor = 0; Result = 0; Size = 0; StartPos = 0;
- Encoding = Closes; time(&Date); ServerFd = -1;};
+ Encoding = Closes; time(&Date); ServerFd = -1;
+ Pipeline = true;};
int RunHeaders();
bool RunData();
static void SigTerm(int);
public:
- friend ServerState;
+ friend class ServerState;
FileFd *File;
ServerState *Server;
};
};
-URI Proxy;
-
#endif