Fix spectator desync in rare conditions (there was team which left during its turn, and last command with timestamp from it was '+')
/* borrowed from https://github.com/skhaz/qt-physfs-wrapper
* TODO: add copyright header, determine license
*/
#include "hwpacksmounter.h"
#include "FileEngine.h"
const QString FileEngineHandler::scheme = "physfs:/";
FileEngine::FileEngine(const QString& filename)
: m_handle(NULL)
, m_size(0)
, m_flags(0)
, m_bufferSet(false)
, m_readWrite(false)
{
setFileName(filename);
}
FileEngine::~FileEngine()
{
close();
}
bool FileEngine::open(QIODevice::OpenMode openMode)
{
close();
if ((openMode & QIODevice::ReadWrite) == QIODevice::ReadWrite) {
m_handle = PHYSFS_openAppend(m_fileName.toUtf8().constData());
if(m_handle)
{
m_readWrite = true;
seek(0);
}
}
else if (openMode & QIODevice::WriteOnly) {
m_handle = PHYSFS_openWrite(m_fileName.toUtf8().constData());
m_flags = QAbstractFileEngine::WriteOwnerPerm | QAbstractFileEngine::WriteUserPerm | QAbstractFileEngine::FileType;
}
else if (openMode & QIODevice::ReadOnly) {
m_handle = PHYSFS_openRead(m_fileName.toUtf8().constData());
}
else if (openMode & QIODevice::Append) {
m_handle = PHYSFS_openAppend(m_fileName.toUtf8().constData());
}
else {
qWarning("[PHYSFS] Bad file open mode: %d", (int)openMode);
}
if (!m_handle) {
qWarning("%s", QString("[PHYSFS] Failed to open %1, reason: %2").arg(m_fileName).arg(FileEngineHandler::errorStr()).toLocal8Bit().constData());
return false;
}
return true;
}
bool FileEngine::close()
{
if (isOpened()) {
int result = PHYSFS_close(m_handle);
m_handle = NULL;
return result != 0;
}
return true;
}
bool FileEngine::flush()
{
return PHYSFS_flush(m_handle) != 0;
}
qint64 FileEngine::size() const
{
return m_size;
}
qint64 FileEngine::pos() const
{
return PHYSFS_tell(m_handle);
}
bool FileEngine::setSize(qint64 size)
{
if(size == 0)
{
m_size = 0;
return open(QIODevice::WriteOnly);
}
else
return false;
}
bool FileEngine::seek(qint64 pos)
{
bool ok = PHYSFS_seek(m_handle, pos) != 0;
return ok;
}
bool FileEngine::isSequential() const
{
return false;
}
bool FileEngine::remove()
{
return PHYSFS_delete(m_fileName.toUtf8().constData()) != 0;
}
bool FileEngine::mkdir(const QString &dirName, bool createParentDirectories) const
{
Q_UNUSED(createParentDirectories);
return PHYSFS_mkdir(dirName.toUtf8().constData()) != 0;
}
bool FileEngine::rmdir(const QString &dirName, bool recurseParentDirectories) const
{
Q_UNUSED(recurseParentDirectories);
return PHYSFS_delete(dirName.toUtf8().constData()) != 0;
}
bool FileEngine::caseSensitive() const
{
return true;
}
bool FileEngine::isRelativePath() const
{
return false;
}
QAbstractFileEngineIterator * FileEngine::beginEntryList(QDir::Filters filters, const QStringList &filterNames)
{
return new FileEngineIterator(filters, filterNames, entryList(filters, filterNames));
}
QStringList FileEngine::entryList(QDir::Filters filters, const QStringList &filterNames) const
{
Q_UNUSED(filters);
QString file;
QStringList result;
char **files = PHYSFS_enumerateFiles(m_fileName.toUtf8().constData());
for (char **i = files; *i != NULL; i++) {
file = QString::fromUtf8(*i);
if (filterNames.isEmpty() || QDir::match(filterNames, file)) {
result << file;
}
}
PHYSFS_freeList(files);
return result;
}
QAbstractFileEngine::FileFlags FileEngine::fileFlags(FileFlags type) const
{
return type & m_flags;
}
QString FileEngine::fileName(FileName file) const
{
switch(file)
{
case QAbstractFileEngine::AbsolutePathName:
{
QString s(PHYSFS_getWriteDir());
return s;
}
case QAbstractFileEngine::BaseName:
{
int l = m_fileName.lastIndexOf('/');
QString s = m_fileName.mid(l + 1);
return s;
}
case QAbstractFileEngine::DefaultName:
case QAbstractFileEngine::AbsoluteName:
default:
{
QString s = "physfs:/" + m_fileName;
return s;
}
}
}
QDateTime FileEngine::fileTime(FileTime time) const
{
switch (time)
{
case QAbstractFileEngine::ModificationTime:
default:
return m_date;
break;
};
}
void FileEngine::setFileName(const QString &file)
{
if(file.startsWith(FileEngineHandler::scheme))
m_fileName = file.mid(FileEngineHandler::scheme.size());
else
m_fileName = file;
PHYSFS_Stat stat;
if (PHYSFS_stat(m_fileName.toUtf8().constData(), &stat) != 0) {
m_size = stat.filesize;
m_date = QDateTime::fromTime_t(stat.modtime);
// m_flags |= QAbstractFileEngine::WriteOwnerPerm;
m_flags |= QAbstractFileEngine::ReadOwnerPerm;
m_flags |= QAbstractFileEngine::ReadUserPerm;
m_flags |= QAbstractFileEngine::ExistsFlag;
m_flags |= QAbstractFileEngine::LocalDiskFlag;
switch (stat.filetype)
{
case PHYSFS_FILETYPE_REGULAR:
m_flags |= QAbstractFileEngine::FileType;
break;
case PHYSFS_FILETYPE_DIRECTORY:
m_flags |= QAbstractFileEngine::DirectoryType;
break;
case PHYSFS_FILETYPE_SYMLINK:
m_flags |= QAbstractFileEngine::LinkType;
break;
default: ;
}
}
}
bool FileEngine::atEnd() const
{
return PHYSFS_eof(m_handle) != 0;
}
qint64 FileEngine::read(char *data, qint64 maxlen)
{
if(m_readWrite)
{
if(pos() == 0)
open(QIODevice::ReadOnly);
else
return -1;
}
qint64 len = PHYSFS_readBytes(m_handle, data, maxlen);
return len;
}
qint64 FileEngine::readLine(char *data, qint64 maxlen)
{
if(!m_bufferSet)
{
PHYSFS_setBuffer(m_handle, 4096);
m_bufferSet = true;
}
qint64 bytesRead = 0;
while(PHYSFS_readBytes(m_handle, data, 1)
&& maxlen
&& (*data == '\n'))
{
++data;
--maxlen;
++bytesRead;
}
return bytesRead;
}
qint64 FileEngine::write(const char *data, qint64 len)
{
return PHYSFS_writeBytes(m_handle, data, len);
}
bool FileEngine::isOpened() const
{
return m_handle != NULL;
}
QFile::FileError FileEngine::error() const
{
return QFile::UnspecifiedError;
}
QString FileEngine::errorString() const
{
return PHYSFS_getLastError();
}
bool FileEngine::supportsExtension(Extension extension) const
{
return
(extension == QAbstractFileEngine::AtEndExtension)
|| (extension == QAbstractFileEngine::FastReadLineExtension)
;
}
FileEngineHandler::FileEngineHandler(char *argv0)
{
PHYSFS_init(argv0);
qDebug("%s", QString("[PHYSFS] Init: %1").arg(errorStr()).toLocal8Bit().constData());
}
FileEngineHandler::~FileEngineHandler()
{
PHYSFS_deinit();
}
QAbstractFileEngine* FileEngineHandler::create(const QString &filename) const
{
if (filename.startsWith(scheme))
return new FileEngine(filename);
else
return NULL;
}
void FileEngineHandler::mount(const QString &path)
{
PHYSFS_mount(path.toUtf8().constData(), NULL, 0);
qDebug("%s", QString("[PHYSFS] Mounting '%1' to '/': %2").arg(path).arg(errorStr()).toLocal8Bit().constData());
}
void FileEngineHandler::mount(const QString & path, const QString & mountPoint)
{
PHYSFS_mount(path.toUtf8().constData(), mountPoint.toUtf8().constData(), 0);
qDebug("%s", QString("[PHYSFS] Mounting '%1' to '%2': %3").arg(path).arg(mountPoint).arg(errorStr()).toLocal8Bit().data());
}
void FileEngineHandler::setWriteDir(const QString &path)
{
PHYSFS_setWriteDir(path.toUtf8().constData());
qDebug("%s", QString("[PHYSFS] Setting write dir to '%1': %2").arg(path).arg(errorStr()).toLocal8Bit().data());
}
void FileEngineHandler::mountPacks()
{
hedgewarsMountPackages();
}
QString FileEngineHandler::errorStr()
{
QString s = QString::fromUtf8(PHYSFS_getLastError());
return s.isEmpty() ? "ok" : s;
}
FileEngineIterator::FileEngineIterator(QDir::Filters filters, const QStringList &nameFilters, const QStringList &entries)
: QAbstractFileEngineIterator(filters, nameFilters)
{
m_entries = entries;
/* heck.. docs are unclear on this
* QDirIterator puts iterator before first entry
* but QAbstractFileEngineIterator example puts iterator on first entry
* though QDirIterator approach seems to be the right one
*/
m_index = -1;
}
bool FileEngineIterator::hasNext() const
{
return m_index < m_entries.size() - 1;
}
QString FileEngineIterator::next()
{
if (!hasNext())
return QString();
++m_index;
return currentFilePath();
}
QString FileEngineIterator::currentFileName() const
{
return m_entries.at(m_index);
}