FileDownlink.hpp

Go to the documentation of this file.

// ======================================================================
// \title  FileDownlink.hpp
// \author bocchino, mstarch
// \brief  hpp file for FileDownlink component implementation class
//
// \copyright
// Copyright 2009-2015, by the California Institute of Technology.
// ALL RIGHTS RESERVED.  United States Government Sponsorship
// acknowledged.
// ======================================================================
 
#ifndef Svc_FileDownlink_HPP
#define Svc_FileDownlink_HPP
 
#include <FileDownlinkCfg.hpp>
#include <Svc/FileDownlink/FileDownlinkComponentAc.hpp>
#include <Fw/FilePacket/FilePacket.hpp>
#include <Os/File.hpp>
#include <Os/Mutex.hpp>
#include <Os/Queue.hpp>
 
 
namespace Svc {
 
  class FileDownlink :
    public FileDownlinkComponentBase
  {
 
    PRIVATE:
 
      // ----------------------------------------------------------------------
      // Types
      // ----------------------------------------------------------------------
 
      class Mode {
 
        public:
 
          typedef enum { IDLE, DOWNLINK, CANCEL, WAIT, COOLDOWN } Type;
 
        public:
 
          Mode(void) : value(IDLE) { }
 
        public:
 
          void set(const Type value) {
            this->mutex.lock();
            this->value = value;
            this->mutex.unLock();
          }
 
          Type get(void) {
            this->mutex.lock();
            const Type value = this->value;
            this->mutex.unLock();
            return value;
          }
 
        private:
 
          Type value;
 
          Os::Mutex mutex;
      };
 
      class File {
 
        public:
 
          File() : size(0) { }
 
        public:
 
          Fw::LogStringArg sourceName;
 
          Fw::LogStringArg destName;
 
          Os::File osFile;
 
          U32 size;
 
        PRIVATE:
 
          CFDP::Checksum checksum;
 
        public:
 
          Os::File::Status open(
              const char *const sourceFileName, 
              const char *const destFileName 
          );
 
          Os::File::Status read(
              U8 *const data,
              const U32 byteOffset,
              const U32 size
          );
 
          void getChecksum(CFDP::Checksum& checksum) {
            checksum = this->checksum;
          }
      };
 
      class FilesSent {
 
        public:
 
          FilesSent(FileDownlink *const fileDownlink) :
            n(0), fileDownlink(fileDownlink)
          { }
 
        public:
 
          void fileSent(void) {
            ++this->n;
            this->fileDownlink->tlmWrite_FilesSent(n);
          }
 
        PRIVATE:
 
          U32 n;
 
          FileDownlink *const fileDownlink;
 
      };
 
      class PacketsSent {
 
        public:
 
          PacketsSent(FileDownlink *const fileDownlink) :
            n(0), fileDownlink(fileDownlink)
          { }
 
        public:
 
          void packetSent(void) {
            ++this->n;
            this->fileDownlink->tlmWrite_PacketsSent(n);
          }
 
        PRIVATE:
 
          U32 n;
 
          FileDownlink *const fileDownlink;
 
      };
 
      class Warnings {
 
        public:
 
          Warnings(FileDownlink *const fileDownlink) :
            n(0), fileDownlink(fileDownlink)
          { }
 
        public:
 
          void fileOpenError(void);
 
          void fileRead(const Os::File::Status status);
 
        PRIVATE:
 
          void warning(void) {
            ++this->n;
            this->fileDownlink->tlmWrite_Warnings(n);
          }
 
        PRIVATE:
 
          U32 n;
 
          FileDownlink *const fileDownlink;
 
      };
 
      enum CallerSource { COMMAND, PORT };
 
      #define FILE_ENTRY_FILENAME_LEN 101
 
      struct FileEntry {
        char srcFilename[FILE_ENTRY_FILENAME_LEN]; // Name of requested file
        char destFilename[FILE_ENTRY_FILENAME_LEN]; // Name of requested file
        U32 offset;
        U32 length;
        CallerSource source; // Source of the downlink request
        FwOpcodeType opCode; // Op code of command, only set for CMD sources.
        U32 cmdSeq; // CmdSeq number, only set for CMD sources.
        U32 context; // Context id of request, only set for PORT sources.
      };
 
      enum PacketType {
          FILE_PACKET,
          CANCEL_PACKET,
          COUNT_PACKET_TYPE
      };
 
    public:
 
      // ----------------------------------------------------------------------
      // Construction, initialization, and destruction
      // ----------------------------------------------------------------------
 
      FileDownlink(
          const char *const compName 
      );
 
      void init(
          const NATIVE_INT_TYPE queueDepth, 
          const NATIVE_INT_TYPE instance 
      );
 
      void configure(
          U32 timeout, 
          U32 cooldown, 
          U32 cycleTime, 
          U32 fileQueueDepth 
      );
 
      void start(
        NATIVE_INT_TYPE identifier,
        NATIVE_INT_TYPE priority,
        NATIVE_INT_TYPE stackSize,
        NATIVE_INT_TYPE cpuAffinity=-1
      );
 
      ~FileDownlink(void);
 
    PRIVATE:
 
      // ----------------------------------------------------------------------
      // Handler implementations for user-defined typed input ports
      // ----------------------------------------------------------------------
 
      void Run_handler(
          const NATIVE_INT_TYPE portNum, 
          NATIVE_UINT_TYPE context 
      );
 
 
      Svc::SendFileResponse SendFile_handler(
          const NATIVE_INT_TYPE portNum, 
          sourceFileNameString sourceFilename, 
          destFileNameString destFilename, 
          U32 offset, 
          U32 length 
      );
 
      void bufferReturn_handler(
          const NATIVE_INT_TYPE portNum, 
          Fw::Buffer &fwBuffer
      );
 
      void pingIn_handler(
          const NATIVE_INT_TYPE portNum, 
          U32 key 
      );
 
 
 
    PRIVATE:
 
      // ----------------------------------------------------------------------
      // Command handler implementations
      // ----------------------------------------------------------------------
 
      void SendFile_cmdHandler(
          const FwOpcodeType opCode, 
          const U32 cmdSeq, 
          const Fw::CmdStringArg& sourceFilename, 
          const Fw::CmdStringArg& destFilename 
      );
 
      void Cancel_cmdHandler(
          const FwOpcodeType opCode, 
          const U32 cmdSeq 
      );
 
      void SendPartial_cmdHandler(
          FwOpcodeType opCode, 
          U32 cmdSeq, 
          const Fw::CmdStringArg& sourceFilename, 
          const Fw::CmdStringArg& destFilename, 
          U32 startOffset, 
          U32 length 
      );
 
 
    PRIVATE:
 
      // ----------------------------------------------------------------------
      // Private helper methods
      // ----------------------------------------------------------------------
 
 
      void sendFile(
          const char* sourceFilename, 
          const char* destFilename, 
          U32 startOffset, 
          U32 length 
      );
 
      //Individual packet transfer functions
      Os::File::Status sendDataPacket(U32 &byteOffset);
      void sendCancelPacket(void);
      void sendEndPacket(void);
      void sendStartPacket(void);
      void sendFilePacket(const Fw::FilePacket& filePacket);
 
      //State-helper functions
      void exitFileTransfer(void);
      void enterCooldown(void);
 
      //Function to acquire a buffer internally
      void getBuffer(Fw::Buffer& buffer, PacketType type);
      //Downlink the "next" packet
      void downlinkPacket();
      //Finish the file transfer
      void finishHelper(bool is_cancel);
      // Convert internal status enum to a command response;
      Fw::CommandResponse statusToCmdResp(SendFileStatus status);
      //Send response after completing file downlink
      void sendResponse(SendFileStatus resp);
 
    PRIVATE:
 
      // ----------------------------------------------------------------------
      // Member variables
      // ----------------------------------------------------------------------
 
      bool configured;
 
      Os::Queue fileQueue;
 
      U8 memoryStore[COUNT_PACKET_TYPE][FILEDOWNLINK_INTERNAL_BUFFER_SIZE];
 
      Mode mode;
 
      File file;
 
      FilesSent filesSent;
 
      PacketsSent packetsSent;
 
      Warnings warnings;
 
      U32 sequenceIndex;
 
      U32 timeout;
 
      U32 cooldown;
 
      U32 curTimer;
 
      U32 cycleTime;
 
      Fw::Buffer buffer;
 
      U32 bufferSize;
 
      U32 byteOffset;
 
      U32 endOffset;
 
      Fw::FilePacket::Type lastCompletedType;
 
      U32 lastBufferId;
 
      struct FileEntry curEntry;
 
      U32 cntxId;
    };
 
} // end namespace Svc
 
#endif