filestream.h

Go to the documentation of this file.

#ifndef filestream_HEADER_GUARD
#define filestream_HEADER_GUARD
/*
 * filestream.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 "frame.h"
#include "thread.h"
#include "framefilter.h"
#include "logging.h"
#include "tools.h"
 
 
 
class AbstractFileStream {                  // <pyapi>
  
public:                                     // <pyapi>
    AbstractFileStream();                   // <pyapi>
    virtual ~AbstractFileStream();          // <pyapi>
 
protected:
    long int    reftime;                
    long int    target_mstimestamp_;    
    long int    frame_mstimestamp_;     
    AbstractFileState   state;          
    Frame       *next_frame;            
    BasicFrame  out_frame;              
    
public: // getters
    AbstractFileState   getState() {return this->state;}
    
public:
    void setRefMstime(long int ms_streamtime_);  
    void play();                                 
    void stop();                                 
    long int update(long int mstimestamp);       
    
    virtual void seek(long int ms_streamtime_);  
    virtual long int pullNextFrame();            
};                                           // <pyapi>
 
 
class AbstractFileThread : public Thread {              // <pyapi>
    
public:                                                 // <pyapi>
    AbstractFileThread(const char* name, FrameFifoContext fifo_ctx=FrameFifoContext(10));   // <pyapi>
    virtual ~AbstractFileThread();                                                          // <pyapi>
 
protected: // frame input
    FrameFifo               infifo;           
    FifoFrameFilter         infilter;         
 
protected:
    virtual void preRun();
    virtual void postRun();
    virtual void run();
};                                                      // <pyapi>
 
 
 
 
 
#endif