/* * Copyright (C) 2003-2013 The Music Player Daemon Project * http://www.musicpd.org * * This program is free software; you can redistribute it and/or modify * it under the terms of the GNU General Public License as published by * the Free Software Foundation; either version 2 of the License, or * (at your option) any later version. * * This program is distributed in the hope that it will be useful, * but WITHOUT ANY WARRANTY; without even the implied warranty of * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the * GNU General Public License for more details. * * You should have received a copy of the GNU General Public License along * with this program; if not, write to the Free Software Foundation, Inc., * 51 Franklin Street, Fifth Floor, Boston, MA 02110-1301 USA. */ #include "config.h" #include "CurlInputPlugin.hxx" #include "input_plugin.h" #include "conf.h" #include "tag.h" #include "IcyMetaDataParser.hxx" extern "C" { #include "input_internal.h" } #include "IOThread.hxx" #include "glib_compat.h" #include #if defined(WIN32) #include #else #include #endif #include #include #include #include #include #include #if LIBCURL_VERSION_NUM < 0x071200 #error libcurl is too old #endif #undef G_LOG_DOMAIN #define G_LOG_DOMAIN "input_curl" /** * Do not buffer more than this number of bytes. It should be a * reasonable limit that doesn't make low-end machines suffer too * much, but doesn't cause stuttering on high-latency lines. */ static const size_t CURL_MAX_BUFFERED = 512 * 1024; /** * Resume the stream at this number of bytes after it has been paused. */ static const size_t CURL_RESUME_AT = 384 * 1024; /** * Buffers created by input_curl_writefunction(). */ class CurlInputBuffer { /** size of the payload */ size_t size; /** how much has been consumed yet? */ size_t consumed; /** the payload */ uint8_t *data; public: CurlInputBuffer(const void *_data, size_t _size) :size(_size), consumed(0), data(new uint8_t[size]) { memcpy(data, _data, size); } ~CurlInputBuffer() { delete[] data; } CurlInputBuffer(const CurlInputBuffer &) = delete; CurlInputBuffer &operator=(const CurlInputBuffer &) = delete; const void *Begin() const { return data + consumed; } size_t TotalSize() const { return size; } size_t Available() const { return size - consumed; } /** * Mark a part of the buffer as consumed. * * @return false if the buffer is now empty */ bool Consume(size_t length) { assert(consumed < size); consumed += length; if (consumed < size) return true; assert(consumed == size); return false; } bool Read(void *dest, size_t length) { assert(consumed + length <= size); memcpy(dest, data + consumed, length); return Consume(length); } }; struct input_curl { struct input_stream base; /* some buffers which were passed to libcurl, which we have too free */ char *range; struct curl_slist *request_headers; /** the curl handles */ CURL *easy; /** list of buffers, where input_curl_writefunction() appends to, and input_curl_read() reads from them */ std::list buffers; /** * Is the connection currently paused? That happens when the * buffer was getting too large. It will be unpaused when the * buffer is below the threshold again. */ bool paused; /** error message provided by libcurl */ char error[CURL_ERROR_SIZE]; /** parser for icy-metadata */ IcyMetaDataParser icy; /** the stream name from the icy-name response header */ char *meta_name; /** the tag object ready to be requested via input_stream_tag() */ struct tag *tag; GError *postponed_error; input_curl(const char *url, GMutex *mutex, GCond *cond) :range(nullptr), request_headers(nullptr), paused(false), meta_name(nullptr), tag(nullptr), postponed_error(nullptr) { input_stream_init(&base, &input_plugin_curl, url, mutex, cond); } ~input_curl(); input_curl(const input_curl &) = delete; input_curl &operator=(const input_curl &) = delete; }; /** libcurl should accept "ICY 200 OK" */ static struct curl_slist *http_200_aliases; /** HTTP proxy settings */ static const char *proxy, *proxy_user, *proxy_password; static unsigned proxy_port; static struct { CURLM *multi; /** * A linked list of all active HTTP requests. An active * request is one that doesn't have the "eof" flag set. */ std::forward_list requests; /** * The GMainLoop source used to poll all CURL file * descriptors. */ GSource *source; /** * The source id of #source. */ guint source_id; /** a linked list of all registered GPollFD objects */ std::forward_list fds; /** * Did CURL give us a timeout? If yes, then we need to call * curl_multi_perform(), even if there was no event on any * file descriptor. */ bool timeout; /** * The absolute time stamp when the timeout expires. This is * used in the GSource method check(). */ gint64 absolute_timeout; } curl; static inline GQuark curl_quark(void) { return g_quark_from_static_string("curl"); } /** * Find a request by its CURL "easy" handle. * * Runs in the I/O thread. No lock needed. */ static struct input_curl * input_curl_find_request(CURL *easy) { assert(io_thread_inside()); for (auto c : curl.requests) if (c->easy == easy) return c; return NULL; } static gpointer input_curl_resume(gpointer data) { assert(io_thread_inside()); struct input_curl *c = (struct input_curl *)data; if (c->paused) { c->paused = false; curl_easy_pause(c->easy, CURLPAUSE_CONT); } return NULL; } /** * Calculates the GLib event bit mask for one file descriptor, * obtained from three #fd_set objects filled by curl_multi_fdset(). */ static gushort input_curl_fd_events(int fd, fd_set *rfds, fd_set *wfds, fd_set *efds) { gushort events = 0; if (FD_ISSET(fd, rfds)) { events |= G_IO_IN | G_IO_HUP | G_IO_ERR; FD_CLR(fd, rfds); } if (FD_ISSET(fd, wfds)) { events |= G_IO_OUT | G_IO_ERR; FD_CLR(fd, wfds); } if (FD_ISSET(fd, efds)) { events |= G_IO_HUP | G_IO_ERR; FD_CLR(fd, efds); } return events; } /** * Updates all registered GPollFD objects, unregisters old ones, * registers new ones. * * Runs in the I/O thread. No lock needed. */ static void curl_update_fds(void) { assert(io_thread_inside()); fd_set rfds, wfds, efds; FD_ZERO(&rfds); FD_ZERO(&wfds); FD_ZERO(&efds); int max_fd; CURLMcode mcode = curl_multi_fdset(curl.multi, &rfds, &wfds, &efds, &max_fd); if (mcode != CURLM_OK) { g_warning("curl_multi_fdset() failed: %s\n", curl_multi_strerror(mcode)); return; } for (auto prev = curl.fds.before_begin(), end = curl.fds.end(), i = std::next(prev); i != end; i = std::next(prev)) { const auto poll_fd = &*i; assert(poll_fd->events != 0); gushort events = input_curl_fd_events(poll_fd->fd, &rfds, &wfds, &efds); if (events != poll_fd->events) g_source_remove_poll(curl.source, poll_fd); if (events != 0) { if (events != poll_fd->events) { poll_fd->events = events; g_source_add_poll(curl.source, poll_fd); } prev = i; } else { curl.fds.erase_after(prev); } } for (int fd = 0; fd <= max_fd; ++fd) { gushort events = input_curl_fd_events(fd, &rfds, &wfds, &efds); if (events != 0) { curl.fds.push_front(GPollFD()); const auto poll_fd = &curl.fds.front(); poll_fd->fd = fd; poll_fd->events = events; g_source_add_poll(curl.source, poll_fd); } } } /** * Runs in the I/O thread. No lock needed. */ static bool input_curl_easy_add(struct input_curl *c, GError **error_r) { assert(io_thread_inside()); assert(c != NULL); assert(c->easy != NULL); assert(input_curl_find_request(c->easy) == NULL); curl.requests.push_front(c); CURLMcode mcode = curl_multi_add_handle(curl.multi, c->easy); if (mcode != CURLM_OK) { g_set_error(error_r, curl_quark(), mcode, "curl_multi_add_handle() failed: %s", curl_multi_strerror(mcode)); return false; } curl_update_fds(); return true; } struct easy_add_params { struct input_curl *c; GError **error_r; }; static gpointer input_curl_easy_add_callback(gpointer data) { const struct easy_add_params *params = (const struct easy_add_params *)data; bool success = input_curl_easy_add(params->c, params->error_r); return GUINT_TO_POINTER(success); } /** * Call input_curl_easy_add() in the I/O thread. May be called from * any thread. Caller must not hold a mutex. */ static bool input_curl_easy_add_indirect(struct input_curl *c, GError **error_r) { assert(c != NULL); assert(c->easy != NULL); struct easy_add_params params = { c, error_r, }; gpointer result = io_thread_call(input_curl_easy_add_callback, ¶ms); return GPOINTER_TO_UINT(result); } /** * Frees the current "libcurl easy" handle, and everything associated * with it. * * Runs in the I/O thread. */ static void input_curl_easy_free(struct input_curl *c) { assert(io_thread_inside()); assert(c != NULL); if (c->easy == NULL) return; curl.requests.remove(c); curl_multi_remove_handle(curl.multi, c->easy); curl_easy_cleanup(c->easy); c->easy = NULL; curl_slist_free_all(c->request_headers); c->request_headers = NULL; g_free(c->range); c->range = NULL; } static gpointer input_curl_easy_free_callback(gpointer data) { struct input_curl *c = (struct input_curl *)data; input_curl_easy_free(c); curl_update_fds(); return NULL; } /** * Frees the current "libcurl easy" handle, and everything associated * with it. * * The mutex must not be locked. */ static void input_curl_easy_free_indirect(struct input_curl *c) { io_thread_call(input_curl_easy_free_callback, c); assert(c->easy == NULL); } /** * Abort and free all HTTP requests. * * Runs in the I/O thread. The caller must not hold locks. */ static void input_curl_abort_all_requests(GError *error) { assert(io_thread_inside()); assert(error != NULL); while (!curl.requests.empty()) { struct input_curl *c = curl.requests.front(); assert(c->postponed_error == NULL); input_curl_easy_free(c); g_mutex_lock(c->base.mutex); c->postponed_error = g_error_copy(error); c->base.ready = true; g_cond_broadcast(c->base.cond); g_mutex_unlock(c->base.mutex); } g_error_free(error); } /** * A HTTP request is finished. * * Runs in the I/O thread. The caller must not hold locks. */ static void input_curl_request_done(struct input_curl *c, CURLcode result, long status) { assert(io_thread_inside()); assert(c != NULL); assert(c->easy == NULL); assert(c->postponed_error == NULL); g_mutex_lock(c->base.mutex); if (result != CURLE_OK) { c->postponed_error = g_error_new(curl_quark(), result, "curl failed: %s", c->error); } else if (status < 200 || status >= 300) { c->postponed_error = g_error_new(curl_quark(), 0, "got HTTP status %ld", status); } c->base.ready = true; g_cond_broadcast(c->base.cond); g_mutex_unlock(c->base.mutex); } static void input_curl_handle_done(CURL *easy_handle, CURLcode result) { struct input_curl *c = input_curl_find_request(easy_handle); assert(c != NULL); long status = 0; curl_easy_getinfo(easy_handle, CURLINFO_RESPONSE_CODE, &status); input_curl_easy_free(c); input_curl_request_done(c, result, status); } /** * Check for finished HTTP responses. * * Runs in the I/O thread. The caller must not hold locks. */ static void input_curl_info_read(void) { assert(io_thread_inside()); CURLMsg *msg; int msgs_in_queue; while ((msg = curl_multi_info_read(curl.multi, &msgs_in_queue)) != NULL) { if (msg->msg == CURLMSG_DONE) input_curl_handle_done(msg->easy_handle, msg->data.result); } } /** * Give control to CURL. * * Runs in the I/O thread. The caller must not hold locks. */ static bool input_curl_perform(void) { assert(io_thread_inside()); CURLMcode mcode; do { int running_handles; mcode = curl_multi_perform(curl.multi, &running_handles); } while (mcode == CURLM_CALL_MULTI_PERFORM); if (mcode != CURLM_OK && mcode != CURLM_CALL_MULTI_PERFORM) { GError *error = g_error_new(curl_quark(), mcode, "curl_multi_perform() failed: %s", curl_multi_strerror(mcode)); input_curl_abort_all_requests(error); return false; } return true; } /* * GSource methods * */ /** * The GSource prepare() method implementation. */ static gboolean input_curl_source_prepare(G_GNUC_UNUSED GSource *source, gint *timeout_r) { curl_update_fds(); curl.timeout = false; long timeout2; CURLMcode mcode = curl_multi_timeout(curl.multi, &timeout2); if (mcode == CURLM_OK) { if (timeout2 >= 0) curl.absolute_timeout = g_source_get_time(source) + timeout2 * 1000; if (timeout2 >= 0 && timeout2 < 10) /* CURL 7.21.1 likes to report "timeout=0", which means we're running in a busy loop. Quite a bad idea to waste so much CPU. Let's use a lower limit of 10ms. */ timeout2 = 10; *timeout_r = timeout2; curl.timeout = timeout2 >= 0; } else g_warning("curl_multi_timeout() failed: %s\n", curl_multi_strerror(mcode)); return false; } /** * The GSource check() method implementation. */ static gboolean input_curl_source_check(G_GNUC_UNUSED GSource *source) { if (curl.timeout) { /* when a timeout has expired, we need to call curl_multi_perform(), even if there was no file descriptor event */ if (g_source_get_time(source) >= curl.absolute_timeout) return true; } for (const auto &i : curl.fds) if (i.revents != 0) return true; return false; } /** * The GSource dispatch() method implementation. The callback isn't * used, because we're handling all events directly. */ static gboolean input_curl_source_dispatch(G_GNUC_UNUSED GSource *source, G_GNUC_UNUSED GSourceFunc callback, G_GNUC_UNUSED gpointer user_data) { if (input_curl_perform()) input_curl_info_read(); return true; } /** * The vtable for our GSource implementation. Unfortunately, we * cannot declare it "const", because g_source_new() takes a non-const * pointer, for whatever reason. */ static GSourceFuncs curl_source_funcs = { input_curl_source_prepare, input_curl_source_check, input_curl_source_dispatch, nullptr, nullptr, nullptr, }; /* * input_plugin methods * */ static bool input_curl_init(const struct config_param *param, G_GNUC_UNUSED GError **error_r) { CURLcode code = curl_global_init(CURL_GLOBAL_ALL); if (code != CURLE_OK) { g_set_error(error_r, curl_quark(), code, "curl_global_init() failed: %s\n", curl_easy_strerror(code)); return false; } http_200_aliases = curl_slist_append(http_200_aliases, "ICY 200 OK"); proxy = config_get_block_string(param, "proxy", NULL); proxy_port = config_get_block_unsigned(param, "proxy_port", 0); proxy_user = config_get_block_string(param, "proxy_user", NULL); proxy_password = config_get_block_string(param, "proxy_password", NULL); if (proxy == NULL) { /* deprecated proxy configuration */ proxy = config_get_string(CONF_HTTP_PROXY_HOST, NULL); proxy_port = config_get_positive(CONF_HTTP_PROXY_PORT, 0); proxy_user = config_get_string(CONF_HTTP_PROXY_USER, NULL); proxy_password = config_get_string(CONF_HTTP_PROXY_PASSWORD, ""); } curl.multi = curl_multi_init(); if (curl.multi == NULL) { g_set_error(error_r, curl_quark(), 0, "curl_multi_init() failed"); return false; } curl.source = g_source_new(&curl_source_funcs, sizeof(*curl.source)); curl.source_id = g_source_attach(curl.source, io_thread_context()); return true; } static gpointer curl_destroy_sources(G_GNUC_UNUSED gpointer data) { g_source_destroy(curl.source); return NULL; } static void input_curl_finish(void) { assert(curl.requests.empty()); io_thread_call(curl_destroy_sources, NULL); curl_multi_cleanup(curl.multi); curl_slist_free_all(http_200_aliases); curl_global_cleanup(); } /** * Determine the total sizes of all buffers, including portions that * have already been consumed. * * The caller must lock the mutex. */ G_GNUC_PURE static size_t curl_total_buffer_size(const struct input_curl *c) { size_t total = 0; for (const auto &i : c->buffers) total += i.TotalSize(); return total; } input_curl::~input_curl() { if (tag != NULL) tag_free(tag); g_free(meta_name); input_curl_easy_free_indirect(this); if (postponed_error != NULL) g_error_free(postponed_error); input_stream_deinit(&base); } static bool input_curl_check(struct input_stream *is, GError **error_r) { struct input_curl *c = (struct input_curl *)is; bool success = c->postponed_error == NULL; if (!success) { g_propagate_error(error_r, c->postponed_error); c->postponed_error = NULL; } return success; } static struct tag * input_curl_tag(struct input_stream *is) { struct input_curl *c = (struct input_curl *)is; struct tag *tag = c->tag; c->tag = NULL; return tag; } static bool fill_buffer(struct input_curl *c, GError **error_r) { while (c->easy != NULL && c->buffers.empty()) g_cond_wait(c->base.cond, c->base.mutex); if (c->postponed_error != NULL) { g_propagate_error(error_r, c->postponed_error); c->postponed_error = NULL; return false; } return !c->buffers.empty(); } static size_t read_from_buffer(IcyMetaDataParser &icy, std::list &buffers, void *dest0, size_t length) { auto &buffer = buffers.front(); uint8_t *dest = (uint8_t *)dest0; size_t nbytes = 0; if (length > buffer.Available()) length = buffer.Available(); while (true) { size_t chunk; chunk = icy.Data(length); if (chunk > 0) { const bool empty = !buffer.Read(dest, chunk); nbytes += chunk; dest += chunk; length -= chunk; if (empty) { buffers.pop_front(); break; } } chunk = icy.Meta(buffer.Begin(), length); if (chunk > 0) { const bool empty = !buffer.Consume(chunk); length -= chunk; if (empty) { buffers.pop_front(); break; } } } return nbytes; } static void copy_icy_tag(struct input_curl *c) { struct tag *tag = c->icy.ReadTag(); if (tag == NULL) return; if (c->tag != NULL) tag_free(c->tag); if (c->meta_name != NULL && !tag_has_type(tag, TAG_NAME)) tag_add_item(tag, TAG_NAME, c->meta_name); c->tag = tag; } static bool input_curl_available(struct input_stream *is) { struct input_curl *c = (struct input_curl *)is; return c->postponed_error != NULL || c->easy == NULL || !c->buffers.empty(); } static size_t input_curl_read(struct input_stream *is, void *ptr, size_t size, GError **error_r) { struct input_curl *c = (struct input_curl *)is; bool success; size_t nbytes = 0; char *dest = (char *)ptr; do { /* fill the buffer */ success = fill_buffer(c, error_r); if (!success) return 0; /* send buffer contents */ while (size > 0 && !c->buffers.empty()) { size_t copy = read_from_buffer(c->icy, c->buffers, dest + nbytes, size); nbytes += copy; size -= copy; } } while (nbytes == 0); if (c->icy.IsDefined()) copy_icy_tag(c); is->offset += (goffset)nbytes; if (c->paused && curl_total_buffer_size(c) < CURL_RESUME_AT) { g_mutex_unlock(c->base.mutex); io_thread_call(input_curl_resume, c); g_mutex_lock(c->base.mutex); } return nbytes; } static void input_curl_close(struct input_stream *is) { struct input_curl *c = (struct input_curl *)is; delete c; } static bool input_curl_eof(G_GNUC_UNUSED struct input_stream *is) { struct input_curl *c = (struct input_curl *)is; return c->easy == NULL && c->buffers.empty(); } /** called by curl when new data is available */ static size_t input_curl_headerfunction(void *ptr, size_t size, size_t nmemb, void *stream) { struct input_curl *c = (struct input_curl *)stream; char name[64]; size *= nmemb; const char *header = (const char *)ptr; const char *end = header + size; const char *value = (const char *)memchr(header, ':', size); if (value == NULL || (size_t)(value - header) >= sizeof(name)) return size; memcpy(name, header, value - header); name[value - header] = 0; /* skip the colon */ ++value; /* strip the value */ while (value < end && g_ascii_isspace(*value)) ++value; while (end > value && g_ascii_isspace(end[-1])) --end; if (g_ascii_strcasecmp(name, "accept-ranges") == 0) { /* a stream with icy-metadata is not seekable */ if (!c->icy.IsDefined()) c->base.seekable = true; } else if (g_ascii_strcasecmp(name, "content-length") == 0) { char buffer[64]; if ((size_t)(end - header) >= sizeof(buffer)) return size; memcpy(buffer, value, end - value); buffer[end - value] = 0; c->base.size = c->base.offset + g_ascii_strtoull(buffer, NULL, 10); } else if (g_ascii_strcasecmp(name, "content-type") == 0) { g_free(c->base.mime); c->base.mime = g_strndup(value, end - value); } else if (g_ascii_strcasecmp(name, "icy-name") == 0 || g_ascii_strcasecmp(name, "ice-name") == 0 || g_ascii_strcasecmp(name, "x-audiocast-name") == 0) { g_free(c->meta_name); c->meta_name = g_strndup(value, end - value); if (c->tag != NULL) tag_free(c->tag); c->tag = tag_new(); tag_add_item(c->tag, TAG_NAME, c->meta_name); } else if (g_ascii_strcasecmp(name, "icy-metaint") == 0) { char buffer[64]; size_t icy_metaint; if ((size_t)(end - header) >= sizeof(buffer) || c->icy.IsDefined()) return size; memcpy(buffer, value, end - value); buffer[end - value] = 0; icy_metaint = g_ascii_strtoull(buffer, NULL, 10); g_debug("icy-metaint=%zu", icy_metaint); if (icy_metaint > 0) { c->icy.Start(icy_metaint); /* a stream with icy-metadata is not seekable */ c->base.seekable = false; } } return size; } /** called by curl when new data is available */ static size_t input_curl_writefunction(void *ptr, size_t size, size_t nmemb, void *stream) { struct input_curl *c = (struct input_curl *)stream; size *= nmemb; if (size == 0) return 0; g_mutex_lock(c->base.mutex); if (curl_total_buffer_size(c) + size >= CURL_MAX_BUFFERED) { c->paused = true; g_mutex_unlock(c->base.mutex); return CURL_WRITEFUNC_PAUSE; } c->buffers.emplace_back(ptr, size); c->base.ready = true; g_cond_broadcast(c->base.cond); g_mutex_unlock(c->base.mutex); return size; } static bool input_curl_easy_init(struct input_curl *c, GError **error_r) { CURLcode code; c->easy = curl_easy_init(); if (c->easy == NULL) { g_set_error(error_r, curl_quark(), 0, "curl_easy_init() failed"); return false; } curl_easy_setopt(c->easy, CURLOPT_USERAGENT, "Music Player Daemon " VERSION); curl_easy_setopt(c->easy, CURLOPT_HEADERFUNCTION, input_curl_headerfunction); curl_easy_setopt(c->easy, CURLOPT_WRITEHEADER, c); curl_easy_setopt(c->easy, CURLOPT_WRITEFUNCTION, input_curl_writefunction); curl_easy_setopt(c->easy, CURLOPT_WRITEDATA, c); curl_easy_setopt(c->easy, CURLOPT_HTTP200ALIASES, http_200_aliases); curl_easy_setopt(c->easy, CURLOPT_FOLLOWLOCATION, 1); curl_easy_setopt(c->easy, CURLOPT_NETRC, 1); curl_easy_setopt(c->easy, CURLOPT_MAXREDIRS, 5); curl_easy_setopt(c->easy, CURLOPT_FAILONERROR, true); curl_easy_setopt(c->easy, CURLOPT_ERRORBUFFER, c->error); curl_easy_setopt(c->easy, CURLOPT_NOPROGRESS, 1l); curl_easy_setopt(c->easy, CURLOPT_NOSIGNAL, 1l); curl_easy_setopt(c->easy, CURLOPT_CONNECTTIMEOUT, 10l); if (proxy != NULL) curl_easy_setopt(c->easy, CURLOPT_PROXY, proxy); if (proxy_port > 0) curl_easy_setopt(c->easy, CURLOPT_PROXYPORT, (long)proxy_port); if (proxy_user != NULL && proxy_password != NULL) { char *proxy_auth_str = g_strconcat(proxy_user, ":", proxy_password, NULL); curl_easy_setopt(c->easy, CURLOPT_PROXYUSERPWD, proxy_auth_str); g_free(proxy_auth_str); } code = curl_easy_setopt(c->easy, CURLOPT_URL, c->base.uri); if (code != CURLE_OK) { g_set_error(error_r, curl_quark(), code, "curl_easy_setopt() failed: %s", curl_easy_strerror(code)); return false; } c->request_headers = NULL; c->request_headers = curl_slist_append(c->request_headers, "Icy-Metadata: 1"); curl_easy_setopt(c->easy, CURLOPT_HTTPHEADER, c->request_headers); return true; } static bool input_curl_seek(struct input_stream *is, goffset offset, int whence, GError **error_r) { struct input_curl *c = (struct input_curl *)is; bool ret; assert(is->ready); if (whence == SEEK_SET && offset == is->offset) /* no-op */ return true; if (!is->seekable) return false; /* calculate the absolute offset */ switch (whence) { case SEEK_SET: break; case SEEK_CUR: offset += is->offset; break; case SEEK_END: if (is->size < 0) /* stream size is not known */ return false; offset += is->size; break; default: return false; } if (offset < 0) return false; /* check if we can fast-forward the buffer */ while (offset > is->offset && !c->buffers.empty()) { auto &buffer = c->buffers.front(); size_t length = buffer.Available(); if (offset - is->offset < (goffset)length) length = offset - is->offset; const bool empty = !buffer.Consume(length); if (empty) c->buffers.pop_front(); is->offset += length; } if (offset == is->offset) return true; /* close the old connection and open a new one */ g_mutex_unlock(c->base.mutex); input_curl_easy_free_indirect(c); c->buffers.clear(); is->offset = offset; if (is->offset == is->size) { /* seek to EOF: simulate empty result; avoid triggering a "416 Requested Range Not Satisfiable" response */ return true; } ret = input_curl_easy_init(c, error_r); if (!ret) return false; /* send the "Range" header */ if (is->offset > 0) { c->range = g_strdup_printf("%lld-", (long long)is->offset); curl_easy_setopt(c->easy, CURLOPT_RANGE, c->range); } c->base.ready = false; if (!input_curl_easy_add_indirect(c, error_r)) return false; g_mutex_lock(c->base.mutex); while (!c->base.ready) g_cond_wait(c->base.cond, c->base.mutex); if (c->postponed_error != NULL) { g_propagate_error(error_r, c->postponed_error); c->postponed_error = NULL; return false; } return true; } static struct input_stream * input_curl_open(const char *url, GMutex *mutex, GCond *cond, GError **error_r) { assert(mutex != NULL); assert(cond != NULL); if (strncmp(url, "http://", 7) != 0) return NULL; struct input_curl *c = new input_curl(url, mutex, cond); if (!input_curl_easy_init(c, error_r)) { delete c; return NULL; } if (!input_curl_easy_add_indirect(c, error_r)) { delete c; return NULL; } return &c->base; } const struct input_plugin input_plugin_curl = { "curl", input_curl_init, input_curl_finish, input_curl_open, input_curl_close, input_curl_check, nullptr, input_curl_tag, input_curl_available, input_curl_read, input_curl_eof, input_curl_seek, };