summaryrefslogtreecommitdiff
path: root/src/storage/plugins
diff options
context:
space:
mode:
authorMax Kellermann <max@musicpd.org>2019-12-24 16:17:10 +0100
committerMax Kellermann <max@musicpd.org>2019-12-24 16:31:06 +0100
commit803a48e96d5c84f5bff382492da2c943f536d7bd (patch)
tree8dbf3ab08fad835c9c788085e88f051c757d77c4 /src/storage/plugins
parent57b8e7f651494122e9a2fc30a1281f9d927e5b87 (diff)
parentbf41d1ad2bed5cb0b7b64b0cf4f87688da43d62c (diff)
Merge tag 'v0.21.18'
release v0.21.18
Diffstat (limited to 'src/storage/plugins')
-rw-r--r--src/storage/plugins/CurlStorage.cxx5
1 files changed, 5 insertions, 0 deletions
diff --git a/src/storage/plugins/CurlStorage.cxx b/src/storage/plugins/CurlStorage.cxx
index 72ad439f4..af43eb876 100644
--- a/src/storage/plugins/CurlStorage.cxx
+++ b/src/storage/plugins/CurlStorage.cxx
@@ -105,7 +105,9 @@ public:
BIND_THIS_METHOD(OnDeferredStart)),
request(curl, uri, *this) {
// TODO: use CurlInputStream's configuration
+ }
+ void DeferStart() noexcept {
/* start the transfer inside the IOThread */
defer_start.Schedule();
}
@@ -278,6 +280,7 @@ public:
}
using BlockingHttpRequest::GetEasy;
+ using BlockingHttpRequest::DeferStart;
using BlockingHttpRequest::Wait;
protected:
@@ -425,6 +428,7 @@ public:
}
const StorageFileInfo &Perform() {
+ DeferStart();
Wait();
return info;
}
@@ -476,6 +480,7 @@ public:
base_path(UriPathOrSlash(uri)) {}
std::unique_ptr<StorageDirectoryReader> Perform() {
+ DeferStart();
Wait();
return ToReader();
}