From f1b8566ea28d1256cf533f5fe07a6662041a6c5d Mon Sep 17 00:00:00 2001 From: Daniel Stenberg Date: Tue, 3 Oct 2000 11:02:52 +0000 Subject: new upload-buffer size design that starts with a smallish buffer and increases its size in case of need --- lib/highlevel.c | 15 ++++++++++++++- 1 file changed, 14 insertions(+), 1 deletion(-) diff --git a/lib/highlevel.c b/lib/highlevel.c index f0a6a6810..c3b6269e1 100644 --- a/lib/highlevel.c +++ b/lib/highlevel.c @@ -112,6 +112,10 @@ #define _MPRINTF_REPLACE /* use our functions only */ #include +#ifndef min +#define min(a, b) ((a) < (b) ? (a) : (b)) +#endif + CURLcode _Transfer(struct connectdata *c_conn) { @@ -522,7 +526,7 @@ _Transfer(struct connectdata *c_conn) if(data->crlf) buf = data->buffer; /* put it back on the buffer */ - nread = data->fread(buf, 1, BUFSIZE, data->in); + nread = data->fread(buf, 1, conn->upload_bufsize, data->in); /* the signed int typecase of nread of for systems that has unsigned size_t */ @@ -570,6 +574,15 @@ _Transfer(struct connectdata *c_conn) if (urg) return urg; + if(data->progress.ulspeed > conn->upload_bufsize) { + /* If we're transfering more data per second than fits in our buffer, + we increase the buffer size to adjust to the current + speed. However, we must not set it larger than BUFSIZE. We don't + adjust it downwards again since we don't see any point in that! + */ + conn->upload_bufsize=(long)min(data->progress.ulspeed, BUFSIZE); + } + if (data->timeout && (tvdiff (now, start) > data->timeout)) { failf (data, "Operation timed out with %d out of %d bytes received", bytecount, conn->size); -- cgit v1.2.3