decoderthread.h

Go to the documentation of this file.

#ifndef decoderthread_HEADER_GUARD
#define decoderthread_HEADER_GUARD
/*
 * decoderthread.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 Affero 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 Affero General Public License for more details.
 *
 * You should have received a copy of the GNU Affero General Public License
 * along with this program.  If not, see <https://www.gnu.org/licenses/>
 *
 */
 
#include "constant.h"
#include "frame.h"
#include "thread.h" 
#include "decoder.h"
#include "tools.h"
#include "framefilter.h"
 
class DecoderThread : public Thread { // <pyapi>
  
public: // <pyapi>
    DecoderThread(const char* name, FrameFilter& outfilter, FrameFifoContext fifo_ctx=FrameFifoContext()); // <pyapi>
    virtual ~DecoderThread(); 
    
protected: // frame input
    FrameFifo               infifo;           
    FifoFrameFilter         infilter;         
    BlockingFifoFrameFilter infilter_block;   
    int                     n_threads;
    
protected:
    FrameFilter& outfilter;                
    std::vector<Decoder*> decoders;        
    long int     mstimetolerance;          
    AbstractFileState state;               
    std::vector<SetupFrame> setupframes;   
 
private: // framefilter for chaining output for outfilter2
    TimestampFrameFilter2 timefilter;
    bool use_time_correction;
 
protected:
    bool is_decoding; 
        
protected: // Thread member redefinitions
    std::deque<AVSignalContext> signal_fifo;   
 
protected:
    virtual Decoder* chooseAudioDecoder(AVCodecID codec_id);
    virtual Decoder* chooseVideoDecoder(AVCodecID codec_id); 
    virtual Decoder* fallbackAudioDecoder(AVCodecID codec_id);
    virtual Decoder* fallbackVideoDecoder(AVCodecID codec_id);
 
public: // redefined virtual functions
    void run();
    void preRun();
    void postRun();
    void sendSignal(AVSignalContext signal_ctx); 
    
protected: 
    FrameFifo &getFifo();
        
protected:
    void handleSignals();
        
public: // API <pyapi>
    void setTimeCorrection(bool val);             // <pyapi>
    FifoFrameFilter &getFrameFilter();            // <pyapi>
    FifoFrameFilter &getBlockingFrameFilter();    // <pyapi>
    void setTimeTolerance(long int mstol);    
    void setNumberOfThreads(int n_threads);       // <pyapi>
    void decodingOnCall();   
    void decodingOffCall();  
    void requestStopCall();  
}; // <pyapi>
 
 
#endif