blob: 21d3e6b10b6a843b9c314883199c30a06ffec2d3 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
|
/*
* 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 "threads/CriticalSection.h"
#include "threads/Event.h"
namespace XFILE {
class CCircularCache : public CCacheStrategy
{
public:
CCircularCache(size_t front, size_t back);
~CCircularCache() override;
int Open() override;
void Close() override;
size_t GetMaxWriteSize(const size_t& iRequestSize) override;
int WriteToCache(const char *buf, size_t len) override;
int ReadFromCache(char *buf, size_t len) override;
int64_t WaitForData(uint32_t minimum, std::chrono::milliseconds timeout) override;
int64_t Seek(int64_t pos) override;
bool Reset(int64_t pos) override;
int64_t CachedDataEndPosIfSeekTo(int64_t iFilePosition) override;
int64_t CachedDataStartPos() override;
int64_t CachedDataEndPos() override;
bool IsCachedPosition(int64_t iFilePosition) override;
CCacheStrategy *CreateNew() override;
protected:
int64_t m_beg; /**< index in file (not buffer) of beginning of valid data */
int64_t m_end; /**< index in file (not buffer) of end of valid data */
int64_t m_cur; /**< current reading index in file */
uint8_t *m_buf; /**< buffer holding data */
size_t m_size; /**< size of data buffer used (m_buf) */
size_t m_size_back; /**< guaranteed size of back buffer (actual size can be smaller, or larger if front buffer doesn't need it) */
CCriticalSection m_sync;
CEvent m_written;
#ifdef TARGET_WINDOWS
HANDLE m_handle;
#endif
};
} // namespace XFILE
|
