]> git.saurik.com Git - apt.git/blame - methods/http.h
Fix typo
[apt.git] / methods / http.h
CommitLineData
be4401bf 1// -*- mode: cpp; mode: fold -*-
a305f593
AL
2// Description /*{{{*/// $Id: http.h,v 1.12 2002/04/18 05:09:38 jgg Exp $
3// $Id: http.h,v 1.12 2002/04/18 05:09:38 jgg Exp $
be4401bf
AL
4/* ######################################################################
5
ae58a985 6 HTTP Acquire Method - This is the HTTP aquire method for APT.
be4401bf
AL
7
8 ##################################################################### */
9 /*}}}*/
10
11#ifndef APT_HTTP_H
12#define APT_HTTP_H
13
14#define MAXLEN 360
15
42195eb2
AL
16#include <iostream>
17
18using std::cout;
19using std::endl;
20
be4401bf
AL
21class HttpMethod;
22
23class CircleBuf
24{
25 unsigned char *Buf;
26 unsigned long Size;
27 unsigned long InP;
28 unsigned long OutP;
29 string OutQueue;
30 unsigned long StrPos;
31 unsigned long MaxGet;
32 struct timeval Start;
33
7c6e2dc7
MV
34 static unsigned long BwReadLimit;
35 static unsigned long BwTickReadData;
36 static struct timeval BwReadTick;
37 static const unsigned int BW_HZ;
38
be4401bf
AL
39 unsigned long LeftRead()
40 {
41 unsigned long Sz = Size - (InP - OutP);
42 if (Sz > Size - (InP%Size))
43 Sz = Size - (InP%Size);
44 return Sz;
45 }
46 unsigned long LeftWrite()
47 {
48 unsigned long Sz = InP - OutP;
49 if (InP > MaxGet)
50 Sz = MaxGet - OutP;
51 if (Sz > Size - (OutP%Size))
52 Sz = Size - (OutP%Size);
53 return Sz;
54 }
55 void FillOut();
56
57 public:
58
63b1700f 59 Hashes *Hash;
be4401bf
AL
60
61 // Read data in
62 bool Read(int Fd);
63 bool Read(string Data);
64
65 // Write data out
66 bool Write(int Fd);
67 bool WriteTillEl(string &Data,bool Single = false);
68
69 // Control the write limit
70 void Limit(long Max) {if (Max == -1) MaxGet = 0-1; else MaxGet = OutP + Max;}
71 bool IsLimit() {return MaxGet == OutP;};
72 void Print() {cout << MaxGet << ',' << OutP << endl;};
73
74 // Test for free space in the buffer
75 bool ReadSpace() {return Size - (InP - OutP) > 0;};
76 bool WriteSpace() {return InP - OutP > 0;};
77
78 // Dump everything
79 void Reset();
80 void Stats();
81
82 CircleBuf(unsigned long Size);
a305f593 83 ~CircleBuf() {delete [] Buf; delete Hash;};
be4401bf
AL
84};
85
86struct ServerState
87{
88 // This is the last parsed Header Line
89 unsigned int Major;
90 unsigned int Minor;
91 unsigned int Result;
92 char Code[MAXLEN];
93
92e889c8 94 // These are some statistics from the last parsed header lines
be4401bf
AL
95 unsigned long Size;
96 signed long StartPos;
97 time_t Date;
92e889c8 98 bool HaveContent;
be4401bf
AL
99 enum {Chunked,Stream,Closes} Encoding;
100 enum {Header, Data} State;
e836f356 101 bool Persistent;
09fab244 102 string Location;
e836f356
AL
103
104 // This is a Persistent attribute of the server itself.
f93d1355 105 bool Pipeline;
be4401bf
AL
106
107 HttpMethod *Owner;
108
109 // This is the connection itself. Output is data FROM the server
110 CircleBuf In;
111 CircleBuf Out;
112 int ServerFd;
113 URI ServerName;
114
115 bool HeaderLine(string Line);
116 bool Comp(URI Other) {return Other.Host == ServerName.Host && Other.Port == ServerName.Port;};
117 void Reset() {Major = 0; Minor = 0; Result = 0; Size = 0; StartPos = 0;
f93d1355
AL
118 Encoding = Closes; time(&Date); ServerFd = -1;
119 Pipeline = true;};
92e889c8 120 int RunHeaders();
be4401bf
AL
121 bool RunData();
122
123 bool Open();
124 bool Close();
125
126 ServerState(URI Srv,HttpMethod *Owner);
127 ~ServerState() {Close();};
128};
129
130class HttpMethod : public pkgAcqMethod
131{
132 void SendReq(FetchItem *Itm,CircleBuf &Out);
133 bool Go(bool ToFile,ServerState *Srv);
134 bool Flush(ServerState *Srv);
135 bool ServerDie(ServerState *Srv);
136 int DealWithHeaders(FetchResult &Res,ServerState *Srv);
5cb5d8dc 137
85f72a56
AL
138 virtual bool Fetch(FetchItem *);
139 virtual bool Configuration(string Message);
be4401bf 140
492f957a
AL
141 // In the event of a fatal signal this file will be closed and timestamped.
142 static string FailFile;
143 static int FailFd;
144 static time_t FailTime;
145 static void SigTerm(int);
146
09fab244
MV
147 string NextURI;
148
be4401bf 149 public:
b2e465d6 150 friend class ServerState;
be4401bf 151
be4401bf 152 FileFd *File;
5cb5d8dc 153 ServerState *Server;
be4401bf
AL
154
155 int Loop();
156
b98f2859 157 HttpMethod() : pkgAcqMethod("1.2",Pipeline | SendConfig)
be4401bf 158 {
be4401bf 159 File = 0;
5cb5d8dc 160 Server = 0;
be4401bf
AL
161 };
162};
163
be4401bf 164#endif