Commit 58ac72f7 authored by Max Kellermann's avatar Max Kellermann

input/nfs: use NfsFileReader::GetEventLoop()

parent 6d590480
...@@ -41,14 +41,15 @@ static const size_t NFS_MAX_BUFFERED = 512 * 1024; ...@@ -41,14 +41,15 @@ static const size_t NFS_MAX_BUFFERED = 512 * 1024;
*/ */
static const size_t NFS_RESUME_AT = 384 * 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; uint64_t next_offset;
bool reconnect_on_resume = false, reconnecting = false; bool reconnect_on_resume = false, reconnecting = false;
public: public:
NfsInputStream(const char *_uri, Mutex &_mutex, Cond &_cond) 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_MAX_BUFFERED,
NFS_RESUME_AT) {} NFS_RESUME_AT) {}
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment