summaryrefslogtreecommitdiffstats
path: root/xbmc/filesystem/FileCache.h
diff options
context:
space:
mode:
Diffstat (limited to 'xbmc/filesystem/FileCache.h')
-rw-r--r--xbmc/filesystem/FileCache.h79
1 files changed, 79 insertions, 0 deletions
diff --git a/xbmc/filesystem/FileCache.h b/xbmc/filesystem/FileCache.h
new file mode 100644
index 0000000..df7c839
--- /dev/null
+++ b/xbmc/filesystem/FileCache.h
@@ -0,0 +1,79 @@
+/*
+ * Copyright (C) 2005-2018 Team Kodi
+ * This file is part of Kodi - https://kodi.tv
+ *
+ * SPDX-License-Identifier: GPL-2.0-or-later
+ * See LICENSES/README.md for more information.
+ */
+
+#pragma once
+
+#include "CacheStrategy.h"
+#include "File.h"
+#include "IFile.h"
+#include "threads/CriticalSection.h"
+#include "threads/Thread.h"
+
+#include <atomic>
+#include <memory>
+
+namespace XFILE
+{
+
+ class CFileCache : public IFile, public CThread
+ {
+ public:
+ explicit CFileCache(const unsigned int flags);
+ ~CFileCache() override;
+
+ // CThread methods
+ void Process() override;
+ void OnExit() override;
+ void StopThread(bool bWait = true) override;
+
+ // IFIle methods
+ bool Open(const CURL& url) override;
+ void Close() override;
+ bool Exists(const CURL& url) override;
+ int Stat(const CURL& url, struct __stat64* buffer) override;
+
+ ssize_t Read(void* lpBuf, size_t uiBufSize) override;
+
+ int64_t Seek(int64_t iFilePosition, int iWhence) override;
+ int64_t GetPosition() override;
+ int64_t GetLength() override;
+
+ int IoControl(EIoControl request, void* param) override;
+
+ IFile *GetFileImp();
+
+ const std::string GetProperty(XFILE::FileProperty type, const std::string &name = "") const override;
+
+ const std::vector<std::string> GetPropertyValues(XFILE::FileProperty type, const std::string& name = "") const override
+ {
+ return std::vector<std::string>();
+ }
+
+ private:
+ std::unique_ptr<CCacheStrategy> m_pCache;
+ int m_seekPossible;
+ CFile m_source;
+ std::string m_sourcePath;
+ CEvent m_seekEvent;
+ CEvent m_seekEnded;
+ int64_t m_nSeekResult;
+ int64_t m_seekPos;
+ int64_t m_readPos;
+ int64_t m_writePos;
+ unsigned m_chunkSize;
+ uint32_t m_writeRate;
+ uint32_t m_writeRateActual;
+ uint32_t m_writeRateLowSpeed;
+ int64_t m_forwardCacheSize;
+ bool m_bFilling;
+ std::atomic<int64_t> m_fileSize;
+ unsigned int m_flags;
+ CCriticalSection m_sync;
+ };
+
+}