libcmo21/LibCmo/VxMath/VxMemoryMappedFile.cpp

140 lines
3.2 KiB
C++
Raw Normal View History

2023-02-25 17:39:39 +08:00
#include "VxMemoryMappedFile.hpp"
#include "VTEncoding.hpp"
2023-02-10 16:17:17 +08:00
2023-02-26 21:48:03 +08:00
namespace LibCmo::VxMath {
2023-02-10 16:17:17 +08:00
VxMemoryMappedFile::VxMemoryMappedFile(const char* u8_filepath) :
2023-02-12 21:03:36 +08:00
// init members
#if defined(LIBCMO_OS_WIN32)
m_hFile(NULL), m_hFileMapping(NULL), m_hFileMapView(NULL),
m_dwFileSizeLow(0), m_dwFileSizeHigh(0),
#else
m_hFile(-1), m_offFileSize(0), m_pFileAddr((void*)-1),
2023-02-12 21:03:36 +08:00
#endif
2023-02-10 16:17:17 +08:00
m_szFilePath(),
2023-02-12 21:03:36 +08:00
m_bIsValid(false), m_pMemoryMappedFileBase(nullptr), m_cbFile(0u) {
2023-02-10 16:17:17 +08:00
2023-02-12 21:03:36 +08:00
// save file path
2023-02-10 16:17:17 +08:00
#if defined(LIBCMO_OS_WIN32)
2023-02-26 21:48:03 +08:00
EncodingHelper::SetStdPathFromU8Path(m_szFilePath, u8_filepath);
2023-02-10 16:17:17 +08:00
#else
this->m_szFilePath = u8_filepath;
#endif
2023-02-12 21:03:36 +08:00
// real mapping work
#if defined(LIBCMO_OS_WIN32)
2023-02-15 21:03:26 +08:00
2023-02-10 16:17:17 +08:00
// open file
2023-02-12 21:03:36 +08:00
this->m_hFile = CreateFileW(
2023-02-25 22:58:28 +08:00
this->m_szFilePath.wstring().c_str(),
2023-02-12 21:03:36 +08:00
GENERIC_READ,
0, // do not share
NULL, // no security
OPEN_EXISTING,
FILE_ATTRIBUTE_NORMAL, // no attr
NULL // no template
2023-02-10 16:17:17 +08:00
);
2023-02-12 21:03:36 +08:00
if (this->m_hFile == INVALID_HANDLE_VALUE) {
return;
}
2023-02-10 16:17:17 +08:00
2023-02-12 21:03:36 +08:00
// get size
m_dwFileSizeLow = ::GetFileSize(this->m_hFile, &this->m_dwFileSizeHigh);
if (m_dwFileSizeLow == INVALID_FILE_SIZE) {
CloseHandle(this->m_hFile);
return;
}
// open mapping
this->m_hFileMapping = CreateFileMappingW(
this->m_hFile,
NULL, // default security
PAGE_READONLY,
0, 0, // expand to file size
NULL // no name
2023-02-10 16:17:17 +08:00
);
2023-02-12 21:03:36 +08:00
if (this->m_hFileMapping == NULL) {
CloseHandle(this->m_hFile);
return;
}
// open map view
this->m_hFileMapView = MapViewOfFile(
this->m_hFileMapping,
FILE_MAP_READ,
0, 0, //no offset
0 // expand to full file size
);
if (this->m_hFileMapView == NULL) {
CloseHandle(m_hFileMapping);
CloseHandle(m_hFile);
}
// write member data
m_pMemoryMappedFileBase = m_hFileMapView;
2023-02-14 21:31:18 +08:00
m_cbFile = static_cast<size_t>(static_cast<uint64_t>(m_dwFileSizeLow) | (static_cast<uint64_t>(m_dwFileSizeHigh) << 32));
2023-02-12 21:03:36 +08:00
#else
// create file
// we do not need provide mode_t, because is served for new created file.
// we are opening a existed file.
this->m_hFile = open(m_szFilePath.string().c_str(), O_RDONLY);
if (m_hFile == -1) {
return;
}
// calculate file size
struct stat sb;
int err = fstat(m_hFile, &sb);
// if failed or not a regular file, exit
if (err == -1 || (sb.st_mode & S_IFMT) != S_IFREG) {
close(m_hFile);
return;
}
// setup size
this->m_offFileSize = sb.st_size;
// map file
this->m_pFileAddr = mmap(
nullptr, // request linux distribute one
this->m_offFileSize, // map the full file
PROT_READ, // only for reading
MAP_PRIVATE,
this->m_hFile,
0 // no offset
);
if (this->m_pFileAddr == MAP_FAILED) {
close(m_hFile);
return;
}
2023-02-12 21:03:36 +08:00
// write member data
m_pMemoryMappedFileBase = m_pFileAddr;
m_cbFile = static_cast<size_t>(this->m_offFileSize);
#endif
2023-02-10 16:17:17 +08:00
// set valid
this->m_bIsValid = true;
}
VxMemoryMappedFile::~VxMemoryMappedFile(void) {
2023-02-12 21:03:36 +08:00
if (this->m_bIsValid) {
// only success mapping need free
this->m_bIsValid = false;
m_cbFile = 0;
m_pMemoryMappedFileBase = nullptr;
2023-02-10 16:17:17 +08:00
2023-02-12 21:03:36 +08:00
#if defined(LIBCMO_OS_WIN32)
UnmapViewOfFile(this->m_hFileMapView);
CloseHandle(m_hFileMapping);
CloseHandle(m_hFile);
#else
munmap(this->m_pFileAddr, this->m_offFileSize);
close(m_hFile);
2023-02-12 21:03:36 +08:00
#endif
}
2023-02-10 16:17:17 +08:00
}
2023-02-11 15:29:51 +08:00
2023-02-10 16:17:17 +08:00
}