FilesystemIO.h

Go to the documentation of this file.

#ifndef FILESYSTEMIO_H
#define FILESYSTEMIO_H
 
#include <string>
#include <unistd.h>
#include <list>
 
#include "IOChannel.h"
#include "Sensors/SensorBoard.h"
#include "Utility/Types.h"
 
#define MAX_FILENAME_SIZE   (4096)
 
// Invalidate the first 10MB of cache when initially snapping a request.
#define INVALIDATE_SIZE     (0xA00000)
 
// Observer class for the FilesystemIO channel. has hooks incase the subclasser doesn't care about a specific operation.
class tcFilesystemIOWatcher {
public:
    tcFilesystemIOWatcher() {}
    virtual ~tcFilesystemIOWatcher() {}
 
    virtual void onFileWritten(int32 anNumWritten) {}
 
    enum teWriteError {
        eeIndexMismatch,
        eeFrameWriteFailure
    };
 
    virtual void onWriteErrorDetected(teWriteError aeError) {}
};
 
class tcFilesystemIO: public tcIOChannel
{
public:
    tcFilesystemIO(SocCamera::tcSensorBoard *apSensor);
    virtual ~tcFilesystemIO();
 
    void registerWatcher(tcFilesystemIOWatcher *apWatcher);
 
    void unregisterWatcher(tcFilesystemIOWatcher *apWatcher);
 
    virtual SocCamera::teNackCode capture(tsCaptureRequest asRequest);
 
    virtual SocCamera::teNackCode setBpp(SocCamera::teBPPMode aeBppMode);
 
    virtual void sendUpdate(tsNewFrameMsg *apMsg);
 
    SocCamera::teNackCode setFilenamePrefix(std::string asName);
 
    std::string getFilenamePrefix();
 
    SocCamera::teNackCode setImagesPerFile(uint32 anImagesPerFile);
 
    uint32 getImagesPerFile();
 
    SocCamera::teNackCode setPath(std::string asPath, bool abCreate = true);
 
    std::string getPath();
 
    SocCamera::teNackCode flush();
 
    uint32 getCurrentFrameIndex();
 
private:
    void closeAll();
 
    void issueWriteError(tcFilesystemIOWatcher::teWriteError aeError);
 
    bool mbIsOpen;
    bool mbOutputting;
    bool mbCancel;
    tcMutex mcFileMutex;
    FILE* mpIndexFile;
    FILE* mpRawFile;
    uint32 mnCurrentHeaderIndex;
    uint32 mnImagesSinceClose;
    uint32 mnImagesToWrite;
 
    uint32 mnBufferSize;
    uint8* mpIntermediateBuffer;
 
    std::string msFilePrefix;
    std::string msPath;
    std::string msExtension;
    char maFilename[MAX_FILENAME_SIZE];
 
    std::list<tcFilesystemIOWatcher*> mcWatcherList;
 
    uint32 mnImagesWritten;
};
 
#endif // FILESYSTEMIO_H