restream.h

#ifndef _INCLUDE_RESTREAM_H_
    #define _INCLUDE_RESTREAM_H_

    #define _GNU_SOURCE

    #include <pthread.h>
    #include <libavcodec/avcodec.h>
    #include <libavformat/avformat.h>
    #include <libavfilter/buffersink.h>
    #include <libavfilter/buffersrc.h>
    #include <libavutil/opt.h>
    #include <libavutil/imgutils.h>
    #include <libavutil/pixdesc.h>
    #include <libavutil/timestamp.h>
    #include <libavutil/time.h>
    #include <libavutil/mem.h>
    #include <libswscale/swscale.h>
    #include <stdio.h>
    #include <stdlib.h>
    #include <dirent.h>
    #include <errno.h>
    #include <sys/types.h>
    #include <sys/stat.h>
    #include <fcntl.h>
    #include <unistd.h>
    #include <signal.h>
    #include <sys/time.h>
    #include <time.h>

    #define SLEEP(seconds, nanoseconds) {              \
                    struct timespec tv;                \
                    tv.tv_sec = (seconds);             \
                    tv.tv_nsec = (nanoseconds);        \
                    while (nanosleep(&tv, &tv) == -1); \
            }

    /* values of boolean */
    #ifndef FALSE
        #define FALSE   0
    #endif
    #ifndef TRUE
        #define TRUE    1
    #endif

    enum PIPE_STATUS{
        PIPE_IS_OPEN,
        PIPE_IS_CLOSED,
        PIPE_NEEDS_RESET
    };
    enum READER_STATUS{
        READER_STATUS_CLOSED,
        READER_STATUS_PAUSED,
        READER_STATUS_OPEN,
        READER_STATUS_INACTIVE,
        READER_STATUS_READING,
        READER_STATUS_READBYTE
    };
    enum READER_ACTION{
        READER_ACTION_START,
        READER_ACTION_OPEN,
        READER_ACTION_CLOSE,
        READER_ACTION_END,
        READER_ACTION_BYTE
    };

    typedef struct StreamContext {
        AVCodecContext      *dec_ctx;
        AVCodecContext      *enc_ctx;
    } StreamContext;

    struct guide_item {
        char   *movie1_filename;
        char   *movie2_filename;

        char   *movie1_displayname;
        char   *movie2_displayname;
        char   *guide_filename;
        char   *guide_displayname;

        char   time1_st[25];
        char   time1_en[25];

        char   time2_st[25];
        char   time2_en[25];

    };

    typedef struct ctx_restream {
        char                    *in_filename;
        char                    *out_filename;
        AVFormatContext         *ifmt_ctx;
        AVFormatContext         *ofmt_ctx;
        AVOutputFormat          *ofmt;
        AVPacket                pkt;

        int                     stream_index;
        int                     audio_index;
        int                     video_index;
        StreamContext           *stream_ctx;
        int                     stream_count;

        int64_t                 time_start;
        int64_t                 dts_start;
        int64_t                 dts_last;
        int64_t                 dts_base;

        unsigned int            rand_seed;

        struct playlist_item    *playlist;
        char                    *playlist_dir;
        char           *function_name;
        int                     finish;
        int                     playlist_count;
        int                     playlist_index;
        char                    *playlist_sort_method;   //a =alpha, r = random

        struct guide_item       *guide_info;

        volatile enum PIPE_STATUS       pipe_state;
        volatile enum READER_STATUS     reader_status;
        volatile enum READER_ACTION     reader_action;

        int64_t                watchdog_reader;
        int64_t                watchdog_playlist;
        int64_t                connect_start;
        int                    soft_restart;
        pthread_t              reader_thread;
        pthread_t              process_playlist_thread;
        pthread_mutex_t        mutex_reader;   /* mutex used with the output reader */


    } ctx_restream;
    /**********************************************************/

    struct channel_context {
        struct channel_item   *channel_info;
        int                    channel_count;
    };

    /* Global shutdown flag*/
    volatile int finish;  /*Stop movie playing*/
    volatile int thread_count;
    int restrm_interrupt(void *ctx);

#endif