FileManager.hpp

Go to the documentation of this file.

// ======================================================================
// \title  FileManager.hpp
// \author bocchino
// \brief  hpp file for FileManager component implementation class
//
// \copyright
// Copyright 2009-2015, by the California Institute of Technology.
// ALL RIGHTS RESERVED.  United States Government Sponsorship
// acknowledged.
//
// ======================================================================

#ifndef Svc_FileManager_HPP
#define Svc_FileManager_HPP

#include <atomic>
#include "Os/FileSystem.hpp"
#include "Svc/FileManager/FileManagerComponentAc.hpp"

namespace Svc {

class FileManager final : public FileManagerComponentBase {
    friend class FileManagerTester;

  public:
    // ----------------------------------------------------------------------
    // Construction, initialization, and destruction
    // ----------------------------------------------------------------------

    FileManager(const char* const compName  
    );

    ~FileManager();

  private:
    // ----------------------------------------------------------------------
    // Command handler implementations
    // ----------------------------------------------------------------------

    void CreateDirectory_cmdHandler(const FwOpcodeType opCode,       
                                    const U32 cmdSeq,                
                                    const Fw::CmdStringArg& dirName  
                                    ) override;

    void RemoveFile_cmdHandler(const FwOpcodeType opCode,         
                               const U32 cmdSeq,                  
                               const Fw::CmdStringArg& fileName,  
                               const bool ignoreErrors            
                               ) override;

    void MoveFile_cmdHandler(const FwOpcodeType opCode,               
                             const U32 cmdSeq,                        
                             const Fw::CmdStringArg& sourceFileName,  
                             const Fw::CmdStringArg& destFileName     
                             ) override;

    void RemoveDirectory_cmdHandler(const FwOpcodeType opCode,       
                                    const U32 cmdSeq,                
                                    const Fw::CmdStringArg& dirName  
                                    ) override;

    void AppendFile_cmdHandler(const FwOpcodeType opCode,       
                               const U32 cmdSeq,                
                               const Fw::CmdStringArg& source,  
                               const Fw::CmdStringArg& target   
                               ) override;

    void FileSize_cmdHandler(const FwOpcodeType opCode,        
                             const U32 cmdSeq,                 
                             const Fw::CmdStringArg& fileName  
                             ) override;

    void ListDirectory_cmdHandler(const FwOpcodeType opCode,       
                                  const U32 cmdSeq,                
                                  const Fw::CmdStringArg& dirName  
                                  ) override;

    void CalculateCrc_cmdHandler(FwOpcodeType opCode,              
                                 U32 cmdSeq,                       
                                 const Fw::CmdStringArg& filename  
                                 ) override;

    void pingIn_handler(const FwIndexType portNum, 
                        U32 key                    
                        ) override;

    void schedIn_handler(const FwIndexType portNum, 
                         U32 context                
                         ) override;

  private:
    // ----------------------------------------------------------------------
    // Helper methods
    // ----------------------------------------------------------------------

    void emitTelemetry(const Os::FileSystem::Status status  
    );

    void sendCommandResponse(const FwOpcodeType opCode,           
                             const U32 cmdSeq,                    
                             const Os::FileSystem::Status status  
    );

  private:
    // ----------------------------------------------------------------------
    // Handler implementations for user-defined internal interfaces
    // ----------------------------------------------------------------------

    void run_internalInterfaceHandler() override;

  private:
    // ----------------------------------------------------------------------
    // Variables
    // ----------------------------------------------------------------------

    U32 commandCount;

    U32 errorCount;

    // ----------------------------------------------------------------------
    // Directory listing state machine variables
    // ----------------------------------------------------------------------
    // The FileManager uses an asynchronous state machine to process
    // directory listings through Rate Group 2. This prevents event
    // flooding and ensures bounded execution time by processing one
    // directory entry per rate tick (0.5Hz).

    enum ListDirectoryState {
        IDLE,                
        LISTING_IN_PROGRESS  
    };

    ListDirectoryState m_listState;

    Os::Directory m_currentDir;

    Fw::String m_currentDirName;

    U32 m_totalEntries;

    FwOpcodeType m_currentOpCode;

    U32 m_currentCmdSeq;

    std::atomic<bool> m_runQueued;
};

}  // end namespace Svc

#endif