diff --git a/src/input/plugins/NfsInputPlugin.cxx b/src/input/plugins/NfsInputPlugin.cxx index 6a1fc1997..c525a3143 100644 --- a/src/input/plugins/NfsInputPlugin.cxx +++ b/src/input/plugins/NfsInputPlugin.cxx @@ -41,14 +41,15 @@ static const size_t NFS_MAX_BUFFERED = 512 * 1024; */ static const size_t NFS_RESUME_AT = 384 * 1024; -class NfsInputStream final : public AsyncInputStream, NfsFileReader { +class NfsInputStream final : NfsFileReader, public AsyncInputStream { uint64_t next_offset; bool reconnect_on_resume = false, reconnecting = false; public: NfsInputStream(const char *_uri, Mutex &_mutex, Cond &_cond) - :AsyncInputStream(io_thread_get(), _uri, _mutex, _cond, + :AsyncInputStream(NfsFileReader::GetEventLoop(), + _uri, _mutex, _cond, NFS_MAX_BUFFERED, NFS_RESUME_AT) {}