#include <stdint.h>
extern "C" {
+#include <libavformat/avformat.h>
#include <libavformat/avio.h>
}
#include "frame_on_disk.h"
#include "jpeg_frame_view.h"
-#include "ref_counted_gl_sync.h"
+#include "shared/ref_counted_gl_sync.h"
#include "queue_spot_holder.h"
+#include <atomic>
#include <chrono>
#include <condition_variable>
#include <deque>
class VideoStream {
public:
- VideoStream();
+ VideoStream(AVFormatContext *file_avctx); // nullptr if output to stream.
~VideoStream();
void start();
void stop();
void encode_thread_func();
std::thread encode_thread;
+ std::atomic<bool> should_quit{false};
static int write_packet2_thunk(void *opaque, uint8_t *buf, int buf_size, AVIODataMarkerType type, int64_t time);
int write_packet2(uint8_t *buf, int buf_size, AVIODataMarkerType type, int64_t time);
std::deque<QueuedFrame> frame_queue; // Under <queue_lock>.
std::condition_variable queue_changed;
- std::unique_ptr<Mux> stream_mux; // To HTTP.
- std::string stream_mux_header;
+ AVFormatContext *avctx;
+ std::unique_ptr<Mux> mux; // To HTTP, or to file.
+ std::string stream_mux_header; // Only used in HTTP.
bool seen_sync_markers = false;
+ bool output_fast_forward;
std::unique_ptr<YCbCrConverter> ycbcr_converter;
std::unique_ptr<YCbCrConverter> ycbcr_semiplanar_converter;