valkkafsreader.h

Go to the documentation of this file.

#ifndef valkkafsreader_HEADER_GUARD
#define valkkafsreader_HEADER_GUARD
/*
 * valkkafsreader.h :
 * 
 * (c) Copyright 2017-2024 Sampsa Riikonen
 * 
 * Authors: Sampsa Riikonen <sampsa.riikonen@iki.fi>
 * 
 * This file is part of the Valkka library.
 * 
 * Valkka is free software: you can redistribute it and/or modify
 * it under the terms of the GNU Lesser General Public License as
 * published by the Free Software Foundation, either version 3 of the
 * License, or (at your option) any later version.
 * 
 * This program is distributed in the hope that it will be useful,
 * but WITHOUT ANY WARRANTY; without even the implied warranty of
 * MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
 * GNU Lesser General Public License for more details.
 *
 * You should have received a copy of the GNU Lesser General Public License
 * along with this program.  If not, see <https://www.gnu.org/licenses/>
 *
 */
 
#include "common.h"
#include "thread.h"
#include "framefifo.h"
#include "framefilter.h"
#include "valkkafs.h"
#include "rawrite.h"
 
class ValkkaFSReaderThread : public Thread {                                                // <pyapi>
 
public:                                                                                     // <pyapi>
    ValkkaFSReaderThread(const char *name, ValkkaFS &valkkafs, FrameFilter &outfilter, FrameFifoContext fifo_ctx=FrameFifoContext(10), bool o_direct = false);     // <pyapi>
    ~ValkkaFSReaderThread();                                                                // <pyapi>
 
protected:
    ValkkaFS                        &valkkafs;
    FrameFilter                     &outfilter;
    std::map<IdNumber, SlotNumber>  id_to_slot;
    // std::fstream                    filestream;
    RawReader                       raw_reader;
    
protected: // frame input
    FrameFifo               infifo;           
    FifoFrameFilter         infilter;         
 
protected: // Thread member redefinitions
    std::deque<ValkkaFSReaderSignalContext> signal_fifo;   
  
public: // redefined virtual functions
    void run();
    void preRun();
    void postRun();
    void sendSignal(ValkkaFSReaderSignalContext signal_ctx);    
      
protected:
    void handleSignal(ValkkaFSReaderSignalContext &signal_ctx); 
    void handleSignals();                                       
 
protected:
    void setSlotId(SlotNumber slot, IdNumber id);
    void unSetSlotId(IdNumber id);
    void clearSlotId();
    void reportSlotId();
    void pullBlocks(std::list<std::size_t> block_list);
    
// API
public:                                                       // <pyapi>
    FifoFrameFilter &getFrameFilter();                        // <pyapi>
    void setSlotIdCall(SlotNumber slot, IdNumber id);         // <pyapi>
    void unSetSlotIdCall(IdNumber id);                    // <pyapi>
    void clearSlotIdCall();                                   // <pyapi>
    void reportSlotIdCall();                                  // <pyapi>
    void pullBlocksCall(std::list<std::size_t> block_list);
    void pullBlocksPyCall(PyObject *pylist);                  // <pyapi>
    void requestStopCall();                                   // <pyapi>
};                                                            // <pyapi>
 
 
 
 
#endif