summaryrefslogtreecommitdiff
path: root/methods
diff options
context:
space:
mode:
authorMichael Vogt <michael.vogt@ubuntu.com>2005-10-17 14:33:58 +0000
committerMichael Vogt <michael.vogt@ubuntu.com>2005-10-17 14:33:58 +0000
commitcec6091772ae3463cb04c417e3f598f9b6814516 (patch)
treeabc6b9a54e3dd8dfc938eadb12368a1cc74d15c6 /methods
parent2d4722e202421007bc34f5439ab4a7cd0bd1148f (diff)
* removed the URL-Reamp hack (we have pdiff support in the main archive now), removed bw-limit support (NO idea how that got into this archive in the first place)
Diffstat (limited to 'methods')
-rw-r--r--methods/http.cc38
-rw-r--r--methods/http.h5
2 files changed, 1 insertions, 42 deletions
diff --git a/methods/http.cc b/methods/http.cc
index 2ec1fe631..e2337a9ba 100644
--- a/methods/http.cc
+++ b/methods/http.cc
@@ -59,11 +59,6 @@ unsigned long TimeOut = 120;
bool Debug = false;
-unsigned long CircleBuf::BwReadLimit=0;
-unsigned long CircleBuf::BwTickReadData=0;
-struct timeval CircleBuf::BwReadTick={0,0};
-const unsigned int CircleBuf::BW_HZ=10;
-
// CircleBuf::CircleBuf - Circular input buffer /*{{{*/
// ---------------------------------------------------------------------
/* */
@@ -71,8 +66,6 @@ CircleBuf::CircleBuf(unsigned long Size) : Size(Size), Hash(0)
{
Buf = new unsigned char[Size];
Reset();
-
- CircleBuf::BwReadLimit = _config->FindI("Acquire::http::DlLimit",0)*1024;
}
/*}}}*/
// CircleBuf::Reset - Reset to the default state /*{{{*/
@@ -98,45 +91,16 @@ void CircleBuf::Reset()
is non-blocking.. */
bool CircleBuf::Read(int Fd)
{
- unsigned long BwReadMax;
-
while (1)
{
// Woops, buffer is full
if (InP - OutP == Size)
return true;
- // what's left to read in this tick
- BwReadMax = CircleBuf::BwReadLimit/BW_HZ;
-
- if(CircleBuf::BwReadLimit) {
- struct timeval now;
- gettimeofday(&now,0);
-
- unsigned long d = (now.tv_sec-CircleBuf::BwReadTick.tv_sec)*1000000 +
- now.tv_usec-CircleBuf::BwReadTick.tv_usec;
- if(d > 1000000/BW_HZ) {
- CircleBuf::BwReadTick = now;
- CircleBuf::BwTickReadData = 0;
- }
-
- if(CircleBuf::BwTickReadData >= BwReadMax) {
- usleep(1000000/BW_HZ);
- return true;
- }
- }
-
// Write the buffer segment
int Res;
- if(CircleBuf::BwReadLimit) {
- Res = read(Fd,Buf + (InP%Size),
- BwReadMax > LeftRead() ? LeftRead() : BwReadMax);
- } else
- Res = read(Fd,Buf + (InP%Size),LeftRead());
+ Res = read(Fd,Buf + (InP%Size),LeftRead());
- if(Res > 0 && BwReadLimit > 0)
- CircleBuf::BwTickReadData += Res;
-
if (Res == 0)
return false;
if (Res < 0)
diff --git a/methods/http.h b/methods/http.h
index 541e2952c..c5a4d0e86 100644
--- a/methods/http.h
+++ b/methods/http.h
@@ -31,11 +31,6 @@ 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);