FileSystem.cpp

Go to the documentation of this file.

#include <FpConfig.hpp>
#include <Fw/Types/Assert.hpp>
#include <Os/File.hpp>
#include <Os/FileSystem.hpp>
 
#include <dirent.h>
#include <sys/stat.h>
#include <sys/statvfs.h>
#include <unistd.h>
#include <cerrno>
#include <cstdio>  // Needed for rename
#include <cstring>
#include <limits>
 
namespace Os {
 
namespace FileSystem {
 
Status createDirectory(const char* path) {
    Status stat = OP_OK;
 
#ifdef __VXWORKS__
    int mkStat = ::mkdir(path);
#else
    int mkStat = ::mkdir(path, S_IRWXU);
#endif
 
    if (-1 == mkStat) {
        switch (errno) {
            case EACCES:
            case EPERM:
            case EROFS:
            case EFAULT:
                stat = NO_PERMISSION;
                break;
            case EEXIST:
                stat = ALREADY_EXISTS;
                break;
            case ELOOP:
            case ENOENT:
            case ENAMETOOLONG:
                stat = INVALID_PATH;
                break;
            case ENOTDIR:
                stat = NOT_DIR;
                break;
            case ENOSPC:
            case EDQUOT:
                stat = NO_SPACE;
                break;
            case EMLINK:
                stat = FILE_LIMIT;
                break;
            default:
                stat = OTHER_ERROR;
                break;
        }
    }
 
    return stat;
}  // end createDirectory
 
Status removeDirectory(const char* path) {
    Status stat = OP_OK;
 
    if (::rmdir(path) == -1) {
        switch (errno) {
            case EACCES:
            case EPERM:
            case EROFS:
            case EFAULT:
                stat = NO_PERMISSION;
                break;
            case ENOTEMPTY:
            case EEXIST:
                stat = NOT_EMPTY;
                break;
            case EINVAL:
            case ELOOP:
            case ENOENT:
            case ENAMETOOLONG:
                stat = INVALID_PATH;
                break;
            case ENOTDIR:
                stat = NOT_DIR;
                break;
            case EBUSY:
                stat = BUSY;
                break;
            default:
                stat = OTHER_ERROR;
                break;
        }
    }
 
    return stat;
}  // end removeDirectory
 
Status readDirectory(const char* path, const U32 maxNum, Fw::String fileArray[], U32& numFiles) {
    Status dirStat = OP_OK;
    DIR* dirPtr = nullptr;
    struct dirent* direntData = nullptr;
 
    FW_ASSERT(fileArray != nullptr);
    FW_ASSERT(path != nullptr);
 
    // Open directory failed:
    if ((dirPtr = ::opendir(path)) == nullptr) {
        switch (errno) {
            case EACCES:
                dirStat = NO_PERMISSION;
                break;
            case ENOENT:
                dirStat = INVALID_PATH;
                break;
            case ENOTDIR:
                dirStat = NOT_DIR;
                break;
            default:
                dirStat = OTHER_ERROR;
                break;
        }
        return dirStat;
    }
 
    // Set errno to 0 so we know why we exited readdir
    errno = 0;
    U32 arrayIdx = 0;
    U32 limitCount = 0;
    const U32 loopLimit = std::numeric_limits<U32>::max();
 
    // Read the directory contents and store in passed in array:
    while (arrayIdx < maxNum && limitCount < loopLimit) {
        ++limitCount;
 
        if ((direntData = ::readdir(dirPtr)) != nullptr) {
            // We are only care about regular files
            if (direntData->d_type == DT_REG) {
                FW_ASSERT(arrayIdx < maxNum, static_cast<NATIVE_INT_TYPE>(arrayIdx),
                          static_cast<NATIVE_INT_TYPE>(maxNum));
 
                Fw::String str(direntData->d_name);
                fileArray[arrayIdx++] = str;
            }
        } else {
            // readdir failed, did it error or did we run out of files?
            if (errno != 0) {
                // Only error from readdir is EBADF
                dirStat = OTHER_ERROR;
            }
            break;
        }
    }
 
    if (limitCount == loopLimit) {
        dirStat = FILE_LIMIT;
    }
 
    if (::closedir(dirPtr) == -1) {
        // Only error from closedir is EBADF
        dirStat = OTHER_ERROR;
    }
 
    numFiles = arrayIdx;
 
    return dirStat;
}
 
Status removeFile(const char* path) {
    Status stat = OP_OK;
 
    if (::unlink(path) == -1) {
        switch (errno) {
            case EACCES:
            case EPERM:
            case EROFS:
                stat = NO_PERMISSION;
                break;
            case EISDIR:
                stat = IS_DIR;
                break;
            case ELOOP:
            case ENOENT:
            case ENAMETOOLONG:
                stat = INVALID_PATH;
                break;
            case ENOTDIR:
                stat = NOT_DIR;
                break;
            case EBUSY:
                stat = BUSY;
                break;
            default:
                stat = OTHER_ERROR;
                break;
        }
    }
 
    return stat;
}  // end removeFile
 
Status moveFile(const char* originPath, const char* destPath) {
    Status stat = OP_OK;
 
    if (::rename(originPath, destPath) == -1) {
        switch (errno) {
            case EACCES:
            case EPERM:
            case EROFS:
            case EFAULT:
                stat = NO_PERMISSION;
                break;
            case EDQUOT:
            case ENOSPC:
                stat = NO_SPACE;
                break;
            case ELOOP:
            case ENAMETOOLONG:
            case ENOENT:
            case EINVAL:
                stat = INVALID_PATH;
                break;
            case ENOTDIR:
            case EISDIR:  // Old path is not a dir
                stat = NOT_DIR;
                break;
            case ENOTEMPTY:
            case EEXIST:
                stat = NOT_EMPTY;
                break;
            case EMLINK:
                stat = FILE_LIMIT;
                break;
            case EBUSY:
                stat = BUSY;
                break;
            default:
                stat = OTHER_ERROR;
                break;
        }
    }
    return stat;
 
}  // end moveFile
 
Status handleFileError(File::Status fileStatus) {
    Status fileSystemStatus = OTHER_ERROR;
 
    switch (fileStatus) {
        case File::NO_SPACE:
            fileSystemStatus = NO_SPACE;
            break;
        case File::NO_PERMISSION:
            fileSystemStatus = NO_PERMISSION;
            break;
        case File::DOESNT_EXIST:
            fileSystemStatus = INVALID_PATH;
            break;
        default:
            fileSystemStatus = OTHER_ERROR;
    }
    return fileSystemStatus;
}  // end handleFileError
 
Status initAndCheckFileStats(const char* filePath, struct stat* fileInfo = nullptr) {
    FileSystem::Status fs_status;
    struct stat local_info;
    if (!fileInfo) {
        // No external struct given, so use the local one
        fileInfo = &local_info;
    }
 
    if (::stat(filePath, fileInfo) == -1) {
        switch (errno) {
            case EACCES:
                fs_status = NO_PERMISSION;
                break;
            case ELOOP:
            case ENOENT:
            case ENAMETOOLONG:
                fs_status = INVALID_PATH;
                break;
            case ENOTDIR:
                fs_status = NOT_DIR;
                break;
            default:
                fs_status = OTHER_ERROR;
                break;
        }
        return fs_status;
    }
 
    // Make sure the origin is a regular file
    if (!S_ISREG(fileInfo->st_mode)) {
        return INVALID_PATH;
    }
 
    return OP_OK;
}
 
Status copyFileData(File& source, File& destination, FwSignedSizeType size) {
    static_assert(FILE_SYSTEM_CHUNK_SIZE != 0, "FILE_SYSTEM_CHUNK_SIZE must be >0");
    U8 fileBuffer[FILE_SYSTEM_CHUNK_SIZE];
    File::Status file_status;
 
    // Set loop limit
    const FwSignedSizeType copyLoopLimit = (size / FILE_SYSTEM_CHUNK_SIZE) + 2;
 
    FwSignedSizeType loopCounter = 0;
    FwSignedSizeType chunkSize;
    while (loopCounter < copyLoopLimit) {
        chunkSize = FILE_SYSTEM_CHUNK_SIZE;
        file_status = source.read(fileBuffer, chunkSize, Os::File::WaitType::NO_WAIT);
        if (file_status != File::OP_OK) {
            return handleFileError(file_status);
        }
 
        if (chunkSize == 0) {
            // file has been successfully copied
            break;
        }
 
        file_status = destination.write(fileBuffer, chunkSize, Os::File::WaitType::WAIT);
        if (file_status != File::OP_OK) {
            return handleFileError(file_status);
        }
        loopCounter++;
    }
    FW_ASSERT(loopCounter < copyLoopLimit);
 
    return FileSystem::OP_OK;
}  // end copyFileData
 
Status copyFile(const char* originPath, const char* destPath) {
    FileSystem::Status fs_status;
    File::Status file_status;
 
    FwSignedSizeType fileSize = 0;
 
    File source;
    File destination;
 
    fs_status = initAndCheckFileStats(originPath);
    if (FileSystem::OP_OK != fs_status) {
        return fs_status;
    }
 
    // Get the file size:
    fs_status =
        FileSystem::getFileSize(originPath, fileSize);  
    if (FileSystem::OP_OK != fs_status) {
        return fs_status;
    }
 
    file_status = source.open(originPath, File::OPEN_READ);
    if (file_status != File::OP_OK) {
        return handleFileError(file_status);
    }
 
    file_status = destination.open(destPath, File::OPEN_WRITE);
    if (file_status != File::OP_OK) {
        return handleFileError(file_status);
    }
 
    fs_status = copyFileData(source, destination, fileSize);
 
    (void)source.close();
    (void)destination.close();
 
    return fs_status;
}  // end copyFile
 
Status appendFile(const char* originPath, const char* destPath, bool createMissingDest) {
    FileSystem::Status fs_status;
    File::Status file_status;
    FwSignedSizeType fileSize = 0;
 
    File source;
    File destination;
 
    fs_status = initAndCheckFileStats(originPath);
    if (FileSystem::OP_OK != fs_status) {
        return fs_status;
    }
 
    // Get the file size:
    fs_status =
        FileSystem::getFileSize(originPath, fileSize);  
    if (FileSystem::OP_OK != fs_status) {
        return fs_status;
    }
 
    file_status = source.open(originPath, File::OPEN_READ);
    if (file_status != File::OP_OK) {
        return handleFileError(file_status);
    }
 
    // If needed, check if destination file exists (and exit if not)
    if (!createMissingDest) {
        fs_status = initAndCheckFileStats(destPath);
        if (FileSystem::OP_OK != fs_status) {
            return fs_status;
        }
    }
 
    file_status = destination.open(destPath, File::OPEN_APPEND);
    if (file_status != File::OP_OK) {
        return handleFileError(file_status);
    }
 
    fs_status = copyFileData(source, destination, fileSize);
 
    (void)source.close();
    (void)destination.close();
 
    return fs_status;
}  // end appendFile
 
Status getFileSize(const char* path, FwSignedSizeType& size) {
    Status fileStat = OP_OK;
    struct stat fileStatStruct;
 
    fileStat = initAndCheckFileStats(path, &fileStatStruct);
    if (FileSystem::OP_OK == fileStat) {
        // Only check size if struct was initialized successfully
        size = fileStatStruct.st_size;
        if (static_cast<off_t>(size) != fileStatStruct.st_size) {
            return FileSystem::OTHER_ERROR;
        }
    }
 
    return fileStat;
}  // end getFileSize
 
Status changeWorkingDirectory(const char* path) {
    Status stat = OP_OK;
 
    if (::chdir(path) == -1) {
        switch (errno) {
            case EACCES:
            case EFAULT:
                stat = NO_PERMISSION;
                break;
            case ENOTEMPTY:
                stat = NOT_EMPTY;
                break;
            case ENOENT:
            case ELOOP:
            case ENAMETOOLONG:
                stat = INVALID_PATH;
                break;
            case ENOTDIR:
                stat = NOT_DIR;
                break;
            default:
                stat = OTHER_ERROR;
                break;
        }
    }
 
    return stat;
}  // end changeWorkingDirectory
 
Status getFreeSpace(const char* path, FwSizeType& totalBytes, FwSizeType& freeBytes) {
    Status stat = OP_OK;
 
    struct statvfs fsStat;
    int ret = statvfs(path, &fsStat);
    if (ret) {
        switch (errno) {
            case EACCES:
                stat = NO_PERMISSION;
                break;
            case ELOOP:
            case ENOENT:
            case ENAMETOOLONG:
                stat = INVALID_PATH;
                break;
            case ENOTDIR:
                stat = NOT_DIR;
                break;
            default:
                stat = OTHER_ERROR;
                break;
        }
        return stat;
    }
 
    const FwSizeType block_size = static_cast<FwSizeType>(fsStat.f_frsize);
    const FwSizeType free_blocks = static_cast<FwSizeType>(fsStat.f_bfree);
    const FwSizeType total_blocks = static_cast<FwSizeType>(fsStat.f_blocks);
 
    // Check for casting and type error
    if (((block_size <= 0) || (static_cast<unsigned long>(block_size) != fsStat.f_frsize)) ||
        ((free_blocks <= 0) || (static_cast<fsblkcnt_t>(free_blocks) != fsStat.f_bfree)) ||
        ((total_blocks <= 0) || (static_cast<fsblkcnt_t>(block_size) != fsStat.f_blocks))) {
        return OTHER_ERROR;
    }
    // Check for overflow in multiplication
    if (free_blocks > (std::numeric_limits<FwSizeType>::max() / block_size) ||
        total_blocks > (std::numeric_limits<FwSizeType>::max() / block_size)) {
        return OTHER_ERROR;
    }
    freeBytes = free_blocks * block_size;
    totalBytes = total_blocks * block_size;
    return stat;
}
 
// Public function to get the file count for a given directory.
Status getFileCount(const char* directory, U32& fileCount) {
    Status dirStat = OP_OK;
    DIR* dirPtr = nullptr;
    struct dirent* direntData = nullptr;
    U32 limitCount;
    const U32 loopLimit = std::numeric_limits<U32>::max();
 
    fileCount = 0;
    if ((dirPtr = ::opendir(directory)) == nullptr) {
        switch (errno) {
            case EACCES:
                dirStat = NO_PERMISSION;
                break;
            case ENOENT:
                dirStat = INVALID_PATH;
                break;
            case ENOTDIR:
                dirStat = NOT_DIR;
                break;
            default:
                dirStat = OTHER_ERROR;
                break;
        }
        return dirStat;
    }
 
    // Set errno to 0 so we know why we exited readdir
    errno = 0;
    for (limitCount = 0; limitCount < loopLimit; limitCount++) {
        if ((direntData = ::readdir(dirPtr)) != nullptr) {
            // We are only counting regular files
            if (direntData->d_type == DT_REG) {
                fileCount++;
            }
        } else {
            // readdir failed, did it error or did we run out of files?
            if (errno != 0) {
                // Only error from readdir is EBADF
                dirStat = OTHER_ERROR;
            }
            break;
        }
    }
    if (limitCount == loopLimit) {
        dirStat = FILE_LIMIT;
    }
 
    if (::closedir(dirPtr) == -1) {
        // Only error from closedir is EBADF
        dirStat = OTHER_ERROR;
    }
 
    return dirStat;
}  // end getFileCount
 
}  // namespace FileSystem
 
}  // namespace Os