aboutsummaryrefslogtreecommitdiffstats
path: root/src/input
diff options
context:
space:
mode:
authorMax Kellermann <max@duempel.org>2011-08-25 19:16:26 +0200
committerMax Kellermann <max@duempel.org>2011-08-25 19:20:28 +0200
commitba31d176c8a58a91ac720486c4af2e591d1b7e43 (patch)
tree791b360e38a56f8ed97c058094fe5442b5f38259 /src/input
parent68edbc3e4a3f164a612437dd3ae4c57771a5fbb6 (diff)
downloadmpd-ba31d176c8a58a91ac720486c4af2e591d1b7e43.tar.gz
mpd-ba31d176c8a58a91ac720486c4af2e591d1b7e43.tar.xz
mpd-ba31d176c8a58a91ac720486c4af2e591d1b7e43.zip
input/curl: eliminate attribute "eof"
Assume the flag is true when the "easy" CURL handle is NULL. That way, we don't need to keep track if CURL has sent us the "DONE" information yet.
Diffstat (limited to 'src/input')
-rw-r--r--src/input/curl_input_plugin.c15
1 files changed, 4 insertions, 11 deletions
diff --git a/src/input/curl_input_plugin.c b/src/input/curl_input_plugin.c
index 76d8fe8f7..f344c3f11 100644
--- a/src/input/curl_input_plugin.c
+++ b/src/input/curl_input_plugin.c
@@ -82,9 +82,6 @@ struct input_curl {
/** has something been added to the buffers list? */
bool buffered;
- /** did libcurl tell us the we're at the end of the response body? */
- bool eof;
-
/** error message provided by libcurl */
char error[CURL_ERROR_SIZE];
@@ -207,7 +204,6 @@ input_curl_easy_free(struct input_curl *c)
g_free(c->range);
c->range = NULL;
- c->eof = true;
c->base.ready = true;
}
@@ -285,7 +281,7 @@ input_curl_select(struct input_curl *c, GError **error_r)
.tv_usec = 0,
};
- assert(!c->eof);
+ assert(c->easy != NULL);
FD_ZERO(&rfds);
FD_ZERO(&wfds);
@@ -331,7 +327,7 @@ fill_buffer(struct input_curl *c, GError **error_r)
{
CURLMcode mcode = CURLM_CALL_MULTI_PERFORM;
- while (!c->eof && g_queue_is_empty(c->buffers)) {
+ while (c->easy != NULL && g_queue_is_empty(c->buffers)) {
int running_handles;
bool bret;
@@ -499,7 +495,7 @@ input_curl_eof(G_GNUC_UNUSED struct input_stream *is)
{
struct input_curl *c = (struct input_curl *)is;
- return c->eof && g_queue_is_empty(c->buffers);
+ return c->easy == NULL && g_queue_is_empty(c->buffers);
}
static int
@@ -516,7 +512,7 @@ input_curl_buffer(struct input_stream *is, GError **error_r)
c->buffered = false;
- if (!is->ready && !c->eof)
+ if (!is->ready && c->easy != NULL)
/* not ready yet means the caller is waiting in a busy
loop; relax that by calling select() on the
socket */
@@ -656,8 +652,6 @@ input_curl_easy_init(struct input_curl *c, GError **error_r)
CURLcode code;
CURLMcode mcode;
- c->eof = false;
-
c->easy = curl_easy_init();
if (c->easy == NULL) {
g_set_error(error_r, curl_quark(), 0,
@@ -810,7 +804,6 @@ input_curl_seek(struct input_stream *is, goffset offset, int whence,
/* seek to EOF: simulate empty result; avoid
triggering a "416 Requested Range Not Satisfiable"
response */
- c->eof = true;
return true;
}