| 1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374 |
- #pragma once
- #include <obs-avc.h>
- #include <obs-module.h>
- #include <obs-hotkey.h>
- #include <util/circlebuf.h>
- #include <util/darray.h>
- #include <util/dstr.h>
- #include <util/pipe.h>
- #include <util/platform.h>
- #include <util/threading.h>
- struct ffmpeg_muxer {
- obs_output_t *output;
- os_process_pipe_t *pipe;
- int64_t stop_ts;
- uint64_t total_bytes;
- bool sent_headers;
- volatile bool active;
- volatile bool capturing;
- volatile bool stopping;
- struct dstr path;
- struct dstr printable_path;
- struct dstr muxer_settings;
- struct dstr stream_key;
- /* replay buffer and split file */
- int64_t cur_size;
- int64_t cur_time;
- int64_t max_size;
- int64_t max_time;
- /* replay buffer */
- int64_t save_ts;
- int keyframes;
- obs_hotkey_id hotkey;
- volatile bool muxing;
- DARRAY(struct encoder_packet) mux_packets;
- /* split file */
- bool found_video;
- bool found_audio[MAX_AUDIO_MIXES];
- int64_t video_pts_offset;
- int64_t audio_dts_offsets[MAX_AUDIO_MIXES];
- /* these are accessed both by replay buffer and by HLS */
- pthread_t mux_thread;
- bool mux_thread_joinable;
- struct circlebuf packets;
- /* HLS only */
- int keyint_sec;
- pthread_mutex_t write_mutex;
- os_sem_t *write_sem;
- os_event_t *stop_event;
- bool is_hls;
- int dropped_frames;
- int min_priority;
- int64_t last_dts_usec;
- bool is_network;
- bool split_file;
- bool reset_timestamps;
- bool allow_overwrite;
- };
- bool stopping(struct ffmpeg_muxer *stream);
- bool active(struct ffmpeg_muxer *stream);
- void start_pipe(struct ffmpeg_muxer *stream, const char *path);
- bool write_packet(struct ffmpeg_muxer *stream, struct encoder_packet *packet);
- bool send_headers(struct ffmpeg_muxer *stream);
- int deactivate(struct ffmpeg_muxer *stream, int code);
- void ffmpeg_mux_stop(void *data, uint64_t ts);
- uint64_t ffmpeg_mux_total_bytes(void *data);
|
