mirrors/scrcpy
0
0
Fork 0
mirror of https://github.com/Genymobile/scrcpy.git synced 2025-08-02 14:19:05 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

Rename demuxer to video_demuxer

Browse source 
There will be another demuxer instance for audio.
This commit is contained in:
Romain Vimont 2023-02-06 10:08:01 +01:00
commit ceb3423b98
1 changed files with 19 additions and 16 deletions
Download patch file Download diff file Expand all files Collapse all files

35
app/src/scrcpy.c
View file

@ -40,7 +40,7 @@
struct scrcpy { struct scrcpy {
struct sc_server server; struct sc_server server;
struct sc_screen screen; struct sc_screen screen;
struct sc_demuxer demuxer; struct sc_demuxer video_demuxer;
struct sc_decoder decoder; struct sc_decoder decoder;
struct sc_recorder recorder; struct sc_recorder recorder;
#ifdef HAVE_V4L2 #ifdef HAVE_V4L2
@ -250,7 +250,8 @@ sc_recorder_on_ended(struct sc_recorder *recorder, bool success,
} }
static void static void
sc_demuxer_on_ended(struct sc_demuxer *demuxer, bool eos, void *userdata) { sc_video_demuxer_on_ended(struct sc_demuxer *demuxer, bool eos,
void *userdata) {
(void) demuxer; (void) demuxer;
(void) userdata; (void) userdata;
@ -317,7 +318,7 @@ scrcpy(struct scrcpy_options *options) {
#ifdef HAVE_V4L2 #ifdef HAVE_V4L2
bool v4l2_sink_initialized = false; bool v4l2_sink_initialized = false;
#endif #endif
bool demuxer_started = false; bool video_demuxer_started = false;
#ifdef HAVE_USB #ifdef HAVE_USB
bool aoa_hid_initialized = false; bool aoa_hid_initialized = false;
bool hid_keyboard_initialized = false; bool hid_keyboard_initialized = false;
@ -445,17 +446,18 @@ scrcpy(struct scrcpy_options *options) {
av_log_set_callback(av_log_callback); av_log_set_callback(av_log_callback);
static const struct sc_demuxer_callbacks demuxer_cbs = { static const struct sc_demuxer_callbacks video_demuxer_cbs = {
.on_ended = sc_demuxer_on_ended, .on_ended = sc_video_demuxer_on_ended,
}; };
sc_demuxer_init(&s->demuxer, s->server.video_socket, &demuxer_cbs, NULL); sc_demuxer_init(&s->video_demuxer, s->server.video_socket,
&video_demuxer_cbs, NULL);
if (dec) { if (dec) {
sc_demuxer_add_sink(&s->demuxer, &dec->packet_sink); sc_demuxer_add_sink(&s->video_demuxer, &dec->packet_sink);
} }
if (rec) { if (rec) {
sc_demuxer_add_sink(&s->demuxer, &rec->packet_sink); sc_demuxer_add_sink(&s->video_demuxer, &rec->packet_sink);
} }
struct sc_controller *controller = NULL; struct sc_controller *controller = NULL;
@ -663,17 +665,17 @@ aoa_hid_end:
#endif #endif
// now we consumed the header values, the socket receives the video stream // now we consumed the header values, the socket receives the video stream
// start the demuxer // start the video demuxer
if (!sc_demuxer_start(&s->demuxer)) { if (!sc_demuxer_start(&s->video_demuxer)) {
goto end; goto end;
} }
demuxer_started = true; video_demuxer_started = true;
ret = event_loop(s); ret = event_loop(s);
LOGD("quit..."); LOGD("quit...");
// Close the window immediately on closing, because screen_destroy() may // Close the window immediately on closing, because screen_destroy() may
// only be called once the demuxer thread is joined (it may take time) // only be called once the video demuxer thread is joined (it may take time)
sc_screen_hide_window(&s->screen); sc_screen_hide_window(&s->screen);
end: end:
@ -714,8 +716,8 @@ end:
// now that the sockets are shutdown, the demuxer and controller are // now that the sockets are shutdown, the demuxer and controller are
// interrupted, we can join them // interrupted, we can join them
if (demuxer_started) { if (video_demuxer_started) {
sc_demuxer_join(&s->demuxer); sc_demuxer_join(&s->video_demuxer);
} }
#ifdef HAVE_V4L2 #ifdef HAVE_V4L2
@ -734,8 +736,9 @@ end:
} }
#endif #endif
// Destroy the screen only after the demuxer is guaranteed to be finished, // Destroy the screen only after the video demuxer is guaranteed to be
// because otherwise the screen could receive new frames after destruction // finished, because otherwise the screen could receive new frames after
// destruction
if (screen_initialized) { if (screen_initialized) {
sc_screen_join(&s->screen); sc_screen_join(&s->screen);
sc_screen_destroy(&s->screen); sc_screen_destroy(&s->screen);