86 lines
1.8 KiB
C
86 lines
1.8 KiB
C
#ifndef SC_VIDEO_BUFFER_H
|
|
#define SC_VIDEO_BUFFER_H
|
|
|
|
#include "common.h"
|
|
|
|
#include <stdbool.h>
|
|
|
|
#include "frame_buffer.h"
|
|
#include "util/queue.h"
|
|
#include "util/thread.h"
|
|
|
|
// forward declarations
|
|
typedef struct AVFrame AVFrame;
|
|
|
|
struct sc_video_buffer_frame {
|
|
AVFrame *frame;
|
|
sc_tick system_pts;
|
|
struct sc_video_buffer_frame *next;
|
|
};
|
|
|
|
struct sc_video_buffer_frame_queue SC_QUEUE(struct sc_video_buffer_frame);
|
|
|
|
struct sc_clock {
|
|
double coeff;
|
|
sc_tick offset;
|
|
unsigned weight;
|
|
|
|
struct {
|
|
sc_tick system;
|
|
sc_tick stream;
|
|
} last;
|
|
|
|
sc_tick mad; // mean absolute difference
|
|
};
|
|
|
|
struct sc_video_buffer {
|
|
struct sc_frame_buffer fb;
|
|
|
|
unsigned buffering_ms;
|
|
|
|
// only if buffering_ms > 0
|
|
struct {
|
|
sc_thread thread;
|
|
sc_mutex mutex;
|
|
sc_cond queue_cond;
|
|
sc_cond wait_cond;
|
|
|
|
struct sc_clock clock;
|
|
struct sc_video_buffer_frame_queue queue;
|
|
bool stopped;
|
|
} b; // buffering
|
|
|
|
const struct sc_video_buffer_callbacks *cbs;
|
|
void *cbs_userdata;
|
|
};
|
|
|
|
struct sc_video_buffer_callbacks {
|
|
void (*on_new_frame)(struct sc_video_buffer *vb, bool previous_skipped,
|
|
void *userdata);
|
|
};
|
|
|
|
bool
|
|
sc_video_buffer_init(struct sc_video_buffer *vb, unsigned buffering_ms,
|
|
const struct sc_video_buffer_callbacks *cbs,
|
|
void *cbs_userdata);
|
|
|
|
bool
|
|
sc_video_buffer_start(struct sc_video_buffer *vb);
|
|
|
|
void
|
|
sc_video_buffer_stop(struct sc_video_buffer *vb);
|
|
|
|
void
|
|
sc_video_buffer_join(struct sc_video_buffer *vb);
|
|
|
|
void
|
|
sc_video_buffer_destroy(struct sc_video_buffer *vb);
|
|
|
|
bool
|
|
sc_video_buffer_push(struct sc_video_buffer *vb, const AVFrame *frame);
|
|
|
|
void
|
|
sc_video_buffer_consume(struct sc_video_buffer *vb, AVFrame *dst);
|
|
|
|
#endif
|