blob: 81e5de901a3d673677c22a66c4980ae0e4316cbb (
plain) (
blame)
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
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
|
// Copyright Yahoo. Licensed under the terms of the Apache 2.0 license. See LICENSE in the project root.
/**
******************************************************************************
* @author Oivind H. Danielsen
* @date Creation date: 2000-01-18
* @file
* Class definitions for FastOS_UNIX_File
*****************************************************************************/
#pragma once
#include <vespa/fastos/file.h>
/**
* This is the generic UNIX implementation of @ref FastOS_FileInterface.
*/
class FastOS_UNIX_File : public FastOS_FileInterface
{
public:
using FastOS_FileInterface::ReadBuf;
private:
FastOS_UNIX_File(const FastOS_UNIX_File&);
FastOS_UNIX_File& operator=(const FastOS_UNIX_File&);
protected:
void *_mmapbase;
size_t _mmaplen;
int _filedes;
int _mmapFlags;
bool _mmapEnabled;
static unsigned int CalcAccessFlags(unsigned int openFlags);
public:
static bool Stat(const char *filename, FastOS_StatInfo *statInfo);
static int GetMaximumFilenameLength (const char *pathName);
static int GetMaximumPathLength (const char *pathName);
FastOS_UNIX_File(const char *filename=nullptr)
: FastOS_FileInterface(filename),
_mmapbase(nullptr),
_mmaplen(0),
_filedes(-1),
_mmapFlags(0),
_mmapEnabled(false)
{ }
void ReadBuf(void *buffer, size_t length, int64_t readOffset) override;
[[nodiscard]] ssize_t Read(void *buffer, size_t len) override;
[[nodiscard]] ssize_t Write2(const void *buffer, size_t len) override;
bool Open(unsigned int openFlags, const char *filename) override;
[[nodiscard]] bool Close() override;
bool IsOpened() const override { return _filedes >= 0; }
void enableMemoryMap(int flags) override {
_mmapEnabled = true;
_mmapFlags = flags;
}
void *MemoryMapPtr(int64_t position) const override {
if (_mmapbase != nullptr) {
if (position < int64_t(_mmaplen)) {
return static_cast<void *>(static_cast<char *>(_mmapbase) + position);
} else { // This is an indication that the file size has changed and a remap/reopen must be done.
return nullptr;
}
} else {
return nullptr;
}
}
bool IsMemoryMapped() const override { return _mmapbase != nullptr; }
bool SetPosition(int64_t desiredPosition) override;
int64_t getPosition() const override;
int64_t getSize() const override;
[[nodiscard]] bool Sync() override;
bool SetSize(int64_t newSize) override;
void dropFromCache() const override;
static int GetLastOSError();
static Error TranslateError(const int osError);
static std::string getErrorString(const int osError);
static int64_t GetFreeDiskSpace (const char *path);
static int count_open_files();
};
|
