X-Git-Url: https://git.sesse.net/?a=blobdiff_plain;f=ffmpeg_capture.cpp;h=235393a5058b0a2215a8ea021becc6c1fc75ab9a;hb=a5746714e6ca1e665bf9e74344e67712443f947a;hp=c5f71b67a20a1848d2b346038c80f660d645328a;hpb=9e821958485d7f5845c3b24635df1f3243092e02;p=nageru

diff --git a/ffmpeg_capture.cpp b/ffmpeg_capture.cpp
index c5f71b6..235393a 100644
--- a/ffmpeg_capture.cpp
+++ b/ffmpeg_capture.cpp
@@ -208,7 +208,6 @@ YCbCrFormat decode_ycbcr_format(const AVPixFmtDescriptor *desc, const AVFrame *f
 FFmpegCapture::FFmpegCapture(const string &filename, unsigned width, unsigned height)
 	: filename(filename), width(width), height(height), video_timebase{1, 1}
 {
-	// Not really used for anything.
 	description = "Video: " + filename;
 
 	last_frame = steady_clock::now();
@@ -283,9 +282,15 @@ void FFmpegCapture::producer_thread_func()
 	pthread_setname_np(pthread_self(), thread_name);
 
 	while (!producer_thread_should_quit.should_quit()) {
-		string pathname = search_for_file(filename);
-		if (filename.empty()) {
-			fprintf(stderr, "%s not found, sleeping one second and trying again...\n", filename.c_str());
+		string filename_copy;
+		{
+			lock_guard<mutex> lock(filename_mu);
+			filename_copy = filename;
+		}
+
+		string pathname = search_for_file(filename_copy);
+		if (pathname.empty()) {
+			fprintf(stderr, "%s not found, sleeping one second and trying again...\n", filename_copy.c_str());
 			send_disconnected_frame();
 			producer_thread_should_quit.sleep_for(seconds(1));
 			continue;
@@ -322,6 +327,7 @@ void FFmpegCapture::send_disconnected_frame()
 		if (pixel_format == bmusb::PixelFormat_8BitBGRA) {
 			video_format.stride = width * 4;
 			video_frame.len = width * height * 4;
+			memset(video_frame.data, 0, video_frame.len);
 		} else {
 			video_format.stride = width;
 			current_frame_ycbcr_format.luma_coefficients = YCBCR_REC_709;
@@ -334,8 +340,9 @@ void FFmpegCapture::send_disconnected_frame()
 			current_frame_ycbcr_format.cr_x_position = 0.0f;
 			current_frame_ycbcr_format.cr_y_position = 0.0f;
 			video_frame.len = width * height * 2;
+			memset(video_frame.data, 0, width * height);
+			memset(video_frame.data + width * height, 128, width * height);  // Valid for both NV12 and planar.
 		}
-		memset(video_frame.data, 0, video_frame.len);
 
 		frame_callback(-1, AVRational{1, TIMEBASE}, -1, AVRational{1, TIMEBASE}, timecode++,
 			video_frame, /*video_offset=*/0, video_format,