Arianna autonomous DAQ firmware

Dependencies:   mbed SDFileSystemFilinfo AriSnProtocol NetServicesMin AriSnComm MODSERIAL PowerControlClkPatch DS1820OW

SnSDUtils.h

Committer:
uci1
Date:
2012-10-16
Revision:
22:f957c4f840ad
Parent:
21:ce51bb0ba4a5
Child:
25:57b2627fe756

File content as of revision 22:f957c4f840ad:

#ifndef SN_SnSDUtils
#define SN_SnSDUtils

#include <stdio.h>
#include <stdint.h>

#include "SnCommWin.h"
#include "SnBitUtils.h"
#include "SnPowerFrame.h"
#include "SnHeaderFrame.h"

class SnEventFrame;
class SnConfigFrame;

// a namespace-like class to handle the i/o with the SD card

class SnSDUtils {
 public:
    static const char* const kSDdir;
    static const char* const kSDsubDir;
    static const uint8_t     kFNBufSize=128;
    static const uint8_t     kIOvers; // file I/O version
    static const uint32_t    kMaxSizeOfFileHdr;
    
 private:
    
    static
    FILE* OpenSDFile(const char* name, const char* mode);
    
    static
    uint16_t GetSeqNum(const uint64_t macadr,
                       const uint32_t run);
    
    static
    const char* GetOutFileName(const uint64_t macadr,
                               const uint32_t run,
                               const uint16_t seq);
    
    static
    void  DeleteFile(FILE*& f, const char* fname);
        
    static char     fgCurFileName[kFNBufSize];
    static FILE*    fgCurFile;
    static uint16_t fgCurSeq;
    
 public:
    SnSDUtils() {}
    virtual ~SnSDUtils() {}
    
    static
    int   CloseOutputFile(FILE* f) {
        // TODO: set current file pointer to 0, IF f is current file
        const int rt = (f!=0) ? fclose(f) : 0;
        return rt;
    }
    
    static
    FILE* OpenNewOutputFile(const uint64_t macadr,
                            const uint32_t run);
    
    static
    FILE* OpenExistingFile(const char* name, const bool setcurrent);
    
    static
    SnCommWin::ECommWinResult SendAllFiles(SnCommWin* comm,
                                           const uint32_t timeout,
                                           char* const buf,
                                           const uint32_t bsize,
                                           const SnConfigFrame& curConf,
                                                 SnEventFrame& evt,
                                                 SnPowerFrame& pow,
                                           const uint32_t handshakeTimeout);
    
    static
    const char* GetCurFileName() { return fgCurFileName; }
    
    static
    FILE*       GetCurFile() { return fgCurFile; }
    
    static
    uint16_t    GetCurSeqNum() { return fgCurSeq; }

    static
    uint16_t    GetSeqNumFromFileName(const char* fn);
    
    static
    void        GetDirProps(const char* dirname,
                            uint32_t& nfiles,
                            float& totbytes);

    static
    bool        WriteHeartbeatTo(FILE* file,
                                 const uint32_t time,
                                 const uint32_t num);

    static
    bool  WriteEventTo(FILE* efile, char* const evtBuf,
                       const SnEventFrame& evt,
                       const SnConfigFrame& conf);
    
    static
    bool  WriteConfig(FILE* efile,
                      const SnConfigFrame& conf);
    
    template<class T>
    static
    SnCommWin::ECommWinResult WritePowerTo(T& f,
                                           const SnPowerFrame& pow,
                                           uint32_t& pnum) {
        const SnCommWin::ECommWinResult rs = 
            SnHeaderFrame::WriteTo(f, SnHeaderFrame::kPowerCode, 
                                   SnPowerFrame::SizeOf(SnPowerFrame::kIOvers));
        const SnCommWin::ECommWinResult re = pow.WriteTo(f);
        ++pnum;
        return (rs<re) ? rs : re;
    }
    
    template<class T>
    static
    SnCommWin::ECommWinResult ReadBlockHeader(T& f,
                                              uint8_t& mcode,
                                              uint32_t& mlen) {
        return SnHeaderFrame::ReadFrom(f, mcode, mlen);
    }
    
    template<class T>
    static
    SnCommWin::ECommWinResult WriteFileHeader(T& f, const uint64_t macadr,
                      const uint32_t run, const uint16_t seq) {
        // MUST INCREMENT kIOvers if these writes are altered
        f = SnBitUtils::WriteTo(f, kIOvers);
        f = SnBitUtils::WriteTo(f, macadr);
        f = SnBitUtils::WriteTo(f, run);
        f = SnBitUtils::WriteTo(f, seq);
        return SnCommWin::kOkMsgSent;
    }
    
    template<class T>
    static
    SnCommWin::ECommWinResult ReadFileHeader(T& f, uint64_t& macadr,
                     uint32_t& run, uint16_t& seq,
                     SnPowerFrame* pow=0) {
        SnCommWin::ECommWinResult res = SnCommWin::kOkWithMsg;
        uint8_t Rv=0;
        f = SnBitUtils::ReadFrom(f, Rv);
        f = SnBitUtils::ReadFrom(f, macadr);
        f = SnBitUtils::ReadFrom(f, run);
        f = SnBitUtils::ReadFrom(f, seq);
        if (Rv==2) {
            uint16_t v1, v2;
            f = SnBitUtils::ReadFrom(f, v1);
            f = SnBitUtils::ReadFrom(f, v2);
            if (pow!=0) {
                pow->Set(v1, v2, 0, 0, 0);
            }
        }
        return res;
    }
    
    static
    uint32_t SizeOfFileHeader(const uint8_t rv) {
        if (rv==2) {
            return kMaxSizeOfFileHdr;
        } else {
            return sizeof(uint8_t)+sizeof(uint64_t)+sizeof(uint32_t)+sizeof(uint16_t);
        }
    }
    
    friend class SnSDUtilsWhisperer; // to restrict access to specific functions
};

class SnSDUtilsWhisperer {
    static
    void  DeleteFile(FILE*& f, const char* fname) {
        return SnSDUtils::DeleteFile(f, fname);
    }
    
    friend class SnCommWin; // the one who's allowed to use me
};

#endif // SN_SnSDUtils